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