| 程序包 | 说明 |
|---|---|
| reactor.core.publisher | |
| reactor.test.publisher |
Components supporting the creation of test-oriented
Publishers. |
| 限定符和类型 | 方法和说明 |
|---|---|
ParallelFlux<T> |
ParallelFlux.checkpoint()
Activate traceback (full assembly tracing) for this particular
ParallelFlux, in case of an
error upstream of the checkpoint. |
ParallelFlux<T> |
ParallelFlux.checkpoint(java.lang.String description)
Activate traceback (assembly marker) for this particular
ParallelFlux by giving it a description that
will be reflected in the assembly traceback in case of an error upstream of the
checkpoint. |
ParallelFlux<T> |
ParallelFlux.checkpoint(java.lang.String description,
boolean forceStackTrace)
Activate traceback (full assembly tracing or the lighter assembly marking depending on the
forceStackTrace option). |
<C> ParallelFlux<C> |
ParallelFlux.collect(java.util.function.Supplier<? extends C> collectionSupplier,
java.util.function.BiConsumer<? super C,? super T> collector)
Collect the elements in each rail into a collection supplied via a
collectionSupplier and collected into with a collector action, emitting the
collection at the end.
|
<R> ParallelFlux<R> |
ParallelFlux.concatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Generates and concatenates Publishers on each 'rail', signalling errors immediately
and generating 2 publishers upfront.
|
<R> ParallelFlux<R> |
ParallelFlux.concatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch)
Generates and concatenates Publishers on each 'rail', signalling errors immediately
and using the given prefetch amount for generating Publishers upfront.
|
<R> ParallelFlux<R> |
ParallelFlux.concatMapDelayError(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Generates and concatenates Publishers on each 'rail', delaying errors
and generating 2 publishers upfront.
|
ParallelFlux<T> |
ParallelFlux.doAfterTerminate(java.lang.Runnable afterTerminate)
Run the specified runnable when a 'rail' completes or signals an error.
|
ParallelFlux<T> |
ParallelFlux.doOnCancel(java.lang.Runnable onCancel)
Run the specified runnable when a 'rail' receives a cancellation.
|
ParallelFlux<T> |
ParallelFlux.doOnComplete(java.lang.Runnable onComplete)
Run the specified runnable when a 'rail' completes.
|
ParallelFlux<T> |
ParallelFlux.doOnEach(java.util.function.Consumer<? super Signal<T>> signalConsumer)
Triggers side-effects when the
ParallelFlux emits an item, fails with an error
or completes successfully. |
ParallelFlux<T> |
ParallelFlux.doOnError(java.util.function.Consumer<? super java.lang.Throwable> onError)
Call the specified consumer with the exception passing through any 'rail'.
|
ParallelFlux<T> |
ParallelFlux.doOnNext(java.util.function.Consumer<? super T> onNext)
Call the specified consumer with the current element passing through any 'rail'.
|
ParallelFlux<T> |
ParallelFlux.doOnRequest(java.util.function.LongConsumer onRequest)
Call the specified consumer with the request amount if any rail receives a
request.
|
ParallelFlux<T> |
ParallelFlux.doOnSubscribe(java.util.function.Consumer<? super org.reactivestreams.Subscription> onSubscribe)
Call the specified callback when a 'rail' receives a Subscription from its
upstream.
|
ParallelFlux<T> |
ParallelFlux.doOnTerminate(java.lang.Runnable onTerminate)
Triggered when the
ParallelFlux terminates, either by completing successfully or with an error. |
ParallelFlux<T> |
ParallelFlux.filter(java.util.function.Predicate<? super T> predicate)
Filters the source values on each 'rail'.
|
<R> ParallelFlux<R> |
ParallelFlux.flatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Generates and flattens Publishers on each 'rail'.
|
<R> ParallelFlux<R> |
ParallelFlux.flatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayError)
Generates and flattens Publishers on each 'rail', optionally delaying errors.
|
<R> ParallelFlux<R> |
ParallelFlux.flatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayError,
int maxConcurrency)
Generates and flattens Publishers on each 'rail', optionally delaying errors and
having a total number of simultaneous subscriptions to the inner Publishers.
|
<R> ParallelFlux<R> |
ParallelFlux.flatMap(java.util.function.Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayError,
int maxConcurrency,
int prefetch)
Generates and flattens Publishers on each 'rail', optionally delaying errors,
having a total number of simultaneous subscriptions to the inner Publishers and
using the given prefetch amount for the inner Publishers.
|
static <T> ParallelFlux<T> |
ParallelFlux.from(org.reactivestreams.Publisher<? extends T> source)
Take a Publisher and prepare to consume it on multiple 'rails' (one per CPU core)
in a round-robin fashion.
|
static <T> ParallelFlux<T> |
ParallelFlux.from(org.reactivestreams.Publisher<? extends T> source,
int parallelism)
Take a Publisher and prepare to consume it on
parallelism number of 'rails',
possibly ordered and in a round-robin fashion. |
static <T> ParallelFlux<T> |
ParallelFlux.from(org.reactivestreams.Publisher<? extends T> source,
int parallelism,
int prefetch,
java.util.function.Supplier<java.util.Queue<T>> queueSupplier)
Take a Publisher and prepare to consume it on
parallelism number of 'rails'
and in a round-robin fashion and use custom prefetch amount and queue
for dealing with the source Publisher's values. |
static <T> ParallelFlux<T> |
ParallelFlux.from(org.reactivestreams.Publisher<T>... publishers)
Wraps multiple Publishers into a
ParallelFlux which runs them in parallel and
unordered. |
ParallelFlux<T> |
ParallelFlux.hide()
Hides the identities of this
ParallelFlux and its Subscription
as well. |
ParallelFlux<T> |
ParallelFlux.log()
Observe all Reactive Streams signals and use
Logger support to handle trace
implementation. |
ParallelFlux<T> |
ParallelFlux.log(java.lang.String category)
Observe all Reactive Streams signals and use
Logger support to handle trace
implementation. |
ParallelFlux<T> |
ParallelFlux.log(java.lang.String category,
java.util.logging.Level level,
boolean showOperatorLine,
SignalType... options)
Observe Reactive Streams signals matching the passed filter
options and use
Logger support to handle trace implementation. |
ParallelFlux<T> |
ParallelFlux.log(java.lang.String category,
java.util.logging.Level level,
SignalType... options)
Observe Reactive Streams signals matching the passed filter
options and use
Logger support to handle trace implementation. |
<U> ParallelFlux<U> |
ParallelFlux.map(java.util.function.Function<? super T,? extends U> mapper)
Maps the source values on each 'rail' to another value.
|
ParallelFlux<T> |
ParallelFlux.name(java.lang.String name)
Give a name to this sequence, which can be retrieved using
Scannable.name()
as long as this is the first reachable Scannable.parents(). |
ParallelFlux<T> |
Flux.parallel()
Prepare this
Flux by dividing data on a number of 'rails' matching the
number of CPU cores, in a round-robin fashion. |
ParallelFlux<T> |
Flux.parallel(int parallelism)
Prepare this
Flux by dividing data on a number of 'rails' matching the
provided parallelism parameter, in a round-robin fashion. |
ParallelFlux<T> |
Flux.parallel(int parallelism,
int prefetch)
|
<R> ParallelFlux<R> |
ParallelFlux.reduce(java.util.function.Supplier<R> initialSupplier,
java.util.function.BiFunction<R,? super T,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 an
initialSupplier value.
|
ParallelFlux<T> |
ParallelFlux.runOn(Scheduler scheduler)
Specifies where each 'rail' will observe its incoming values with possible
work-stealing and default prefetch amount.
|
ParallelFlux<T> |
ParallelFlux.runOn(Scheduler scheduler,
int prefetch)
Specifies where each 'rail' will observe its incoming values with possible
work-stealing and a given prefetch amount.
|
ParallelFlux<T> |
ParallelFlux.tag(java.lang.String key,
java.lang.String value)
Tag this ParallelFlux with a key/value pair.
|
<U> ParallelFlux<U> |
ParallelFlux.transform(java.util.function.Function<? super ParallelFlux<T>,ParallelFlux<U>> composer)
Allows composing operators, in assembly time, on top of this
ParallelFlux
and returns another ParallelFlux with composed features. |
<U> ParallelFlux<U> |
ParallelFlux.transformGroups(java.util.function.Function<? super GroupedFlux<java.lang.Integer,T>,? extends org.reactivestreams.Publisher<? extends U>> composer)
Allows composing operators off the groups (or 'rails'), as individual
GroupedFlux
instances keyed by the zero based rail's index. |
| 限定符和类型 | 方法和说明 |
|---|---|
<U> U |
ParallelFlux.as(java.util.function.Function<? super ParallelFlux<T>,U> converter)
Perform a fluent transformation to a value via a converter function which receives
this ParallelFlux.
|
<U> ParallelFlux<U> |
ParallelFlux.transform(java.util.function.Function<? super ParallelFlux<T>,ParallelFlux<U>> composer)
Allows composing operators, in assembly time, on top of this
ParallelFlux
and returns another ParallelFlux with composed features. |
<U> ParallelFlux<U> |
ParallelFlux.transform(java.util.function.Function<? super ParallelFlux<T>,ParallelFlux<U>> composer)
Allows composing operators, in assembly time, on top of this
ParallelFlux
and returns another ParallelFlux with composed features. |
| 限定符和类型 | 方法和说明 |
|---|---|
ParallelOperatorTest.Scenario<I,O> |
ParallelOperatorTest.Scenario.applyAllOptions(OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>> source) |
ParallelOperatorTest.Scenario<I,O> |
ParallelOperatorTest.Scenario.applyAllOptions(OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>> source) |
ParallelOperatorTest.Scenario<I,O> |
ParallelOperatorTest.scenario(java.util.function.Function<ParallelFlux<I>,? extends ParallelFlux<O>> scenario) |
ParallelOperatorTest.Scenario<I,O> |
ParallelOperatorTest.scenario(java.util.function.Function<ParallelFlux<I>,? extends ParallelFlux<O>> scenario) |