class BehaviorSubject<T> : AbstractFlow<T>, SubjectAPI<T>
Caches one item and replays it to fresh collectors. |
|
class PublishSubject<T> : AbstractFlow<T>, SubjectAPI<T>
Multicasts items to any number of collectors when they are ready to receive. |
|
class ReplaySubject<T> : AbstractFlow<T>, SubjectAPI<T>
Caches and replays some or all items to collectors. |
|
open class Resumable : AtomicReference<Continuation<Any>>
Primitive for suspending and resuming coroutines on demand |
|
interface SubjectAPI<T> : FlowCollector<T>
Base interface for suspendable push signals emit, emitError and complete. |