Uses of Interface
rx.Observable.Operator

Packages that use Observable.Operator

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.plugins	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.Operator

Modifier and Type	Method	Description
final <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.Operator

Modifier and Type	Class	Description
final 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 an Observable that emits true if any element of an observable sequence satisfies a condition, otherwise false.
final class	OperatorAsObservable<T>	Hides the identity of another observable.
final class	OperatorBufferWithSingleObservable<T,TClosing>	This operation takes values from the specified Observable source and stores them in a buffer until the Observable constructed using the Func0 argument, produces a value.
final class	OperatorBufferWithSize<T>	This operation takes values from the specified Observable 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 specified Observable source and stores them in the currently active chunks.
final class	OperatorBufferWithTime<T>	This operation takes values from the specified Observable source and stores them in a buffer.
class	OperatorCast<T,R>	Converts the elements of an observable sequence to the specified type.
final class	OperatorDebounceWithSelector<T,U>	Delay the emission via another observable if no new source appears in the meantime.
final class	OperatorDebounceWithTime<T>	This operation filters out events which are published too quickly in succession.
final class	OperatorDelay<T>	Delays the emission of onNext events by a given amount of time.
final class	OperatorDelayWithSelector<T,V>	Delay the subscription and emission of the source items by a per-item observable that fires its first element.
final class	OperatorDematerialize<T>	Reverses the effect of OperatorMaterialize 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	OperatorDistinctUntilChanged<T,U>	Returns an Observable that emits all sequentially distinct items emitted by the source.
final class	OperatorDoAfterTerminate<T>	Registers an action to be called after an Observable invokes onComplete or onError.
class	OperatorDoOnEach<T>	Converts the elements of an observable sequence to the specified type.
class	OperatorDoOnRequest<T>	This operator modifies an Observable so a given action is invoked when the Producer receives a request.
class	OperatorDoOnSubscribe<T>	This operator modifies an Observable so a given action is invoked when the Observable is subscribed.
class	OperatorDoOnUnsubscribe<T>	This operator modifies an Observable so a given action is invoked when the Observable is unsubscribed.
final class	OperatorEagerConcatMap<T,R>
final class	OperatorElementAt<T>	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	OperatorIgnoreElements<T>
final class	OperatorMapNotification<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	OperatorMapPair<T,U,R>	An Observable.Operator that pairs up items emitted by a source Observable with the sequence of items emitted by the Observable that is derived from each item by means of a selector, and emits the results of this pairing.
final class	OperatorMaterialize<T>	Turns all of the notifications from an Observable into onNext emissions, and marks them with their original notification types within Notification objects.
final class	OperatorMerge<T>	Flattens a list of Observables into one Observable, without any transformation.
final class	OperatorObserveOn<T>	Delivers events on the specified Scheduler asynchronously via an unbounded buffer.
class	OperatorOnBackpressureBuffer<T>
class	OperatorOnBackpressureDrop<T>
final class	OperatorOnBackpressureLatest<T>	An operator which drops all but the last received value in case the downstream doesn't request more.
final class	OperatorOnErrorResumeNextViaFunction<T>	Instruct an Observable to pass control to another Observable (the return value of a function) rather than invoking onError if it encounters an error.
final class	OperatorRetryWithPredicate<T>
final class	OperatorSampleWithObservable<T,U>	Sample with the help of another observable.
final class	OperatorSampleWithTime<T>	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	OperatorSerialize<T>
final class	OperatorSingle<T>	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 first num items emitted by the source Observable.
class	OperatorSkipLast<T>	Bypasses a specified number of elements at the end of an observable sequence.
class	OperatorSkipLastTimed<T>	Skip delivering values in the time window before the values.
final class	OperatorSkipTimed<T>	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	OperatorSkipWhile<T>	Skips any emitted source items as long as the specified condition holds true.
final class	OperatorSwitch<T>	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	OperatorSwitchIfEmpty<T>	If the Observable completes without emitting any items, subscribe to an alternate Observable.
final class	OperatorTake<T>	An Observable that emits the first num items emitted by the source Observable.
final class	OperatorTakeLast<T>	Returns an Observable that emits the at most the last count items emitted by the source Observable.
final class	OperatorTakeLastTimed<T>	Returns an Observable that emits the last count items emitted by the source Observable.
final class	OperatorTakeTimed<T>	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	OperatorTakeUntilPredicate<T>	Returns an Observable that emits items emitted by the source Observable until the provided predicate returns false
final class	OperatorTakeWhile<T>	O Returns an Observable that emits items emitted by the source Observable as long as a specified condition is true.
final class	OperatorThrottleFirst<T>	Throttle by windowing a stream and returning the first value in each window.
final class	OperatorTimeInterval<T>	Records the time interval between consecutive elements in an observable sequence.
final class	OperatorTimeout<T>	Applies a timeout policy for each element in the observable sequence, using the specified scheduler to run timeout timers.
(package private) class	OperatorTimeoutBase<T>
class	OperatorTimeoutWithSelector<T,U,V>	Returns an Observable that mirrors the source Observable.
final class	OperatorTimestamp<T>	Wraps each item emitted by a source Observable in a Timestamped 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	OperatorToObservableList<T>	Returns an Observable that emits a single item, a list composed of all the items emitted by the source Observable.
final class	OperatorToObservableSortedList<T>	Return an Observable that emits the items emitted by the source Observable, in a sorted order (each item emitted by the Observable must implement Comparable with respect to all other items in the sequence, or you must pass in a sort function).
class	OperatorUnsubscribeOn<T>	Unsubscribes on the specified Scheduler.
final class	OperatorWindowWithObservable<T,U>	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	OperatorWindowWithObservableFactory<T,U>	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	OperatorWindowWithSize<T>	Creates windows of values into the source sequence with skip frequency and size bounds.
final class	OperatorWindowWithStartEndObservable<T,U,V>	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	OperatorWindowWithTime<T>	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.Operator

Modifier and Type	Field	Description
(package private) final Observable.Operator<? extends R,? super T>	OnSubscribeLift.operator

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

Modifier and Type	Method	Description
static <T> Observable.Operator<T,T>	OperatorObserveOn.rebatch(int n)

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

Modifier	Constructor	Description
	OnSubscribeLift(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.Operator

Modifier and Type	Field	Description
static 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.Operator

Modifier and Type	Field	Description
(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.Operator

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

Modifier and Type	Method	Description
static Func1<Observable.Operator,Observable.Operator>	RxJavaHooks.getOnObservableLift()	Returns the current Observable onLift hook function or null if it is set to the default pass-through.
static Func1<Observable.Operator,Observable.Operator>	RxJavaHooks.getOnObservableLift()	Returns the current Observable onLift hook function or null if it is set to the default pass-through.
static Func1<Observable.Operator,Observable.Operator>	RxJavaHooks.getOnSingleLift()	Returns the current Single onLift hook function or null if it is set to the default pass-through.
static Func1<Observable.Operator,Observable.Operator>	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.Operator

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

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