SubjectAPI

interface SubjectAPI<T> : FlowCollector<T> , Flow<T>
Content copied to clipboard

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

Functions

collect
Link copied to clipboard
abstract suspend fun collect(collector: FlowCollector<T>)
Content copied to clipboard
collectorCount
Link copied to clipboard
abstract fun collectorCount(): Int
Content copied to clipboard
Returns the number of collectors waiting for data.
complete
Link copied to clipboard
abstract suspend fun complete()
Content copied to clipboard
Indicate no further items will be produced.
emit
Link copied to clipboard
abstract suspend fun emit(value: T)
Content copied to clipboard
emitError
Link copied to clipboard
abstract suspend fun emitError(ex: Throwable)
Content copied to clipboard
Signal an Throwable to the collector.
hasCollectors
Link copied to clipboard
abstract fun hasCollectors(): Boolean
Content copied to clipboard
Returns true if this subject has collectors waiting for data.

Inheritors

BehaviorSubject
Link copied to clipboard
MulticastSubject
Link copied to clipboard
PublishSubject
Link copied to clipboard
ReplaySubject
Link copied to clipboard
UnicastSubject
Link copied to clipboard
UnicastWorkSubject
Link copied to clipboard