Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.functions |
Functional interfaces of functions and actions of arity 0 to 9 and related
utility classes.
|
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.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
Completable.OnSubscribe
Callback used for building deferred computations that takes a CompletableSubscriber.
|
static interface |
Observable.OnSubscribe<T>
Invoked when Observable.subscribe is called.
|
static interface |
Single.OnSubscribe<T>
Invoked when Single.execute is called.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Action0
A zero-argument action.
|
interface |
Action1<T>
A one-argument action.
|
interface |
Action2<T1,T2>
A two-argument action.
|
interface |
Action3<T1,T2,T3>
A three-argument action.
|
interface |
Action4<T1,T2,T3,T4>
A four-argument action.
|
interface |
Action5<T1,T2,T3,T4,T5>
A five-argument action.
|
interface |
Action6<T1,T2,T3,T4,T5,T6>
A six-argument action.
|
interface |
Action7<T1,T2,T3,T4,T5,T6,T7>
A seven-argument action.
|
interface |
Action8<T1,T2,T3,T4,T5,T6,T7,T8>
An eight-argument action.
|
interface |
Action9<T1,T2,T3,T4,T5,T6,T7,T8,T9>
A nine-argument action.
|
interface |
ActionN
A vector-argument action.
|
Modifier and Type | Class and Description |
---|---|
class |
CompletableFlatMapSingleToCompletable<T> |
class |
CompletableFromEmitter
Allows push-based emission of terminal events to a CompletableSubscriber.
|
class |
CompletableOnSubscribeConcat |
class |
CompletableOnSubscribeConcatArray |
class |
CompletableOnSubscribeConcatIterable |
class |
CompletableOnSubscribeMerge |
class |
CompletableOnSubscribeMergeArray |
class |
CompletableOnSubscribeMergeDelayErrorArray |
class |
CompletableOnSubscribeMergeDelayErrorIterable |
class |
CompletableOnSubscribeMergeIterable |
class |
CompletableOnSubscribeTimeout |
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 |
OnSubscribeOnAssemblyCompletable<T>
Captures the current stack when it is instantiated, makes
it available through a field and attaches it to all
passing exception.
|
class |
OnSubscribeOnAssemblySingle<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 |
OnSubscribeSingle<T>
Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
|
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 |
OnSubscribeTimeoutSelectorWithFallback<T,U,V>
Switches to the fallback Observable if: the first upstream item doesn't arrive before
the first timeout Observable signals an item or completes; or the Observable generated from
the previous upstream item signals its item or completes before the upstream signals the next item
of its own.
|
class |
OnSubscribeTimeoutTimedWithFallback<T>
Switches to consuming a fallback Observable if the main source doesn't signal an onNext event
within the given time frame after subscription or the previous onNext event.
|
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 |
SingleDelay<T>
Signal the success or error value on the Scheduler's thread.
|
class |
SingleDoAfterTerminate<T>
Execute an action after onSuccess or onError has been delivered.
|
class |
SingleDoOnEvent<T> |
class |
SingleDoOnSubscribe<T>
Call an Action0 when the subscription happens to the source.
|
class |
SingleDoOnUnsubscribe<T>
Call an Action0 when the subscription happens to the source.
|
class |
SingleFromCallable<T>
Execute a callable and emit its resulting value.
|
class |
SingleFromEmitter<T>
Calls an action with a SingleEmitter instance for each individual subscribers that
generates a terminal signal (eventually).
|
class |
SingleFromFuture<T>
Wait and emit the value of the Future.
|
class |
SingleFromObservable<T>
Wrap an Observable.OnSubscribe and expose it as a Single.OnSubscribe.
|
class |
SingleLiftObservableOperator<T,R>
Lift an Observable.Operator into the Single sequence.
|
class |
SingleObserveOn<T>
Signal the success or error value on the Scheduler's thread.
|
class |
SingleOnErrorReturn<T>
Signal a value returned by a resumeFunction when the source signals a Throwable.
|
class |
SingleOnSubscribeDelaySubscriptionOther<T>
Delays the subscription to the Single until the Observable
fires an event or completes.
|
class |
SingleOnSubscribeMap<T,R>
Applies a function of your choosing to every item emitted by an
Single , and emits the results of
this transformation as a new Single . |
class |
SingleOnSubscribeUsing<T,Resource>
Generates a resource, derives a Single from it and disposes that resource once the
Single terminates.
|
class |
SingleOperatorOnErrorResumeNext<T> |
class |
SingleTakeUntilCompletable<T>
Relay the source signals if the other doesn't terminate before.
|
class |
SingleTakeUntilObservable<T,U>
Relay the source signals if the other doesn't terminate before.
|
class |
SingleTakeUntilSingle<T,U>
Relay the source signals if the other doesn't terminate before.
|
class |
SingleTimeout<T> |
class |
SingleToObservable<T>
Expose a Single.OnSubscribe as an Observable.OnSubscribe.
|
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. |
Copyright © 2018. All rights reserved.