Uses of Interface
rx.Observable.OnSubscribe

Packages that use Observable.OnSubscribe

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.util
rx.observables	Classes extending the Observable base reactive class, synchronous and asynchronous event generators.
rx.plugins	Callback types and a central plugin handler class to hook into the lifecycle of the base reactive types and schedulers.
rx.subjects	Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).

Uses of Observable.OnSubscribe in rx

Classes in rx that implement Observable.OnSubscribe

Modifier and Type	Class	Description
(package private) static final class	Observable.OnSubscribeExtend<T>	Transforms a OnSubscribe.call() into an Observable.subscribe() call.

Fields in rx declared as Observable.OnSubscribe

Modifier and Type	Field	Description
(package private) final Observable.OnSubscribe<T>	Observable.onSubscribe
(package private) final Observable.OnSubscribe<T>	Single.onSubscribe

Methods in rx with parameters of type Observable.OnSubscribe

Modifier and Type	Method	Description
static <T> Observable<T>	Observable.create(Observable.OnSubscribe<T> f)	This method requires advanced knowledge about building operators and data sources; please consider other standard methods first; Returns an Observable that will execute the specified function when a Subscriber subscribes to it.

Method parameters in rx with type arguments of type Observable.OnSubscribe

Modifier and Type	Method	Description
<R> R	Observable.extend(Func1<? super Observable.OnSubscribe<T>,? extends R> conversion)	Passes all emitted values from this Observable to the provided conversion function to be collected and returned as a single value.

Constructors in rx with parameters of type Observable.OnSubscribe

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

Uses of Observable.OnSubscribe in rx.internal.operators

Classes in rx.internal.operators that implement Observable.OnSubscribe

Modifier and Type	Class	Description
(package private) static final class	BufferUntilSubscriber.OnSubscribeAction<T>
(package private) static final class	CachedObservable.CachedSubscribe<T>	Manages the subscription of child subscribers by setting up a replay producer and performs auto-connection of the very first subscription.
enum	EmptyObservableHolder	Holds a singleton instance of an empty Observable which is stateless and completes the child subscriber immediately.
enum	NeverObservableHolder	Holds a singleton instance of a never Observable which is stateless doesn't call any of the Subscriber's methods.
final class	OnSubscribeAmb<T>	Given multiple Observables, propagates the one that first emits an item.
final class	OnSubscribeAutoConnect<T>	Wraps a ConnectableObservable and calls its connect() method once the specified number of Subscribers have subscribed.
final class	OnSubscribeCollect<T,R>
final class	OnSubscribeCombineLatest<T,R>
final class	OnSubscribeConcatMap<T,R>	Maps a source sequence into Observables and concatenates them in order, subscribing to one at a time.
final class	OnSubscribeDefer<T>	Do not create the Observable until an Observer subscribes; create a fresh Observable on each subscription.
final class	OnSubscribeDelaySubscription<T>	Delays the subscription to the source by the given amount, running on the given scheduler.
final class	OnSubscribeDelaySubscriptionOther<T,U>	Delays the subscription to the main source until the other observable fires an event or completes.
final class	OnSubscribeDelaySubscriptionWithSelector<T,U>	Delays the subscription until the Observable emits an event.
final class	OnSubscribeDetach<T>	Nulls out references to upstream data structures when the source terminates or the child unsubscribes.
final class	OnSubscribeFilter<T>	Filters an Observable by discarding any items it emits that do not meet some test.
final class	OnSubscribeFlattenIterable<T,R>	Flattens a sequence if Iterable sources, generated via a function, into a single sequence.
(package private) static final class	OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R>	A custom flattener that works from a scalar value and computes the iterable during subscription time.
final class	OnSubscribeFromArray<T>
final class	OnSubscribeFromAsync<T>
final class	OnSubscribeFromCallable<T>	Do not invoke the function until an Observer subscribes; Invokes function on each subscription.
final class	OnSubscribeFromIterable<T>	Converts an Iterable sequence into an Observable.
final class	OnSubscribeGroupJoin<T1,T2,D1,D2,R>	Correlates two sequences when they overlap and groups the results.
(package private) static final class	OnSubscribeGroupJoin.WindowObservableFunc<T>	The reference-counted window observable.
final class	OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R>	Correlates the elements of two sequences based on overlapping durations.
final class	OnSubscribeLift<T,R>	Transforms the downstream Subscriber into a Subscriber via an operator callback and calls the parent OnSubscribe.call() method with it.
final class	OnSubscribeMap<T,R>	Applies a function of your choosing to every item emitted by an Observable, and emits the results of this transformation as a new Observable.
final class	OnSubscribeOnAssembly<T>	Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
final class	OnSubscribePublishMulticast<T>	Multicasts notifications coming through its input Subscriber view to its client Subscribers via lockstep backpressure mode.
final class	OnSubscribeRange	Emit ints from start to end inclusive.
final class	OnSubscribeRedo<T>
final class	OnSubscribeReduce<T>
final class	OnSubscribeReduceSeed<T,R>
final class	OnSubscribeRefCount<T>	Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.
final class	OnSubscribeTakeLastOne<T>
final class	OnSubscribeThrow<T>	An Observable that invokes onError when the Observer subscribes to it.
final class	OnSubscribeTimerOnce	Timer that emits a single 0L and completes after the specified time.
final class	OnSubscribeTimerPeriodically	Emit 0L after the initial period and ever increasing number after each period.
(package private) static class	OnSubscribeToObservableFuture.ToObservableFuture<T>
final class	OnSubscribeUsing<T,Resource>	Constructs an observable sequence that depends on a resource object.
(package private) static final class	OperatorGroupBy.State<T,K>
final class	OperatorSubscribeOn<T>	Subscribes Observers on the specified Scheduler.
final class	OperatorWithLatestFromMany<T,R>

