UnicastWorkSubject

Buffers items until a single collector collects them.

Parameters

the item type

UnicastWorkSubject

the item type

Companion

collect

suspend override fun collect(collector: FlowCollector<T>)

collectorCount

open override fun collectorCount(): Int

Returns the number of collectors waiting for data.

collectSafely

open suspend override fun collectSafely(collector: FlowCollector<T>)

complete

open suspend override fun complete()

Indicate no further items will be produced.

emit

open suspend override fun emit(value: T)

emitError

open suspend override fun emitError(ex: Throwable)

Signal an Throwable to the collector.

hasCollectors

open override fun hasCollectors(): Boolean

Returns true if this subject has collectors waiting for data.

current

queue

resumable

terminal