public interface CompletableOnSubscribe
subscribe()
method that receives
an instance of a CompletableEmitter
instance that allows pushing
an event in a cancellation-safe manner.Modifier and Type | Method and Description |
---|---|
void |
subscribe(CompletableEmitter emitter)
Called for each CompletableObserver that subscribes.
|
void subscribe(@NonNull CompletableEmitter emitter) throws Exception
emitter
- the safe emitter instance, never nullException
- on error