All Types

hu.akarnokd.kotlin.flow.BehaviorSubject

Caches one item and replays it to fresh collectors.

hu.akarnokd.kotlin.flow.PublishSubject

Multicasts items to any number of collectors when they are ready to receive.

hu.akarnokd.kotlin.flow.ReplaySubject

Caches and replays some or all items to collectors.

hu.akarnokd.kotlin.flow.Resumable

Primitive for suspending and resuming coroutines on demand

hu.akarnokd.kotlin.flow.SubjectAPI

Base interface for suspendable push signals emit, emitError and complete.