io.reactivex.MaybeOnSubscribe<T> |
A functional interface that has a subscribe()
method that receives
an instance of a MaybeEmitter
instance that allows pushing
an event in a cancellation-safe manner.
Public Methods | |||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
abstract void |
subscribe(MaybeEmitter<T> e)
Called for each MaybeObserver that subscribes.
|
Called for each MaybeObserver that subscribes.
e | the safe emitter instance, never null |
---|
Exception | on error |
---|