Uses of Interface
rx.Observable.OnSubscribe
Packages that use Observable.OnSubscribe
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
Callback types and a central plugin handler class to hook into the lifecycle
of the base reactive types and schedulers.
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.OnSubscribeModifier and TypeClassDescription(package private) static final class
Transforms a OnSubscribe.call() into an Observable.subscribe() call.Fields in rx declared as Observable.OnSubscribeModifier and TypeFieldDescription(package private) final Observable.OnSubscribe
<T> Observable.onSubscribe
(package private) final Observable.OnSubscribe
<T> Single.onSubscribe
Methods in rx with parameters of type Observable.OnSubscribeModifier and TypeMethodDescriptionstatic <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 aSubscriber
subscribes to it.Method parameters in rx with type arguments of type Observable.OnSubscribeModifier and TypeMethodDescription<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.OnSubscribeModifierConstructorDescriptionprotected
Creates an Observable with a Function to execute when it is subscribed to.private
-
Uses of Observable.OnSubscribe in rx.internal.operators
Classes in rx.internal.operators that implement Observable.OnSubscribeModifier and TypeClassDescription(package private) static final class
(package private) static final class
Manages the subscription of child subscribers by setting up a replay producer and performs auto-connection of the very first subscription.enum
Holds a singleton instance of an empty Observable which is stateless and completes the child subscriber immediately.enum
Holds a singleton instance of a never Observable which is stateless doesn't call any of the Subscriber's methods.final class
Given multipleObservable
s, propagates the one that first emits an item.final class
Wraps a ConnectableObservable and calls its connect() method once the specified number of Subscribers have subscribed.final class
OnSubscribeCollect<T,
R> final class
final class
OnSubscribeConcatMap<T,
R> Maps a source sequence into Observables and concatenates them in order, subscribing to one at a time.final class
Do not create the Observable until an Observer subscribes; create a fresh Observable on each subscription.final class
Delays the subscription to the source by the given amount, running on the given scheduler.final class
Delays the subscription to the main source until the other observable fires an event or completes.final class
Delays the subscription until the Observable emits an event.final class
Nulls out references to upstream data structures when the source terminates or the child unsubscribes.final class
Filters an Observable by discarding any items it emits that do not meet some test.final class
Flattens a sequence if Iterable sources, generated via a function, into a single sequence.(package private) static final class
A custom flattener that works from a scalar value and computes the iterable during subscription time.final class
final class
final class
Do not invoke the function until an Observer subscribes; Invokes function on each subscription.final class
Converts anIterable
sequence into anObservable
.final class
OnSubscribeGroupJoin<T1,
T2, D1, D2, R> Correlates two sequences when they overlap and groups the results.(package private) static final class
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 anObservable
, and emits the results of this transformation as a newObservable
.final class
Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.final class
Multicasts notifications coming through its input Subscriber view to its client Subscribers via lockstep backpressure mode.final class
Emit ints from start to end inclusive.final class
final class
final class
final class
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
final class
final class
Timer that emits a single 0L and completes after the specified time.final class
Emit 0L after the initial period and ever increasing number after each period.(package private) static class
final class
OnSubscribeUsing<T,
Resource> Constructs an observable sequence that depends on a resource object.(package private) static final class
final class
Subscribes Observers on the specifiedScheduler
.final class
Fields in rx.internal.operators declared as Observable.OnSubscribeModifier and TypeFieldDescription(package private) final Observable.OnSubscribe
<T> OnSubscribeLift.parent
(package private) final Observable.OnSubscribe
<T> OnSubscribeOnAssembly.source
Methods in rx.internal.operators that return Observable.OnSubscribeModifier and TypeMethodDescriptionstatic <T> Observable.OnSubscribe
<T> OnSubscribeAmb.amb
(Iterable<? extends Observable<? extends T>> sources) Given a set ofObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> OnSubscribeAmb.amb
(Observable<? extends T> o1, Observable<? extends T> o2) Given twoObservable
s, 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 threeObservable
s, 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 fourObservable
s, 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 fiveObservable
s, 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 sixObservable
s, 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 sevenObservable
s, 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 eightObservable
s, 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 nineObservable
s, 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.OnSubscribeModifierConstructorDescriptionprivate
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.OnSubscribeModifier and TypeClassDescription(package private) static final class
The OnSubscribe callback for the Observable constructor.(package private) static final class
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.OnSubscribeModifier and TypeClassDescriptionclass
AsyncOnSubscribe<S,
T> A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.(package private) static final class
An implementation of AsyncOnSubscribe that delegatesAsyncOnSubscribe.next(Object, long, Observer)
,AsyncOnSubscribe.generateState()
, andAsyncOnSubscribe.onUnsubscribe(Object)
to provided functions/closures.(package private) static final class
class
SyncOnSubscribe<S,
T> A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.(package private) static final class
An implementation of SyncOnSubscribe that delegatesinvalid reference
SyncOnSubscribe#next(Object, Subscriber)
SyncOnSubscribe.generateState()
, andSyncOnSubscribe.onUnsubscribe(Object)
to provided functions/closures.Methods in rx.observables with parameters of type Observable.OnSubscribeModifier and TypeMethodDescriptionstatic <K,
T> GroupedObservable <K, T> GroupedObservable.create
(K key, Observable.OnSubscribe<T> f) Returns an Observable that will execute the specified function when aSubscriber
subscribes to it.Constructors in rx.observables with parameters of type Observable.OnSubscribeModifierConstructorDescriptionprotected
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.OnSubscribeModifier and TypeFieldDescription(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.OnSubscribeModifier and TypeMethodDescriptionstatic <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.OnSubscribeModifier and TypeMethodDescriptionRxJavaHooks.getOnObservableCreate()
Returns the current Observable onCreate hook function or null if it is set to the default pass-through.RxJavaHooks.getOnObservableCreate()
Returns the current Observable onCreate hook function or null if it is set to the default pass-through.RxJavaHooks.getOnObservableStart()
Returns the current Observable onStart hook function or null if it is set to the default pass-through.RxJavaHooks.getOnObservableStart()
Returns the current Observable onStart hook function or null if it is set to the default pass-through.RxJavaHooks.getOnSingleStart()
Returns the current Single onStart hook function or null if it is set to the default pass-through.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.OnSubscribeModifier and TypeMethodDescriptionstatic <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.OnSubscribeModifier and TypeMethodDescriptionstatic 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.OnSubscribeModifier and TypeClassDescription(package private) static final class
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
Represents the typical state and OnSubscribe logic for a Subject implementation.(package private) static final class
The single-consumption replaying state.Constructors in rx.subjects with parameters of type Observable.OnSubscribeModifierConstructorDescriptionprotected
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)