Uses of Interface
rx.functions.Function

Packages that use Function

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.internal.schedulers
rx.internal.util
rx.observables	Classes extending the Observable base reactive class, synchronous and asynchronous event generators.
rx.subjects	Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).

Uses of Function in rx

Subinterfaces of Function in rx

Modifier and Type	Interface	Description
static interface	Completable.CompletableOnSubscribe	Callback used for building deferred computations that takes a CompletableSubscriber.
static interface	Completable.CompletableOperator	Convenience interface and callback used by the lift operator that given a child CompletableSubscriber, return a parent CompletableSubscriber that does any kind of lifecycle-related transformations.
static interface	Completable.CompletableTransformer	Convenience interface and callback used by the compose operator to turn a Completable into another Completable fluently.
static interface	Observable.OnSubscribe<T>	Invoked when Observable.subscribe is called.
static interface	Observable.Operator<R,T>	Operator function for lifting into an Observable.
static interface	Observable.Transformer<T,R>	Function that receives the current Observable and should return another Observable, possibly with given element type, in exchange that will be subscribed to by the downstream operators and subscribers.
static interface	Single.OnSubscribe<T>	Invoked when Single.execute is called.
static interface	Single.Transformer<T,R>	Transformer function used by Single.compose(rx.Single.Transformer<? super T, ? extends R>).

Classes in rx that implement Function

Modifier and Type	Class	Description
(package private) static final class	Observable.OnSubscribeExtend<T>	Transforms a OnSubscribe.call() into an Observable.subscribe() call.

Uses of Function in rx.functions

Subinterfaces of Function in rx.functions

Modifier and Type	Interface	Description
interface	Action	All Action interfaces extend from this.
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.
interface	Func0<R>	Represents a function with zero arguments.
interface	Func1<T,R>	Represents a function with one argument.
interface	Func2<T1,T2,R>	Represents a function with two arguments.
interface	Func3<T1,T2,T3,R>	Represents a function with three arguments.
interface	Func4<T1,T2,T3,T4,R>	Represents a function with four arguments.
interface	Func5<T1,T2,T3,T4,T5,R>	Represents a function with five arguments.
interface	Func6<T1,T2,T3,T4,T5,T6,R>	Represents a function with six arguments.
interface	Func7<T1,T2,T3,T4,T5,T6,T7,R>	Represents a function with seven arguments.
interface	Func8<T1,T2,T3,T4,T5,T6,T7,T8,R>	Represents a function with eight arguments.
interface	Func9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R>	Represents a function with nine arguments.
interface	FuncN<R>	Represents a vector-argument function.

Classes in rx.functions that implement Function

Modifier and Type	Class	Description
(package private) static final class	Actions.Action1CallsAction0<T>
(package private) static final class	Actions.EmptyAction<T0,T1,T2,T3,T4,T5,T6,T7,T8>

Uses of Function in rx.internal.operators

Subinterfaces of Function in rx.internal.operators

Modifier and Type	Interface	Description
(package private) static interface	OperatorTimeoutBase.FirstTimeoutStub<T>	Set up the timeout action on the first value.
(package private) static interface	OperatorTimeoutBase.TimeoutStub<T>	Set up the timeout action based on every value

Classes in rx.internal.operators that implement Function

