Uses of Class
io.reactivex.rxjava3.parallel.ParallelFlowable
-
Packages that use ParallelFlowable Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable
,Observable
,Single
,Maybe
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.internal.jdk8 io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.parallel Contains the base typeParallelFlowable
, a sub-DSL for working withFlowable
sequences in parallel.io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers. -
-
Uses of ParallelFlowable in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return ParallelFlowable Modifier and Type Method Description @NonNull ParallelFlowable<T>
Flowable. parallel()
Parallelizes the flow by creating multiple 'rails' (equal to the number of CPUs) and dispatches the upstream items to them in a round-robin fashion.@NonNull ParallelFlowable<T>
Flowable. parallel(int parallelism)
Parallelizes the flow by creating the specified number of 'rails' and dispatches the upstream items to them in a round-robin fashion.@NonNull ParallelFlowable<T>
Flowable. parallel(int parallelism, int prefetch)
Parallelizes the flow by creating the specified number of 'rails' and dispatches the upstream items to them in a round-robin fashion and uses the defined per-'rail' prefetch amount. -
Uses of ParallelFlowable in io.reactivex.rxjava3.internal.jdk8
Subclasses of ParallelFlowable in io.reactivex.rxjava3.internal.jdk8 Modifier and Type Class Description class
ParallelFlatMapStream<T,R>
Flattens the generatedStream
s on each rail.class
ParallelMapOptional<T,R>
Maps each 'rail' of the source ParallelFlowable with a mapper function.class
ParallelMapTryOptional<T,R>
Maps each 'rail' of the source ParallelFlowable with a mapper function and handle any failure based on a handler function.Fields in io.reactivex.rxjava3.internal.jdk8 declared as ParallelFlowable Modifier and Type Field Description (package private) ParallelFlowable<? extends T>
ParallelCollector. source
(package private) ParallelFlowable<T>
ParallelFlatMapStream. source
(package private) ParallelFlowable<T>
ParallelMapOptional. source
(package private) ParallelFlowable<T>
ParallelMapTryOptional. source
Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type ParallelFlowable Constructor Description ParallelCollector(ParallelFlowable<? extends T> source, java.util.stream.Collector<T,A,R> collector)
ParallelFlatMapStream(ParallelFlowable<T> source, Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper, int prefetch)
ParallelMapOptional(ParallelFlowable<T> source, Function<? super T,java.util.Optional<? extends R>> mapper)
ParallelMapTryOptional(ParallelFlowable<T> source, Function<? super T,java.util.Optional<? extends R>> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
-
Uses of ParallelFlowable in io.reactivex.rxjava3.internal.operators.parallel
Subclasses of ParallelFlowable in io.reactivex.rxjava3.internal.operators.parallel Modifier and Type Class Description class
ParallelCollect<T,C>
Reduce the sequence of values in each 'rail' to a single value.class
ParallelConcatMap<T,R>
Concatenates the generated Publishers on each rail.class
ParallelDoOnNextTry<T>
Calls a Consumer for each upstream value passing by and handles any failure with a handler function.class
ParallelFilter<T>
Filters each 'rail' of the source ParallelFlowable with a predicate function.class
ParallelFilterTry<T>
Filters each 'rail' of the source ParallelFlowable with a predicate function.class
ParallelFlatMap<T,R>
Flattens the generated Publishers on each rail.class
ParallelFlatMapIterable<T,R>
Flattens the generatedIterable
s on each rail.class
ParallelFromArray<T>
Wraps multiple Publishers into a ParallelFlowable which runs them in parallel.class
ParallelFromPublisher<T>
Dispatches the values from upstream in a round robin fashion to subscribers which are ready to consume elements.class
ParallelMap<T,R>
Maps each 'rail' of the source ParallelFlowable with a mapper function.class
ParallelMapTry<T,R>
Maps each 'rail' of the source ParallelFlowable with a mapper function and handle any failure based on a handler function.class
ParallelPeek<T>
Execute a Consumer in each 'rail' for the current element passing through.class
ParallelReduce<T,R>
Reduce the sequence of values in each 'rail' to a single value.class
ParallelRunOn<T>
Ensures each 'rail' from upstream runs on a Worker from a Scheduler.Fields in io.reactivex.rxjava3.internal.operators.parallel declared as ParallelFlowable Modifier and Type Field Description (package private) ParallelFlowable<? extends T>
ParallelCollect. source
(package private) ParallelFlowable<T>
ParallelConcatMap. source
(package private) ParallelFlowable<T>
ParallelDoOnNextTry. source
(package private) ParallelFlowable<T>
ParallelFilter. source
(package private) ParallelFlowable<T>
ParallelFilterTry. source
(package private) ParallelFlowable<T>
ParallelFlatMap. source
(package private) ParallelFlowable<T>
ParallelFlatMapIterable. source
(package private) ParallelFlowable<? extends T>
ParallelJoin. source
(package private) ParallelFlowable<T>
ParallelMap. source
(package private) ParallelFlowable<T>
ParallelMapTry. source
(package private) ParallelFlowable<T>
ParallelPeek. source
(package private) ParallelFlowable<? extends T>
ParallelReduce. source
(package private) ParallelFlowable<? extends T>
ParallelReduceFull. source
(package private) ParallelFlowable<? extends T>
ParallelRunOn. source
(package private) ParallelFlowable<java.util.List<T>>
ParallelSortedJoin. source
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type ParallelFlowable Constructor Description ParallelCollect(ParallelFlowable<? extends T> source, Supplier<? extends C> initialCollection, BiConsumer<? super C,? super T> collector)
ParallelConcatMap(ParallelFlowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode)
ParallelDoOnNextTry(ParallelFlowable<T> source, Consumer<? super T> onNext, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilter(ParallelFlowable<T> source, Predicate<? super T> predicate)
ParallelFilterTry(ParallelFlowable<T> source, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFlatMap(ParallelFlowable<T> source, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency, int prefetch)
ParallelFlatMapIterable(ParallelFlowable<T> source, Function<? super T,? extends java.lang.Iterable<? extends R>> mapper, int prefetch)
ParallelJoin(ParallelFlowable<? extends T> source, int prefetch, boolean delayErrors)
ParallelMap(ParallelFlowable<T> source, Function<? super T,? extends R> mapper)
ParallelMapTry(ParallelFlowable<T> source, Function<? super T,? extends R> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelPeek(ParallelFlowable<T> source, Consumer<? super T> onNext, Consumer<? super T> onAfterNext, Consumer<? super java.lang.Throwable> onError, Action onComplete, Action onAfterTerminated, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel)
ParallelReduce(ParallelFlowable<? extends T> source, Supplier<R> initialSupplier, BiFunction<R,? super T,R> reducer)
ParallelReduceFull(ParallelFlowable<? extends T> source, BiFunction<T,T,T> reducer)
ParallelRunOn(ParallelFlowable<? extends T> parent, Scheduler scheduler, int prefetch)
ParallelSortedJoin(ParallelFlowable<java.util.List<T>> source, java.util.Comparator<? super T> comparator)
-
Uses of ParallelFlowable in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel that return ParallelFlowable Modifier and Type Method Description @NonNull ParallelFlowable<Downstream>
ParallelTransformer. apply(@NonNull ParallelFlowable<@NonNull Upstream> upstream)
Applies a function to the upstream ParallelFlowable and returns a ParallelFlowable with optionally different element type.<@NonNull C>
@NonNull ParallelFlowable<C>ParallelFlowable. collect(@NonNull Supplier<? extends @NonNull C> collectionSupplier, @NonNull BiConsumer<? super @NonNull C,? super @NonNull T> collector)
Collect the elements in each rail into a collection supplied via acollectionSupplier
and collected into with a collector action, emitting the collection at the end.<@NonNull U>
@NonNull ParallelFlowable<U>ParallelFlowable. compose(@NonNull ParallelTransformer<@NonNull T,@NonNull U> composer)
Allows composing operators, in assembly time, on top of thisParallelFlowable
and returns anotherParallelFlowable
with composed features.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. concatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper)
Generates and concatenatesPublisher
s on each 'rail', signalling errors immediately and generating 2 publishers upfront.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. concatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch)
Generates and concatenatesPublisher
s on each 'rail', signalling errors immediately and using the given prefetch amount for generatingPublisher
s upfront.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. concatMapDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean tillTheEnd)
Generates and concatenatesPublisher
s on each 'rail', optionally delaying errors and generating 2 publishers upfront.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. concatMapDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch, boolean tillTheEnd)
Generates and concatenatesPublisher
s on each 'rail', optionally delaying errors and using the given prefetch amount for generatingPublisher
s upfront.@NonNull ParallelFlowable<T>
ParallelFlowable. doAfterNext(@NonNull Consumer<? super @NonNull T> onAfterNext)
Call the specified consumer with the current element passing through any 'rail' after it has been delivered to downstream within the rail.@NonNull ParallelFlowable<T>
ParallelFlowable. doAfterTerminated(@NonNull Action onAfterTerminate)
Run the specifiedAction
when a 'rail' completes or signals an error.@NonNull ParallelFlowable<T>
ParallelFlowable. doOnCancel(@NonNull Action onCancel)
Run the specifiedAction
when a 'rail' receives a cancellation.@NonNull ParallelFlowable<T>
ParallelFlowable. doOnComplete(@NonNull Action onComplete)
Run the specifiedAction
when a 'rail' completes.@NonNull ParallelFlowable<T>
ParallelFlowable. doOnError(@NonNull Consumer<? super java.lang.Throwable> onError)
Call the specified consumer with the exception passing through any 'rail'.@NonNull ParallelFlowable<T>
ParallelFlowable. doOnNext(@NonNull Consumer<? super @NonNull T> onNext)
Call the specified consumer with the current element passing through any 'rail'.@NonNull ParallelFlowable<T>
ParallelFlowable. doOnNext(@NonNull Consumer<? super @NonNull T> onNext, @NonNull BiFunction<? super java.lang.Long,? super java.lang.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.@NonNull ParallelFlowable<T>
ParallelFlowable. doOnNext(@NonNull Consumer<? super @NonNull T> onNext, @NonNull ParallelFailureHandling errorHandler)
Call the specified consumer with the current element passing through any 'rail' and handles errors based on the givenParallelFailureHandling
enumeration value.@NonNull ParallelFlowable<T>
ParallelFlowable. doOnRequest(@NonNull LongConsumer onRequest)
Call the specified consumer with the request amount if any rail receives a request.@NonNull ParallelFlowable<T>
ParallelFlowable. doOnSubscribe(@NonNull Consumer<? super org.reactivestreams.Subscription> onSubscribe)
Call the specified callback when a 'rail' receives aSubscription
from its upstream.@NonNull ParallelFlowable<T>
ParallelFlowable. filter(@NonNull Predicate<? super @NonNull T> predicate)
Filters the source values on each 'rail'.@NonNull ParallelFlowable<T>
ParallelFlowable. filter(@NonNull Predicate<? super @NonNull T> predicate, @NonNull BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
Filters the source values on each 'rail' and handles errors based on the returned value by the handler function.@NonNull ParallelFlowable<T>
ParallelFlowable. filter(@NonNull Predicate<? super @NonNull T> predicate, @NonNull ParallelFailureHandling errorHandler)
Filters the source values on each 'rail' and handles errors based on the givenParallelFailureHandling
enumeration value.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper)
Generates and flattensPublisher
s on each 'rail'.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError)
Generates and flattensPublisher
s on each 'rail', optionally delaying errors.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError, int maxConcurrency)
Generates and flattensPublisher
s on each 'rail', optionally delaying errors and having a total number of simultaneous subscriptions to the innerPublisher
s.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError, int maxConcurrency, int prefetch)
Generates and flattensPublisher
s on each 'rail', optionally delaying errors, having a total number of simultaneous subscriptions to the innerPublisher
s and using the given prefetch amount for the innerPublisher
s.<@NonNull U>
@NonNull ParallelFlowable<U>ParallelFlowable. flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper)
Returns aParallelFlowable
that merges each item emitted by the source on each rail with the values in anIterable
corresponding to that item that is generated by a selector.<@NonNull U>
@NonNull ParallelFlowable<U>ParallelFlowable. flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper, int bufferSize)
Returns aParallelFlowable
that merges each item emitted by the sourceParallelFlowable
with the values in anIterable
corresponding to that item that is generated by a selector.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. flatMapStream(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper)
Maps each upstream item on each rail into aStream
and emits theStream
's items to the downstream in a sequential fashion.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. flatMapStream(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper, int prefetch)
Maps each upstream item of each rail into aStream
and emits theStream
's items to the downstream in a sequential fashion.static <@NonNull T>
@NonNull ParallelFlowable<T>ParallelFlowable. from(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source)
Take aPublisher
and prepare to consume it on multiple 'rails' (number of CPUs) in a round-robin fashion.static <@NonNull T>
@NonNull ParallelFlowable<T>ParallelFlowable. from(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source, int parallelism)
Take aPublisher
and prepare to consume it on parallelism number of 'rails' in a round-robin fashion.static <@NonNull T>
@NonNull ParallelFlowable<T>ParallelFlowable. from(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source, int parallelism, int prefetch)
Take aPublisher
and prepare to consume it on parallelism number of 'rails' , possibly ordered and round-robin fashion and use custom prefetch amount and queue for dealing with the sourcePublisher
's values.static <@NonNull T>
@NonNull ParallelFlowable<T>ParallelFlowable. fromArray(@NonNull org.reactivestreams.Publisher<@NonNull T>... publishers)
Wraps multiplePublisher
s into aParallelFlowable
which runs them in parallel and unordered.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper)
Maps the source values on each 'rail' to another value.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper, @NonNull BiFunction<? super java.lang.Long,? super java.lang.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.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper, @NonNull ParallelFailureHandling errorHandler)
Maps the source values on each 'rail' to another value and handles errors based on the givenParallelFailureHandling
enumeration value.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper)
Maps the source values on each 'rail' to an optional and emits its value if any.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper, @NonNull BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
Maps the source values on each 'rail' to an optional and emits its value if any and handles errors based on the returned value by the handler function.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper, @NonNull ParallelFailureHandling errorHandler)
Maps the source values on each 'rail' to an optional and emits its value if any and handles errors based on the givenParallelFailureHandling
enumeration value.<@NonNull R>
@NonNull ParallelFlowable<R>ParallelFlowable. reduce(@NonNull Supplier<@NonNull R> initialSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> reducer)
Reduces all values within a 'rail' to a single value (with a possibly different type) via a reducer function that is initialized on each rail from aninitialSupplier
value.@NonNull ParallelFlowable<T>
ParallelFlowable. runOn(@NonNull Scheduler scheduler)
Specifies where each 'rail' will observe its incoming values, specified via aScheduler
, with no work-stealing and default prefetch amount.@NonNull ParallelFlowable<T>
ParallelFlowable. runOn(@NonNull Scheduler scheduler, int prefetch)
Specifies where each 'rail' will observe its incoming values, specified via aScheduler
, with possibly work-stealing and a given prefetch amount.Methods in io.reactivex.rxjava3.parallel with parameters of type ParallelFlowable Modifier and Type Method Description R
ParallelFlowableConverter. apply(@NonNull ParallelFlowable<T> upstream)
Applies a function to the upstream ParallelFlowable and returns a converted value of typeR
.@NonNull ParallelFlowable<Downstream>
ParallelTransformer. apply(@NonNull ParallelFlowable<@NonNull Upstream> upstream)
Applies a function to the upstream ParallelFlowable and returns a ParallelFlowable with optionally different element type. -
Uses of ParallelFlowable in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with type parameters of type ParallelFlowable Modifier and Type Field Description (package private) static @Nullable Function<? super ParallelFlowable,? extends ParallelFlowable>
RxJavaPlugins. onParallelAssembly
(package private) static @Nullable Function<? super ParallelFlowable,? extends ParallelFlowable>
RxJavaPlugins. onParallelAssembly
(package private) static @Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]>
RxJavaPlugins. onParallelSubscribe
Methods in io.reactivex.rxjava3.plugins that return ParallelFlowable Modifier and Type Method Description static <@NonNull T>
@NonNull ParallelFlowable<T>RxJavaPlugins. onAssembly(@NonNull ParallelFlowable<@NonNull T> source)
Calls the associated hook function.Methods in io.reactivex.rxjava3.plugins that return types with arguments of type ParallelFlowable Modifier and Type Method Description static @Nullable Function<? super ParallelFlowable,? extends ParallelFlowable>
RxJavaPlugins. getOnParallelAssembly()
Returns the current hook function.static @Nullable Function<? super ParallelFlowable,? extends ParallelFlowable>
RxJavaPlugins. getOnParallelAssembly()
Returns the current hook function.static @Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]>
RxJavaPlugins. getOnParallelSubscribe()
Returns the current hook function.Methods in io.reactivex.rxjava3.plugins with parameters of type ParallelFlowable Modifier and Type Method Description static <@NonNull T>
@NonNull ParallelFlowable<T>RxJavaPlugins. onAssembly(@NonNull ParallelFlowable<@NonNull T> source)
Calls the associated hook function.static <@NonNull T>
@NonNull org.reactivestreams.Subscriber<? super T>[]RxJavaPlugins. onSubscribe(@NonNull ParallelFlowable<@NonNull T> source, @NonNull org.reactivestreams.Subscriber<? super @NonNull T>[] subscribers)
Calls the associated hook function.Method parameters in io.reactivex.rxjava3.plugins with type arguments of type ParallelFlowable Modifier and Type Method Description static void
RxJavaPlugins. setOnParallelAssembly(@Nullable Function<? super ParallelFlowable,? extends ParallelFlowable> handler)
Sets the specific hook function.static void
RxJavaPlugins. setOnParallelAssembly(@Nullable Function<? super ParallelFlowable,? extends ParallelFlowable> handler)
Sets the specific hook function.static void
RxJavaPlugins. setOnParallelSubscribe(@Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]> handler)
Sets the specific hook function.
-