| 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 |
|---|