PublishSubject

@FlowPreview()

class PublishSubject<T> : AbstractFlow<T> , SubjectAPI<T>

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

Parameters

the element type of the [Flow]

PublishSubject

the element type of the [Flow]

collect

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

collectorCount

open override fun collectorCount(): Int

Returns the current number of collectors.

collectSafely

@FlowPreview()

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

Start collecting signals from this PublishSubject.

complete

open suspend override fun complete()

Indicate no further items will be emitted

emit

open suspend override fun emit(value: T)

Emit the value to all current collectors, waiting for each of them to be ready for consuming it.

emitError

open suspend override fun emitError(ex: Throwable)

Throw an error on the consumer side.

hasCollectors

open override fun hasCollectors(): Boolean

Returns true if this PublishSubject has any collectors.