A C E F I L M R S T W

A

all(Flowable<T>, Predicate<? super T>) - Static method in class io.reactivex.interop.RxJava3Interop

any(Flowable<T>, Predicate<? super T>) - Static method in class io.reactivex.interop.RxJava3Interop

C

collect(Flowable<T>, Callable<C>, BiConsumer<? super C, ? super T>) - Static method in class io.reactivex.interop.RxJava3Interop

concatCompletable(Flowable<? extends CompletableSource>) - Static method in class io.reactivex.interop.RxJava3Interop

concatCompletable(Flowable<? extends CompletableSource>, int) - Static method in class io.reactivex.interop.RxJava3Interop

concatMaybe(Flowable<? extends Maybe<? extends T>>) - Static method in class io.reactivex.interop.RxJava3Interop

concatMaybe(Flowable<? extends Maybe<? extends T>>, int) - Static method in class io.reactivex.interop.RxJava3Interop

concatSingle(Flowable<? extends Single<? extends T>>) - Static method in class io.reactivex.interop.RxJava3Interop

concatSingle(Flowable<? extends Single<? extends T>>, int) - Static method in class io.reactivex.interop.RxJava3Interop

count(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

E

elementAt(Flowable<T>, long) - Static method in class io.reactivex.interop.RxJava3Interop

elementAt(Flowable<T>, long, T) - Static method in class io.reactivex.interop.RxJava3Interop

elementAtOrError(Flowable<T>, long) - Static method in class io.reactivex.interop.RxJava3Interop

F

first(Flowable<T>, T) - Static method in class io.reactivex.interop.RxJava3Interop

firstElement(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

firstOrError(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

flatMapCompletable(Flowable<T>, Function<? super T, ? extends CompletableSource>) - Static method in class io.reactivex.interop.RxJava3Interop

flatMapCompletable(Flowable<T>, Function<? super T, ? extends CompletableSource>, boolean, int) - Static method in class io.reactivex.interop.RxJava3Interop

flatMapMaybe(Flowable<T>, Function<? super T, ? extends MaybeSource<? extends R>>) - Static method in class io.reactivex.interop.RxJava3Interop

flatMapMaybe(Flowable<T>, Function<? super T, ? extends MaybeSource<? extends R>>, boolean, int) - Static method in class io.reactivex.interop.RxJava3Interop

flatMapPublisher(Single<T>, Function<? super T, ? extends Publisher<? extends R>>) - Static method in class io.reactivex.interop.RxJava3Interop

flatMapPublisher(Maybe<T>, Function<? super T, ? extends Publisher<? extends R>>) - Static method in class io.reactivex.interop.RxJava3Interop

flatMapSingle(Flowable<T>, Function<? super T, ? extends SingleSource<? extends R>>) - Static method in class io.reactivex.interop.RxJava3Interop

flatMapSingle(Flowable<T>, Function<? super T, ? extends SingleSource<? extends R>>, boolean, int) - Static method in class io.reactivex.interop.RxJava3Interop

flattenAsFlowable(Single<T>, Function<? super T, ? extends Iterable<? extends R>>) - Static method in class io.reactivex.interop.RxJava3Interop

flattenAsFlowable(Maybe<T>, Function<? super T, ? extends Iterable<? extends R>>) - Static method in class io.reactivex.interop.RxJava3Interop

I

ignoreElements(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

io.reactivex.interop - package io.reactivex.interop

isEmpty(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

L

last(Flowable<T>, T) - Static method in class io.reactivex.interop.RxJava3Interop

lastElement(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

lastOrError(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

M

mergeCompletable(Flowable<? extends CompletableSource>) - Static method in class io.reactivex.interop.RxJava3Interop

mergeCompletable(Flowable<? extends CompletableSource>, int) - Static method in class io.reactivex.interop.RxJava3Interop

mergeCompletableDelayError(Flowable<? extends CompletableSource>) - Static method in class io.reactivex.interop.RxJava3Interop

mergeCompletableDelayError(Flowable<? extends CompletableSource>, int) - Static method in class io.reactivex.interop.RxJava3Interop

mergeMaybe(Flowable<? extends Maybe<? extends R>>) - Static method in class io.reactivex.interop.RxJava3Interop

mergeMaybe(Flowable<? extends Maybe<? extends R>>, int) - Static method in class io.reactivex.interop.RxJava3Interop

mergeSingle(Flowable<? extends Single<? extends R>>) - Static method in class io.reactivex.interop.RxJava3Interop

R

reduce(Flowable<T>, BiFunction<T, T, T>) - Static method in class io.reactivex.interop.RxJava3Interop

reduce(Flowable<T>, R, BiFunction<R, ? super T, R>) - Static method in class io.reactivex.interop.RxJava3Interop

reduceWith(Flowable<T>, Callable<R>, BiFunction<R, ? super T, R>) - Static method in class io.reactivex.interop.RxJava3Interop

RxJava3Interop - Class in io.reactivex.interop

The base utility class that hosts factory methods and functions to be used with the various base classes' to(Function) methods to enable interoperation between the base reactive types and some of their features.

S

single(Flowable<T>, T) - Static method in class io.reactivex.interop.RxJava3Interop

singleElement(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

singleOrError(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

T

takeUntil(Single<T>, Publisher<U>) - Static method in class io.reactivex.interop.RxJava3Interop

takeUntil(Maybe<T>, Publisher<U>) - Static method in class io.reactivex.interop.RxJava3Interop

timeout(Maybe<T>, Publisher<U>) - Static method in class io.reactivex.interop.RxJava3Interop

timeout(Maybe<T>, Publisher<U>, Maybe<T>) - Static method in class io.reactivex.interop.RxJava3Interop

toFlowable(ObservableSource<T>, BackpressureStrategy) - Static method in class io.reactivex.interop.RxJava3Interop

toFlowable(SingleSource<T>) - Static method in class io.reactivex.interop.RxJava3Interop

toFlowable(MaybeSource<T>) - Static method in class io.reactivex.interop.RxJava3Interop

toFlowable(CompletableSource) - Static method in class io.reactivex.interop.RxJava3Interop

toList(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

toList(Flowable<T>, int) - Static method in class io.reactivex.interop.RxJava3Interop

toList(Flowable<T>, Callable<C>) - Static method in class io.reactivex.interop.RxJava3Interop

toMap(Flowable<T>, Function<? super T, ? extends K>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a single HashMap containing all items emitted by the source Publisher, mapped by the keys returned by a specified keySelector function.

toMap(Flowable<T>, Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a single HashMap containing values corresponding to items emitted by the source Publisher, mapped by the keys returned by a specified keySelector function.

toMap(Flowable<T>, Function<? super T, ? extends K>, Function<? super T, ? extends V>, Callable<? extends Map<K, V>>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a single Map, returned by a specified mapFactory function, that contains keys and values extracted from the items emitted by the source Publisher.

toMultimap(Flowable<T>, Function<? super T, ? extends K>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a single HashMap that contains an ArrayList of items emitted by the source Publisher keyed by a specified keySelector function.

toMultimap(Flowable<T>, Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a single HashMap that contains an ArrayList of values extracted by a specified valueSelector function from items emitted by the source Publisher, keyed by a specified keySelector function.

toMultimap(Flowable<T>, Function<? super T, ? extends K>, Function<? super T, ? extends V>, Callable<? extends Map<K, Collection<V>>>, Function<? super K, ? extends Collection<? super V>>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a single Map, returned by a specified mapFactory function, that contains a custom collection of values, extracted by a specified valueSelector function from items emitted by the source Publisher, and keyed by the keySelector function.

toMultimap(Flowable<T>, Function<? super T, ? extends K>, Function<? super T, ? extends V>, Callable<Map<K, Collection<V>>>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a single Map, returned by a specified mapFactory function, that contains an ArrayList of values, extracted by a specified valueSelector function from items emitted by the source Publisher and keyed by the keySelector function.

toObservable(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

toSortedList(Flowable<T>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a list that contains the items emitted by the source Publisher, in a sorted order.

toSortedList(Flowable<T>, Comparator<? super T>) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a list that contains the items emitted by the source Publisher, in a sorted order based on a specified comparison function.

toSortedList(Flowable<T>, Comparator<? super T>, int) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Single that emits a list that contains the items emitted by the source Publisher, in a sorted order based on a specified comparison function.

toSortedList(Flowable<T>, int) - Static method in class io.reactivex.interop.RxJava3Interop

Returns a Flowable that emits a list that contains the items emitted by the source Publisher, in a sorted order.

W

when(Scheduler, Function<Flowable<Flowable<Completable>>, Completable>) - Static method in class io.reactivex.interop.RxJava3Interop

Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.

A C E F I L M R S T W