I have a small piece of zlayer code. The layers are defined as vals, like so:

  private final val kafkaLayer: Layer[Error, Kafka]                                      = Config.live >>> Kafka.live
  private final val transactorLayer: Layer[Error, DbTransactor]                          = (Blocking.live ++ ConfigDb.live) >>> db.hikariLayer
  private final val queryConfigLayer: Layer[

When creating an infinite stream. To stop after the first item, you need to do:

totalCheckouts()
   .select().first()
   .subscribe(). withSubscriber(AssertSubscriber.create())
        .request(1)
        .await()
        .assertItems(0L)
        .assertCompleted();

But having the possibility to wait for the next event (item, failure, completion) would be a nice addition.

As an engineer using kafka-ui in production, I would like to have 100% test coverage.

Please add specs to all Topics page components (src/components/Topics)

Hello frideos team,

I try to build web application, but it stuck with error:

══╡ EXCEPTION CAUGHT BY WIDGETS LIBRARY ╞═══════════════════════════════════════════════════════════
The following UnsupportedError was thrown building _InheritedState:
Unsupported operation: Platform._operatingSystem

The relevant error-causing widget was:
  _InheritedState
  file:///Users/macbook/flutter/