Package | Description |
---|---|
io.reactivex.internal.operators.parallel | |
io.reactivex.parallel |
Contains the base type
ParallelFlowable ,
a sub-DSL for working with Flowable sequences in parallel. |
Constructor and Description |
---|
ParallelDoOnNextTry(ParallelFlowable<T> source,
Consumer<? super T> onNext,
BiFunction<? super Long,? super Throwable,ParallelFailureHandling> errorHandler) |
ParallelFilterTry(ParallelFlowable<T> source,
Predicate<? super T> predicate,
BiFunction<? super Long,? super Throwable,ParallelFailureHandling> errorHandler) |
ParallelMapTry(ParallelFlowable<T> source,
Function<? super T,? extends R> mapper,
BiFunction<? super Long,? super Throwable,ParallelFailureHandling> errorHandler) |
Modifier and Type | Method and Description |
---|---|
ParallelFailureHandling |
ParallelFailureHandling.apply(Long t1,
Throwable t2) |
static ParallelFailureHandling |
ParallelFailureHandling.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ParallelFailureHandling[] |
ParallelFailureHandling.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
ParallelFlowable<T> |
ParallelFlowable.doOnNext(Consumer<? super T> onNext,
ParallelFailureHandling errorHandler)
Call the specified consumer with the current element passing through any 'rail' and
handles errors based on the given
ParallelFailureHandling enumeration value. |
ParallelFlowable<T> |
ParallelFlowable.filter(Predicate<? super T> predicate,
ParallelFailureHandling errorHandler)
Filters the source values on each 'rail' and
handles errors based on the given
ParallelFailureHandling enumeration value. |
<R> ParallelFlowable<R> |
ParallelFlowable.map(Function<? super T,? extends R> mapper,
ParallelFailureHandling errorHandler)
Maps the source values on each 'rail' to another value and
handles errors based on the given
ParallelFailureHandling enumeration value. |
Modifier and Type | Method and Description |
---|---|
ParallelFlowable<T> |
ParallelFlowable.doOnNext(Consumer<? super T> onNext,
BiFunction<? super Long,? super Throwable,ParallelFailureHandling> errorHandler)
Call the specified consumer with the current element passing through any 'rail' and
handles errors based on the returned value by the handler function.
|
ParallelFlowable<T> |
ParallelFlowable.filter(Predicate<? super T> predicate,
BiFunction<? super Long,? super Throwable,ParallelFailureHandling> errorHandler)
Filters the source values on each 'rail' and
handles errors based on the returned value by the handler function.
|
<R> ParallelFlowable<R> |
ParallelFlowable.map(Function<? super T,? extends R> mapper,
BiFunction<? super Long,? super Throwable,ParallelFailureHandling> errorHandler)
Maps the source values on each 'rail' to another value and
handles errors based on the returned value by the handler function.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.