Uses of Interface
rx.functions.Func3
-
Packages that use Func3 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. -
-
Uses of Func3 in rx
Methods in rx with parameters of type Func3 Modifier and Type Method Description static <T1,T2,T3,R>
Observable<R>Observable. combineLatest(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1,? super T2,? super T3,? extends R> combineFunction)
Combines three source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.<T1,T2,R>
Observable<R>Observable. withLatestFrom(Observable<T1> o1, Observable<T2> o2, Func3<? super T,? super T1,? super T2,R> combiner)
Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.static <T1,T2,T3,R>
Observable<R>Observable. zip(Observable<? extends T1> o1, Observable<? extends T2> o2, Observable<? extends T3> o3, Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of three items emitted, in sequence, by three other Observables.static <T1,T2,T3,R>
Single<R>Single. zip(Single<? extends T1> s1, Single<? extends T2> s2, Single<? extends T3> s3, Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to three items emitted by three other Singles. -
Uses of Func3 in rx.functions
Methods in rx.functions that return Func3 Modifier and Type Method Description static <T1,T2,T3>
Func3<T1,T2,T3,java.lang.Void>Actions. toFunc(Action3<T1,T2,T3> action)
Converts anAction3
to a function that calls the action and returnsnull
.static <T1,T2,T3,R>
Func3<T1,T2,T3,R>Actions. toFunc(Action3<T1,T2,T3> action, R result)
Converts anAction3
to a function that calls the action and returns a specified value.Methods in rx.functions with parameters of type Func3 Modifier and Type Method Description static <T0,T1,T2,R>
FuncN<R>Functions. fromFunc(Func3<? super T0,? super T1,? super T2,? extends R> f)
-
Uses of Func3 in rx.internal.operators
Subinterfaces of Func3 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.Constructors in rx.internal.operators with parameters of type Func3 Constructor Description OperatorZip(Func3 f)
-
Uses of Func3 in rx.observables
Fields in rx.observables declared as Func3 Modifier and Type Field Description private Func3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>,? extends S>
AsyncOnSubscribe.AsyncOnSubscribeImpl. next
Methods in rx.observables with parameters of type Func3 Modifier and Type Method Description static <S,T>
AsyncOnSubscribe<S,T>AsyncOnSubscribe. createStateful(Func0<? extends S> generator, Func3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>,? extends S> next)
Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,T>
AsyncOnSubscribe<S,T>AsyncOnSubscribe. createStateful(Func0<? extends S> generator, Func3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>,? extends S> next, Action1<? super S> onUnsubscribe)
Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.Constructors in rx.observables with parameters of type Func3 Constructor Description AsyncOnSubscribeImpl(Func0<? extends S> generator, Func3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>,? extends S> next)
AsyncOnSubscribeImpl(Func0<? extends S> generator, Func3<? super S,java.lang.Long,? super Observer<Observable<? extends T>>,? extends S> next, Action1<? super S> onUnsubscribe)
AsyncOnSubscribeImpl(Func3<S,java.lang.Long,Observer<Observable<? extends T>>,S> nextFunc)
AsyncOnSubscribeImpl(Func3<S,java.lang.Long,Observer<Observable<? extends T>>,S> next, Action1<? super S> onUnsubscribe)
-