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