Uses of Interface
rx.Observable.OnSubscribe

Packages that use Observable.OnSubscribe

Package	Description
rx	Rx Observables
rx.observables
rx.plugins
rx.subjects

Uses of Observable.OnSubscribe in rx

Methods in rx with parameters of type Observable.OnSubscribe

Modifier and Type	Method and Description
static <T> Observable<T>	Observable.create(Observable.OnSubscribe<T> f) Returns an Observable that will execute the specified function when a Subscriber subscribes to it.

Constructors in rx with parameters of type Observable.OnSubscribe

Constructor and Description
Observable(Observable.OnSubscribe<T> f) Creates an Observable with a Function to execute when it is subscribed to.

Uses of Observable.OnSubscribe in rx.observables

Classes in rx.observables that implement Observable.OnSubscribe

Modifier and Type	Class and Description
class	AbstractOnSubscribe<T,S> Abstract base class for the Observable.OnSubscribe interface that helps you build Observable sources one onNext at a time, and automatically supports unsubscription and backpressure.

Methods in rx.observables with parameters of type Observable.OnSubscribe

Modifier and Type	Method and Description
static <K,T> GroupedObservable<K,T>	GroupedObservable.create(K key, Observable.OnSubscribe<T> f) Returns an Observable that will execute the specified function when a Subscriber subscribes to it.

Constructors in rx.observables with parameters of type Observable.OnSubscribe

Constructor and Description
ConnectableObservable(Observable.OnSubscribe<T> onSubscribe)
GroupedObservable(K key, Observable.OnSubscribe<T> onSubscribe)

Uses of Observable.OnSubscribe in rx.plugins

Methods in rx.plugins that return Observable.OnSubscribe

Modifier and Type	Method and Description
<T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f) Invoked during the construction by Observable.create(OnSubscribe)
<T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance, Observable.OnSubscribe<T> onSubscribe) Invoked before Observable.subscribe(rx.Subscriber) is about to be executed.

Methods in rx.plugins with parameters of type Observable.OnSubscribe

Modifier and Type	Method and Description
<T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f) Invoked during the construction by Observable.create(OnSubscribe)
<T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance, Observable.OnSubscribe<T> onSubscribe) Invoked before Observable.subscribe(rx.Subscriber) is about to be executed.

Uses of Observable.OnSubscribe in rx.subjects

Constructors in rx.subjects with parameters of type Observable.OnSubscribe

Constructor and Description
AsyncSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state)
BehaviorSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state)
PublishSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state)
Subject(Observable.OnSubscribe<R> onSubscribe)
TestSubject(Observable.OnSubscribe<T> onSubscribe, rx.subjects.SubjectSubscriptionManager<T> state, TestScheduler scheduler)