Uses of Interface
rx.functions.Action2
-
Packages that use Action2 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.util rx.observables Classes extending the Observable base reactive class, synchronous and asynchronous event generators. -
-
Uses of Action2 in rx
Methods in rx with parameters of type Action2 Modifier and Type Method Description <R> Observable<R>
Observable. collect(Func0<R> stateFactory, Action2<R,? super T> collector)
Collects items emitted by the source Observable into a single mutable data structure and returns an Observable that emits this structure. -
Uses of Action2 in rx.functions
Classes in rx.functions that implement Action2 Modifier and Type Class Description (package private) static class
Actions.EmptyAction<T0,T1,T2,T3,T4,T5,T6,T7,T8>
Methods in rx.functions with parameters of type Action2 Modifier and Type Method Description static <T0,T1>
FuncN<java.lang.Void>Functions. fromAction(Action2<? super T0,? super T1> f)
static <T1,T2>
Func2<T1,T2,java.lang.Void>Actions. toFunc(Action2<T1,T2> action)
Converts anAction2
to a function that calls the action and returnsnull
.static <T1,T2,R>
Func2<T1,T2,R>Actions. toFunc(Action2<T1,T2> action, R result)
Converts anAction2
to a function that calls the action and returns a specified value. -
Uses of Action2 in rx.internal.operators
Fields in rx.internal.operators declared as Action2 Modifier and Type Field Description (package private) Action2<R,? super T>
OnSubscribeCollect. collector
(package private) Action2<R,? super T>
OnSubscribeCollect.CollectSubscriber. collector
Constructors in rx.internal.operators with parameters of type Action2 Constructor Description CollectSubscriber(Subscriber<? super R> actual, R initialValue, Action2<R,? super T> collector)
OnSubscribeCollect(Observable<T> source, Func0<R> collectionFactory, Action2<R,? super T> collector)
-
Uses of Action2 in rx.internal.util
Fields in rx.internal.util declared as Action2 Modifier and Type Field Description (package private) Action2<R,? super T>
InternalObservableUtils.CollectorCaller. collector
Methods in rx.internal.util with parameters of type Action2 Modifier and Type Method Description static <T,R>
Func2<R,T,R>InternalObservableUtils. createCollectorCaller(Action2<R,? super T> collector)
Returns a Func2 which calls a collector with its parameters and returns the first (R) parameter.Constructors in rx.internal.util with parameters of type Action2 Constructor Description CollectorCaller(Action2<R,? super T> collector)
-
Uses of Action2 in rx.observables
Methods in rx.observables with parameters of type Action2 Modifier and Type Method Description static <S,T>
SyncOnSubscribe<S,T>SyncOnSubscribe. createSingleState(Func0<? extends S> generator, Action2<? super S,? super Observer<? super T>> next)
Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,T>
SyncOnSubscribe<S,T>SyncOnSubscribe. createSingleState(Func0<? extends S> generator, Action2<? super S,? super Observer<? super T>> next, Action1<? super S> onUnsubscribe)
Generates a synchronousSyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> AsyncOnSubscribe<java.lang.Void,T>
AsyncOnSubscribe. createStateless(Action2<java.lang.Long,? super Observer<Observable<? extends T>>> next)
Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> AsyncOnSubscribe<java.lang.Void,T>
AsyncOnSubscribe. createStateless(Action2<java.lang.Long,? super Observer<Observable<? extends T>>> next, Action0 onUnsubscribe)
Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.
-