Fields in rx.internal.operators declared as Observable.OnSubscribe

Modifier and Type	Field	Description
(package private) final Observable.OnSubscribe<T>	OnSubscribeLift.parent
(package private) final Observable.OnSubscribe<T>	OnSubscribeOnAssembly.source

Methods in rx.internal.operators that return Observable.OnSubscribe

Modifier and Type	Method	Description
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Iterable<? extends Observable<? extends T>> sources)	Given a set of Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2)	Given two Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3)	Given three Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4)	Given four Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5)	Given five Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6)	Given six Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7)	Given seven Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8)	Given eight Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeAmb.amb(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6, Observable<? extends T> o7, Observable<? extends T> o8, Observable<? extends T> o9)	Given nine Observables, propagates the one that first emits an item.
static <T> Observable.OnSubscribe<T>	OnSubscribeToObservableFuture.toObservableFuture(Future<? extends T> that)
static <T> Observable.OnSubscribe<T>	OnSubscribeToObservableFuture.toObservableFuture(Future<? extends T> that, long time, TimeUnit unit)

Constructors in rx.internal.operators with parameters of type Observable.OnSubscribe

Modifier	Constructor	Description
private	CachedObservable(Observable.OnSubscribe<T> onSubscribe, CachedObservable.CacheState<T> state)	Private constructor because state needs to be shared between the Observable body and the onSubscribe function.
	OnSubscribeLift(Observable.OnSubscribe<T> parent, Observable.Operator<? extends R,? super T> operator)
	OnSubscribeOnAssembly(Observable.OnSubscribe<T> source)
private	OperatorPublish(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, AtomicReference<OperatorPublish.PublishSubscriber<T>> current)
private	OperatorReplay(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, AtomicReference<OperatorReplay.ReplaySubscriber<T>> current, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory)

Uses of Observable.OnSubscribe in rx.internal.util

Classes in rx.internal.util that implement Observable.OnSubscribe

Modifier and Type	Class	Description
(package private) static final class	ScalarSynchronousObservable.JustOnSubscribe<T>	The OnSubscribe callback for the Observable constructor.
(package private) static final class	ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T>	The OnSubscribe implementation that creates the ScalarAsyncProducer for each incoming subscriber.

Uses of Observable.OnSubscribe in rx.observables

Classes in rx.observables that implement Observable.OnSubscribe

Modifier and Type	Class	Description
class	AsyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
(package private) static final class	AsyncOnSubscribe.AsyncOnSubscribeImpl<S,T>	An implementation of AsyncOnSubscribe that delegates AsyncOnSubscribe.next(Object, long, Observer), AsyncOnSubscribe.generateState(), and AsyncOnSubscribe.onUnsubscribe(Object) to provided functions/closures.
(package private) static final class	AsyncOnSubscribe.UnicastSubject.State<T>
class	SyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
(package private) static final class	SyncOnSubscribe.SyncOnSubscribeImpl<S,T>	An implementation of SyncOnSubscribe that delegates invalid reference SyncOnSubscribe#next(Object, Subscriber) , SyncOnSubscribe.generateState(), and SyncOnSubscribe.onUnsubscribe(Object) to provided functions/closures.

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

Modifier and Type	Method	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

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

Uses of Observable.OnSubscribe in rx.plugins

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

Modifier and Type	Field	Description
(package private) static Func1<Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.onObservableCreate
(package private) static Func1<Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.onObservableCreate
(package private) static Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.onObservableStart
(package private) static Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.onObservableStart
(package private) static Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.onSingleStart
(package private) static Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.onSingleStart

Methods in rx.plugins that return Observable.OnSubscribe

