MulticastSubject

@FlowPreview()

class MulticastSubject<T>(expectedCollectors: Int) : AbstractFlow<T> , SubjectAPI<T>

A subject implementation that awaits a certain number of collectors to start consuming, then allows the producer side to deliver items to them.

Parameters

the element type of the [Flow]

bufferSize

the number of items to buffer until consumers arrive

MulticastSubject

fun MulticastSubject(expectedCollectors: Int)

the element type of the [Flow]

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.

collectors

producer

remainingCollectors

terminated