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 |
|---|---|
| public void | subscribe(CompletableEmitter
the safe emitter instance, never null emitter)Called for each CompletableObserver that subscribes. |
| subscribe | back to summary |
|---|---|
| public void subscribe(CompletableEmitter emitter) throws Exception Called for each CompletableObserver that subscribes.
| |