Modifier and Type	Method	Description
static <T> Observable.OnSubscribe<T>	RxJavaHooks.onCreate(Observable.OnSubscribe<T> onSubscribe)	Hook to call when an Observable is created.
<T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f)	Deprecated.
static <T> Observable.OnSubscribe<T>	RxJavaHooks.onObservableStart(Observable<T> instance, Observable.OnSubscribe<T> onSubscribe)	Hook to call before the child subscriber is subscribed to the OnSubscribe action.
static <T> Observable.OnSubscribe<T>	RxJavaHooks.onSingleStart(Single<T> instance, Observable.OnSubscribe<T> onSubscribe)	Hook to call before the child subscriber is subscribed to the OnSubscribe action.
<T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance, Observable.OnSubscribe<T> onSubscribe)	Deprecated.
<T> Observable.OnSubscribe<T>	RxJavaSingleExecutionHook.onSubscribeStart(Single<? extends T> singleInstance, Observable.OnSubscribe<T> onSubscribe)	Deprecated.

Methods in rx.plugins that return types with arguments of type Observable.OnSubscribe

Modifier and Type	Method	Description
static Func1<Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.getOnObservableCreate()	Returns the current Observable onCreate hook function or null if it is set to the default pass-through.
static Func1<Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.getOnObservableCreate()	Returns the current Observable onCreate hook function or null if it is set to the default pass-through.
static Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.getOnObservableStart()	Returns the current Observable onStart hook function or null if it is set to the default pass-through.
static Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.getOnObservableStart()	Returns the current Observable onStart hook function or null if it is set to the default pass-through.
static Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.getOnSingleStart()	Returns the current Single onStart hook function or null if it is set to the default pass-through.
static Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe>	RxJavaHooks.getOnSingleStart()	Returns the current Single onStart hook function or null if it is set to the default pass-through.

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

Modifier and Type	Method	Description
static <T> Observable.OnSubscribe<T>	RxJavaHooks.onCreate(Observable.OnSubscribe<T> onSubscribe)	Hook to call when an Observable is created.
<T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f)	Deprecated.
static <T> Observable.OnSubscribe<T>	RxJavaHooks.onObservableStart(Observable<T> instance, Observable.OnSubscribe<T> onSubscribe)	Hook to call before the child subscriber is subscribed to the OnSubscribe action.
static <T> Observable.OnSubscribe<T>	RxJavaHooks.onSingleStart(Single<T> instance, Observable.OnSubscribe<T> onSubscribe)	Hook to call before the child subscriber is subscribed to the OnSubscribe action.
<T> Observable.OnSubscribe<T>	RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance, Observable.OnSubscribe<T> onSubscribe)	Deprecated.
<T> Observable.OnSubscribe<T>	RxJavaSingleExecutionHook.onSubscribeStart(Single<? extends T> singleInstance, Observable.OnSubscribe<T> onSubscribe)	Deprecated.

Method parameters in rx.plugins with type arguments of type Observable.OnSubscribe

Modifier and Type	Method	Description
static void	RxJavaHooks.setOnObservableCreate(Func1<Observable.OnSubscribe,Observable.OnSubscribe> onObservableCreate)	Sets the Observable onCreate hook function unless a lockdown is in effect.
static void	RxJavaHooks.setOnObservableCreate(Func1<Observable.OnSubscribe,Observable.OnSubscribe> onObservableCreate)	Sets the Observable onCreate hook function unless a lockdown is in effect.
static void	RxJavaHooks.setOnObservableStart(Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe> onObservableStart)	Sets the hook function that is called when a subscriber subscribes to a Observable unless a lockdown is in effect.
static void	RxJavaHooks.setOnObservableStart(Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe> onObservableStart)	Sets the hook function that is called when a subscriber subscribes to a Observable unless a lockdown is in effect.
static void	RxJavaHooks.setOnSingleStart(Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe> onSingleStart)	Sets the hook function that is called when a subscriber subscribes to a Single unless a lockdown is in effect.
static void	RxJavaHooks.setOnSingleStart(Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe> onSingleStart)	Sets the hook function that is called when a subscriber subscribes to a Single unless a lockdown is in effect.

Uses of Observable.OnSubscribe in rx.subjects

Classes in rx.subjects that implement Observable.OnSubscribe

Modifier and Type	Class	Description
(package private) static final class	ReplaySubject.ReplayState<T>	Holds onto the array of Subscriber-wrapping ReplayProducers and the buffer that holds values to be replayed; it manages subscription and signal dispatching.
(package private) final class	SubjectSubscriptionManager<T>	Represents the typical state and OnSubscribe logic for a Subject implementation.
(package private) static final class	UnicastSubject.State<T>	The single-consumption replaying state.

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

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