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.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).
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
Observable.create(Observable.OnSubscribe<T> f)
Deprecated.
1.2.7 - inherently unsafe, use the other create() methods for basic cases or
see
Observable.unsafeCreate(OnSubscribe) for advanced cases (such as custom operators) |
static <T> Observable<T> |
Observable.unsafeCreate(Observable.OnSubscribe<T> f)
Returns an Observable that executes the given OnSubscribe action for each individual Subscriber
that subscribes; unsubscription and backpressure must be implemented manually.
|
Constructor and Description |
---|
Observable(Observable.OnSubscribe<T> f)
Creates an Observable with a Function to execute when it is subscribed to.
|
Single(Observable.OnSubscribe<T> f)
Deprecated.
1.2.1: Not recommended, use
Single.Single(OnSubscribe) to avoid wrapping and
conversion between the Observable and Single protocols. |
Modifier and Type | Class and Description |
---|---|
class |
EmptyObservableHolder
Holds a singleton instance of an empty Observable which is stateless and completes
the child subscriber immediately.
|
class |
NeverObservableHolder
Holds a singleton instance of a never Observable which is stateless doesn't
call any of the Subscriber's methods.
|
class |
OnSubscribeAmb<T>
Given multiple
Observable s, propagates the one that first emits an item. |
class |
OnSubscribeAutoConnect<T>
Wraps a ConnectableObservable and calls its connect() method once
the specified number of Subscribers have subscribed.
|
class |
OnSubscribeCollect<T,R> |
class |
OnSubscribeCombineLatest<T,R> |
class |
OnSubscribeConcatMap<T,R>
Maps a source sequence into Observables and concatenates them in order, subscribing
to one at a time.
|
class |
OnSubscribeCreate<T> |
class |
OnSubscribeDefer<T>
Do not create the Observable until an Observer subscribes; create a fresh Observable on each
subscription.
|
class |
OnSubscribeDelaySubscription<T>
Delays the subscription to the source by the given amount, running on the given scheduler.
|
class |
OnSubscribeDelaySubscriptionOther<T,U>
Delays the subscription to the main source until the other
observable fires an event or completes.
|
class |
OnSubscribeDelaySubscriptionWithSelector<T,U>
Delays the subscription until the Observable emits an event.
|
class |
OnSubscribeDetach<T>
Nulls out references to upstream data structures when the source terminates or
the child unsubscribes.
|
class |
OnSubscribeDoOnEach<T>
Calls specified actions for each notification.
|
class |
OnSubscribeFilter<T>
Filters an Observable by discarding any items it emits that do not meet some test.
|
class |
OnSubscribeFlatMapCompletable<T>
Maps upstream values to Completables and merges them, up to a given
number of them concurrently, optionally delaying errors.
|
class |
OnSubscribeFlatMapSingle<T,R>
Maps upstream values to Singles and merges them, up to a given
number of them concurrently, optionally delaying errors.
|
class |
OnSubscribeFlattenIterable<T,R>
Flattens a sequence if Iterable sources, generated via a function, into a single sequence.
|
class |
OnSubscribeFromArray<T> |
class |
OnSubscribeFromCallable<T>
Do not invoke the function until an Observer subscribes; Invokes function on each
subscription.
|
class |
OnSubscribeFromIterable<T>
Converts an
Iterable sequence into an Observable . |
class |
OnSubscribeGroupJoin<T1,T2,D1,D2,R>
Correlates two sequences when they overlap and groups the results.
|
class |
OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R>
Correlates the elements of two sequences based on overlapping durations.
|
class |
OnSubscribeLift<T,R>
Transforms the downstream Subscriber into a Subscriber via an operator
callback and calls the parent OnSubscribe.call() method with it.
|
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 . |
class |
OnSubscribeOnAssembly<T>
Captures the current stack when it is instantiated, makes
it available through a field and attaches it to all
passing exception.
|
class |
OnSubscribePublishMulticast<T>
Multicasts notifications coming through its input Subscriber view to its
client Subscribers via lockstep backpressure mode.
|
class |
OnSubscribeRange
Emit integers from start to end inclusive.
|
class |
OnSubscribeRedo<T> |
class |
OnSubscribeReduce<T> |
class |
OnSubscribeReduceSeed<T,R> |
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.
|
class |
OnSubscribeSkipTimed<T>
Skips elements until a specified time elapses.
|
class |
OnSubscribeSwitchIfEmpty<T>
If the Observable completes without emitting any items, subscribe to an alternate Observable.
|
class |
OnSubscribeTakeLastOne<T> |
class |
OnSubscribeThrow<T>
|
class |
OnSubscribeTimerOnce
Timer that emits a single 0L and completes after the specified time.
|
class |
OnSubscribeTimerPeriodically
Emit 0L after the initial period and ever increasing number after each period.
|
class |
OnSubscribeToMap<T,K,V>
Maps the elements of the source observable into a java.util.Map instance and
emits that once the source observable completes.
|
class |
OnSubscribeToMultimap<T,K,V>
Maps the elements of the source observable into a multimap
(Map<K, Collection<V>>) where each
key entry has a collection of the source's values.
|
class |
OnSubscribeUsing<T,Resource>
Constructs an observable sequence that depends on a resource object.
|
class |
OperatorSubscribeOn<T>
Subscribes Observers on the specified
Scheduler . |
class |
OperatorWithLatestFromMany<T,R> |
class |
SingleToObservable<T>
Expose a Single.OnSubscribe as an Observable.OnSubscribe.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable.OnSubscribe<T> |
OnSubscribeAmb.amb(Iterable<? extends Observable<? extends T>> sources)
Given a set of
Observable 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 two
Observable 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 three
Observable 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 four
Observable 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 five
Observable 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 six
Observable 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 seven
Observable 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 eight
Observable 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 nine
Observable 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) |
Constructor and Description |
---|
OnSubscribeLift(Observable.OnSubscribe<T> parent,
Observable.Operator<? extends R,? super T> operator) |
OnSubscribeOnAssembly(Observable.OnSubscribe<T> source) |
SingleFromObservable(Observable.OnSubscribe<T> source) |
Modifier and Type | Class and Description |
---|---|
class |
AsyncOnSubscribe<S,T>
A utility class to create
OnSubscribe<T> functions that respond correctly to back
pressure requests from subscribers. |
class |
SyncOnSubscribe<S,T>
A utility class to create
OnSubscribe<T> functions that responds correctly to back
pressure requests from subscribers. |
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. |
Constructor and Description |
---|
ConnectableObservable(Observable.OnSubscribe<T> onSubscribe) |
GroupedObservable(K key,
Observable.OnSubscribe<T> onSubscribe) |
Modifier and Type | Method and 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.
|
<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.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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.
|
<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.
|
Modifier and Type | Method and 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.
|
Constructor and Description |
---|
AsyncSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state) |
BehaviorSubject(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) |
Copyright © 2017. All rights reserved.