Modifier and Type	Class	Description
(package private) static final class	BufferUntilSubscriber.OnSubscribeAction<T>
(package private) static final class	CachedObservable.CachedSubscribe<T>	Manages the subscription of child subscribers by setting up a replay producer and performs auto-connection of the very first subscription.
final class	CompletableOnSubscribeConcat
final class	CompletableOnSubscribeConcatArray
final class	CompletableOnSubscribeConcatIterable
final class	CompletableOnSubscribeMerge
final class	CompletableOnSubscribeMergeArray
final class	CompletableOnSubscribeMergeDelayErrorArray
final class	CompletableOnSubscribeMergeDelayErrorIterable
final class	CompletableOnSubscribeMergeIterable
final class	CompletableOnSubscribeTimeout
enum	EmptyObservableHolder	Holds a singleton instance of an empty Observable which is stateless and completes the child subscriber immediately.
enum	NeverObservableHolder	Holds a singleton instance of a never Observable which is stateless doesn't call any of the Subscriber's methods.
final class	OnSubscribeAmb<T>	Given multiple Observables, propagates the one that first emits an item.
final class	OnSubscribeAutoConnect<T>	Wraps a ConnectableObservable and calls its connect() method once the specified number of Subscribers have subscribed.
final class	OnSubscribeCollect<T,R>
final class	OnSubscribeCombineLatest<T,R>
final class	OnSubscribeConcatMap<T,R>	Maps a source sequence into Observables and concatenates them in order, subscribing to one at a time.
final class	OnSubscribeDefer<T>	Do not create the Observable until an Observer subscribes; create a fresh Observable on each subscription.
final class	OnSubscribeDelaySubscription<T>	Delays the subscription to the source by the given amount, running on the given scheduler.
final class	OnSubscribeDelaySubscriptionOther<T,U>	Delays the subscription to the main source until the other observable fires an event or completes.
final class	OnSubscribeDelaySubscriptionWithSelector<T,U>	Delays the subscription until the Observable emits an event.
final class	OnSubscribeDetach<T>	Nulls out references to upstream data structures when the source terminates or the child unsubscribes.
final class	OnSubscribeFilter<T>	Filters an Observable by discarding any items it emits that do not meet some test.
final class	OnSubscribeFlattenIterable<T,R>	Flattens a sequence if Iterable sources, generated via a function, into a single sequence.
(package private) static final class	OnSubscribeFlattenIterable.OnSubscribeScalarFlattenIterable<T,R>	A custom flattener that works from a scalar value and computes the iterable during subscription time.
final class	OnSubscribeFromArray<T>
final class	OnSubscribeFromAsync<T>
final class	OnSubscribeFromCallable<T>	Do not invoke the function until an Observer subscribes; Invokes function on each subscription.
final class	OnSubscribeFromIterable<T>	Converts an Iterable sequence into an Observable.
final class	OnSubscribeGroupJoin<T1,T2,D1,D2,R>	Correlates two sequences when they overlap and groups the results.
(package private) static final class	OnSubscribeGroupJoin.WindowObservableFunc<T>	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 an Observable, and emits the results of this transformation as a new Observable.
final class	OnSubscribeOnAssembly<T>	Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
final class	OnSubscribeOnAssemblyCompletable<T>	Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
final class	OnSubscribeOnAssemblySingle<T>	Captures the current stack when it is instantiated, makes it available through a field and attaches it to all passing exception.
final class	OnSubscribePublishMulticast<T>	Multicasts notifications coming through its input Subscriber view to its client Subscribers via lockstep backpressure mode.
final class	OnSubscribeRange	Emit ints from start to end inclusive.
final class	OnSubscribeRedo<T>
static final class	OnSubscribeRedo.RedoFinite
static final class	OnSubscribeRedo.RetryWithPredicate
final class	OnSubscribeReduce<T>
final class	OnSubscribeReduceSeed<T,R>
final 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.
final class	OnSubscribeTakeLastOne<T>
final class	OnSubscribeThrow<T>	An Observable that invokes onError when the Observer subscribes to it.
final class	OnSubscribeTimerOnce	Timer that emits a single 0L and completes after the specified time.
final class	OnSubscribeTimerPeriodically	Emit 0L after the initial period and ever increasing number after each period.
(package private) static class	OnSubscribeToObservableFuture.ToObservableFuture<T>
final class	OnSubscribeUsing<T,Resource>	Constructs an observable sequence that depends on a resource object.
(package private) static final class	OnSubscribeUsing.DisposeAction<Resource>
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.
(package private) static class	OperatorGroupBy.GroupBySubscriber.EvictionAction<K>
(package private) static final class	OperatorGroupBy.State<T,K>
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.
(package private) static final class	OperatorMapPair.OuterInnerMapper<T,U,R>
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.
(package private) static final class	OperatorObserveOn.ObserveOnSubscriber<T>	Observe through individual queue per observer.
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.
(package private) static final class	OperatorSampleWithTime.SamplerSubscriber<T>	The source subscriber and sampler.
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	OperatorSubscribeOn<T>	Subscribes Observers on the specified Scheduler.
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.
(package private) static final class	OperatorTakeLast.TakeLastSubscriber<T>
final class	OperatorTakeLastTimed<T>	Returns an Observable that emits the last count items emitted by the source Observable.
(package private) static final class	OperatorTakeLastTimed.TakeLastTimedSubscriber<T>
final class	OperatorTakeTimed<T>	Takes values from the source until the specific time elapses.
(package private) static final class	OperatorTakeTimed.TakeSubscriber<T>	Subscribed to source and scheduled on a worker.
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.
static final class	OperatorToMap.DefaultToMapFactory<K,V>	The default map factory.
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.
static final class	OperatorToMultimap.DefaultMultimapCollectionFactory<K,V>	The default collection factory for a key in the multimap returning an ArrayList independent of the key.
static final class	OperatorToMultimap.DefaultToMultimapFactory<K,V>	The default multimap factory returning a HashMap.
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.
(package private) static final class	OperatorWindowWithSize.WindowExact<T>
(package private) static final class	OperatorWindowWithSize.WindowOverlap<T>
(package private) static final class	OperatorWindowWithSize.WindowSkip<T>
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	OperatorWithLatestFromMany<T,R>
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>
final class	SingleDoAfterTerminate<T>	Execute an action after onSuccess or onError has been delivered.
final class	SingleOnSubscribeDelaySubscriptionOther<T>	Delays the subscription to the Single until the Observable fires an event or completes.
final 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.
final class	SingleOnSubscribeUsing<T,Resource>	Generates a resource, derives a Single from it and disposes that resource once the Single terminates.
final class	SingleOperatorOnErrorResumeNext<T>

