Uses of Interface
rx.Observable.Operator
Packages that use Observable.Operator
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.
Callback types and a central plugin handler class to hook into the lifecycle
of the base reactive types and schedulers.
-
Uses of Observable.Operator in rx
Methods in rx with parameters of type Observable.OperatorModifier and TypeMethodDescriptionfinal <R> Observable
<R> Observable.lift
(Observable.Operator<? extends R, ? super T> operator) This method requires advanced knowledge about building operators; please consider other standard composition methods first; Lifts a function to the current Observable and returns a new Observable that when subscribed to will pass the values of the current Observable through the Operator function.final <R> Single
<R> Single.lift
(Observable.Operator<? extends R, ? super T> lift) Lifts a function to the current Single and returns a new Single that when subscribed to will pass the values of the current Single through the Operator function. -
Uses of Observable.Operator in rx.internal.operators
Classes in rx.internal.operators that implement Observable.OperatorModifier and TypeClassDescriptionfinal class
OperatorAll<T>
Returns an Observable that emits a Boolean that indicates whether all items emitted by an Observable satisfy a condition.final class
OperatorAny<T>
Returns anObservable
that emitstrue
if any element of an observable sequence satisfies a condition, otherwisefalse
.final class
Hides the identity of another observable.final class
OperatorBufferWithSingleObservable<T,
TClosing> This operation takes values from the specifiedObservable
source and stores them in a buffer until theObservable
constructed using theFunc0
argument, produces a value.final class
This operation takes values from the specifiedObservable
source and stores them in all active chunks until the buffer contains a specified number of elements.final class
OperatorBufferWithStartEndObservable<T,
TOpening, TClosing> This operation takes values from the specifiedObservable
source and stores them in the currently active chunks.final class
This operation takes values from the specifiedObservable
source and stores them in a buffer.class
OperatorCast<T,
R> Converts the elements of an observable sequence to the specified type.final class
Delay the emission via another observable if no new source appears in the meantime.final class
This operation filters out events which are published too quickly in succession.final class
Delays the emission of onNext events by a given amount of time.final class
Delay the subscription and emission of the source items by a per-item observable that fires its first element.final class
Reverses the effect ofOperatorMaterialize
by transforming the Notification objects emitted by a source Observable into the items or notifications they represent.final class
OperatorDistinct<T,
U> Returns an Observable that emits all distinct items emitted by the source.final class
Returns an Observable that emits all sequentially distinct items emitted by the source.final class
Registers an action to be called after an Observable invokesonComplete
oronError
.class
Converts the elements of an observable sequence to the specified type.class
This operator modifies anObservable
so a given action is invoked when theProducer
receives a request.class
This operator modifies anObservable
so a given action is invoked when theObservable
is subscribed.class
This operator modifies anObservable
so a given action is invoked when theObservable
is unsubscribed.final class
final class
Returns the element at a specified index in a sequence.final class
OperatorGroupBy<T,
K, V> Groups the items emitted by an Observable according to a specified criterion, and emits these grouped items as Observables, one Observable per group.class
final class
Applies a function of your choosing to every item emitted by anObservable
, and emits the results of this transformation as a newObservable
.final class
OperatorMapPair<T,
U, R> AnObservable.Operator
that pairs up items emitted by a sourceObservable
with the sequence of items emitted by theObservable
that is derived from each item by means of a selector, and emits the results of this pairing.final class
Turns all of the notifications from an Observable intoonNext
emissions, and marks them with their original notification types withinNotification
objects.final class
Flattens a list ofObservable
s into oneObservable
, without any transformation.final class
Delivers events on the specifiedScheduler
asynchronously via an unbounded buffer.class
class
final class
An operator which drops all but the last received value in case the downstream doesn't request more.final class
Instruct an Observable to pass control to another Observable (the return value of a function) rather than invokingonError
if it encounters an error.final class
final class
Sample with the help of another observable.final class
Returns an Observable that emits the results of sampling the items emitted by the source Observable at a specified time interval.final class
OperatorScan<R,
T> Returns an Observable that applies a function to the first item emitted by a source Observable, then feeds the result of that function along with the second item emitted by an Observable into the same function, and so on until all items have been emitted by the source Observable, emitting the result of each of these iterations.final class
final class
If the Observable completes after emitting a single item that matches a predicate, return an Observable containing that item.final class
OperatorSkip<T>
Returns an Observable that skips the firstnum
items emitted by the source Observable.class
Bypasses a specified number of elements at the end of an observable sequence.class
Skip delivering values in the time window before the values.final class
Skips elements until a specified time elapses.final class
OperatorSkipUntil<T,
U> Skip elements from the source Observable until the secondary observable fires an element.final class
Skips any emitted source items as long as the specified condition holds true.final class
Transforms an Observable that emits Observables into a single Observable that emits the items emitted by the most recently published of those Observables.final class
If the Observable completes without emitting any items, subscribe to an alternate Observable.final class
OperatorTake<T>
AnObservable
that emits the firstnum
items emitted by the sourceObservable
.final class
Returns an Observable that emits the at most the lastcount
items emitted by the source Observable.final class
Returns an Observable that emits the lastcount
items emitted by the source Observable.final class
Takes values from the source until the specific time elapses.final class
OperatorTakeUntil<T,
E> Returns an Observable that emits the items from the source Observable until another Observable emits an item.final class
Returns an Observable that emits items emitted by the source Observable until the provided predicate returns falsefinal class
O Returns an Observable that emits items emitted by the source Observable as long as a specified condition is true.final class
Throttle by windowing a stream and returning the first value in each window.final class
Records the time interval between consecutive elements in an observable sequence.final class
Applies a timeout policy for each element in the observable sequence, using the specified scheduler to run timeout timers.(package private) class
class
OperatorTimeoutWithSelector<T,
U, V> Returns an Observable that mirrors the source Observable.final class
Wraps each item emitted by a sourceObservable
in aTimestamped
object.final class
OperatorToMap<T,
K, V> Maps the elements of the source observable into a java.util.Map instance and emits that once the source observable completes.final class
OperatorToMultimap<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.final class
Returns anObservable
that emits a single item, a list composed of all the items emitted by the sourceObservable
.final class
Return anObservable
that emits the items emitted by the sourceObservable
, in a sorted order (each item emitted by theObservable
must implementComparable
with respect to all other items in the sequence, or you must pass in a sort function).class
Unsubscribes on the specified Scheduler.final class
Creates non-overlapping windows of items where each window is terminated by an event from a secondary observable and a new window is started immediately.final class
Creates non-overlapping windows of items where each window is terminated by an event from a secondary observable and a new window is started immediately.final class
Creates windows of values into the source sequence with skip frequency and size bounds.final class
Creates potentially overlapping windows of the source items where each window is started by a value emitted by an observable and closed when an associated Observable emits a value or completes.final class
Creates windows of values into the source sequence with timed window creation, length and size bounds.final class
OperatorWithLatestFrom<T,
U, R> Combines values from two sources only when the main source emits.final class
OperatorZip<R>
Returns an Observable that emits the results of a function applied to sets of items emitted, in sequence, by two or more other Observables.final class
OperatorZipIterable<T1,
T2, R> Fields in rx.internal.operators declared as Observable.OperatorModifier and TypeFieldDescription(package private) final Observable.Operator
<? extends R, ? super T> OnSubscribeLift.operator
Methods in rx.internal.operators that return Observable.OperatorModifier and TypeMethodDescriptionstatic <T> Observable.Operator
<T, T> OperatorObserveOn.rebatch
(int n) Constructors in rx.internal.operators with parameters of type Observable.OperatorModifierConstructorDescriptionOnSubscribeLift
(Observable.OnSubscribe<T> parent, Observable.Operator<? extends R, ? super T> operator) -
Uses of Observable.Operator in rx.internal.util
Fields in rx.internal.util declared as Observable.OperatorModifier and TypeFieldDescriptionstatic final Observable.Operator
<Boolean, Object> InternalObservableUtils.IS_EMPTY
-
Uses of Observable.Operator in rx.plugins
Fields in rx.plugins with type parameters of type Observable.OperatorModifier and TypeFieldDescription(package private) static Func1
<Observable.Operator, Observable.Operator> RxJavaHooks.onObservableLift
(package private) static Func1
<Observable.Operator, Observable.Operator> RxJavaHooks.onObservableLift
(package private) static Func1
<Observable.Operator, Observable.Operator> RxJavaHooks.onSingleLift
(package private) static Func1
<Observable.Operator, Observable.Operator> RxJavaHooks.onSingleLift
Methods in rx.plugins that return Observable.OperatorModifier and TypeMethodDescription<T,
R> Observable.Operator <? extends R, ? super T> RxJavaObservableExecutionHook.onLift
(Observable.Operator<? extends R, ? super T> lift) Deprecated.<T,
R> Observable.Operator <? extends R, ? super T> RxJavaSingleExecutionHook.onLift
(Observable.Operator<? extends R, ? super T> lift) Deprecated.static <T,
R> Observable.Operator <R, T> RxJavaHooks.onObservableLift
(Observable.Operator<R, T> operator) Hook to call before the child subscriber would subscribe to an Operator.static <T,
R> Observable.Operator <R, T> RxJavaHooks.onSingleLift
(Observable.Operator<R, T> operator) Hook to call before the child subscriber would subscribe to an Operator.Methods in rx.plugins that return types with arguments of type Observable.OperatorModifier and TypeMethodDescriptionRxJavaHooks.getOnObservableLift()
Returns the current Observable onLift hook function or null if it is set to the default pass-through.RxJavaHooks.getOnObservableLift()
Returns the current Observable onLift hook function or null if it is set to the default pass-through.RxJavaHooks.getOnSingleLift()
Returns the current Single onLift hook function or null if it is set to the default pass-through.RxJavaHooks.getOnSingleLift()
Returns the current Single onLift hook function or null if it is set to the default pass-through.Methods in rx.plugins with parameters of type Observable.OperatorModifier and TypeMethodDescription<T,
R> Observable.Operator <? extends R, ? super T> RxJavaObservableExecutionHook.onLift
(Observable.Operator<? extends R, ? super T> lift) Deprecated.<T,
R> Observable.Operator <? extends R, ? super T> RxJavaSingleExecutionHook.onLift
(Observable.Operator<? extends R, ? super T> lift) Deprecated.static <T,
R> Observable.Operator <R, T> RxJavaHooks.onObservableLift
(Observable.Operator<R, T> operator) Hook to call before the child subscriber would subscribe to an Operator.static <T,
R> Observable.Operator <R, T> RxJavaHooks.onSingleLift
(Observable.Operator<R, T> operator) Hook to call before the child subscriber would subscribe to an Operator.Method parameters in rx.plugins with type arguments of type Observable.OperatorModifier and TypeMethodDescriptionstatic void
RxJavaHooks.setOnObservableLift
(Func1<Observable.Operator, Observable.Operator> onObservableLift) Sets a hook function that is called with an operator when an Observable operator built with lift() gets subscribed to.static void
RxJavaHooks.setOnObservableLift
(Func1<Observable.Operator, Observable.Operator> onObservableLift) Sets a hook function that is called with an operator when an Observable operator built with lift() gets subscribed to.static void
RxJavaHooks.setOnSingleLift
(Func1<Observable.Operator, Observable.Operator> onSingleLift) Sets a hook function that is called with an operator when an Single operator built with lift() gets subscribed to.static void
RxJavaHooks.setOnSingleLift
(Func1<Observable.Operator, Observable.Operator> onSingleLift) Sets a hook function that is called with an operator when an Single operator built with lift() gets subscribed to.