public interface

ObservableOnSubscribe

io.reactivex.ObservableOnSubscribe<T>

Class Overview

A functional interface that has a subscribe() method that receives an instance of an ObservableEmitter instance that allows pushing events in a cancellation-safe manner.

Summary

Public Methods
abstract void subscribe(ObservableEmitter<T> e)
Called for each Observer that subscribes.

Public Methods

public abstract void subscribe (ObservableEmitter<T> e)

Called for each Observer that subscribes.

Parameters
e the safe emitter instance, never null
Throws
Exception on error