T
- the value type pushed@FunctionalInterface
public 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(@NonNull ObservableEmitter<T> emitter)
Called for each
Observer that subscribes. |
void subscribe(@NonNull @NonNull ObservableEmitter<T> emitter) throws java.lang.Throwable
Observer
that subscribes.emitter
- the safe emitter instance, never null
java.lang.Throwable
- on error