Uses of Function in rx.internal.schedulers

Classes in rx.internal.schedulers that implement Function

Modifier and Type	Class	Description
(package private) class	SleepingAction

Uses of Function in rx.internal.util

Classes in rx.internal.util that implement Function

Modifier and Type	Class	Description
(package private) static final class	InternalObservableUtils.CollectorCaller<T,R>
(package private) static final class	InternalObservableUtils.EqualsWithFunc1
(package private) static final class	InternalObservableUtils.ErrorNotImplementedAction
(package private) static final class	InternalObservableUtils.IsInstanceOfFunc1
(package private) static final class	InternalObservableUtils.NotificationErrorExtractor
(package private) static final class	InternalObservableUtils.ObjectEqualsFunc2
(package private) static final class	InternalObservableUtils.PlusOneFunc2
(package private) static final class	InternalObservableUtils.PlusOneLongFunc2
(package private) static final class	InternalObservableUtils.RepeatNotificationDematerializer
(package private) static final class	InternalObservableUtils.ReplaySupplierBuffer<T>
(package private) static final class	InternalObservableUtils.ReplaySupplierBufferTime<T>
(package private) static final class	InternalObservableUtils.ReplaySupplierNoParams<T>
(package private) static final class	InternalObservableUtils.ReplaySupplierTime<T>
(package private) static final class	InternalObservableUtils.RetryNotificationDematerializer
(package private) static final class	InternalObservableUtils.ReturnsVoidFunc1
(package private) static final class	InternalObservableUtils.SelectorAndObserveOn<T,R>
(package private) static final class	InternalObservableUtils.ToArrayFunc1
(package private) static final class	ScalarSynchronousObservable.JustOnSubscribe<T>	The OnSubscribe callback for the Observable constructor.
(package private) static final class	ScalarSynchronousObservable.ScalarAsyncOnSubscribe<T>	The OnSubscribe implementation that creates the ScalarAsyncProducer for each incoming subscriber.
(package private) static final class	ScalarSynchronousObservable.ScalarAsyncProducer<T>	Represents a producer which schedules the emission of a scalar value on the first positive request via the given scheduler callback.
(package private) static final class	ScalarSynchronousSingle.DirectScheduledEmission<T>	Optimized observeOn for scalar value observed on the EventLoopsScheduler.
(package private) static final class	ScalarSynchronousSingle.NormalScheduledEmission<T>	Emits a scalar value on a general scheduler.
(package private) static final class	ScalarSynchronousSingle.ScalarSynchronousSingleAction<T>	Action that emits a single value when called.
(package private) static enum	UtilityFunctions.AlwaysFalse
(package private) static enum	UtilityFunctions.AlwaysTrue

Uses of Function in rx.observables

Classes in rx.observables that implement Function

Modifier and Type	Class	Description
class	AsyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
(package private) static final class	AsyncOnSubscribe.AsyncOnSubscribeImpl<S,T>	An implementation of AsyncOnSubscribe that delegates AsyncOnSubscribe.next(Object, long, Observer), AsyncOnSubscribe.generateState(), and AsyncOnSubscribe.onUnsubscribe(Object) to provided functions/closures.
(package private) static final class	AsyncOnSubscribe.UnicastSubject.State<T>
class	SyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
(package private) static final class	SyncOnSubscribe.SyncOnSubscribeImpl<S,T>	An implementation of SyncOnSubscribe that delegates invalid reference SyncOnSubscribe#next(Object, Subscriber) , SyncOnSubscribe.generateState(), and SyncOnSubscribe.onUnsubscribe(Object) to provided functions/closures.

Uses of Function in rx.subjects

Classes in rx.subjects that implement Function

Modifier and Type	Class	Description
(package private) static final class	ReplaySubject.ReplayState<T>	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	SubjectSubscriptionManager<T>	Represents the typical state and OnSubscribe logic for a Subject implementation.
(package private) static final class	UnicastSubject.State<T>	The single-consumption replaying state.