T
- the value type pushedpublic interface FlowableOnSubscribe<T>
subscribe()
method that receives
an instance of a FlowableEmitter
instance that allows pushing
events in a backpressure-safe and cancellation-safe manner.Modifier and Type | Method and Description |
---|---|
void |
subscribe(FlowableEmitter<T> emitter)
Called for each Subscriber that subscribes.
|
void subscribe(@NonNull FlowableEmitter<T> emitter) throws Exception
emitter
- the safe emitter instance, never nullException
- on error