T
- the value type pushedpublic interface SingleOnSubscribe<T>
subscribe()
method that receives
an instance of a SingleEmitter
instance that allows pushing
an event in a cancellation-safe manner.Modifier and Type | Method and Description |
---|---|
void |
subscribe(SingleEmitter<T> e)
Called for each SingleObserver that subscribes.
|
void subscribe(@NonNull SingleEmitter<T> e) throws java.lang.Exception
e
- the safe emitter instance, never nulljava.lang.Exception
- on error