io.reactivex.Emitter<T> |
![]()
FlowableEmitter<T>,
ObservableEmitter<T>
|
Base interface for emitting signals in a push-fashion in various generator-like source operators (create, generate).
Public Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
abstract void |
onComplete()
Signal a completion.
| ||||||||||
abstract void |
onError(Throwable error)
Signal a Throwable exception.
| ||||||||||
abstract void |
onNext(T value)
Signal a normal value.
|
Signal a completion.
Signal a Throwable exception.
error | the Throwable to signal, not null |
---|
Signal a normal value.
value | the value to signal, not null |
---|