A B C D E F G H I J K L M N O P Q R S T U V W X Z

P

parallel() - Method in class reactor.core.publisher.Flux

Prepare this Flux by dividing data on a number of 'rails' matching the number of CPU cores, in a round-robin fashion.

parallel(int) - Method in class reactor.core.publisher.Flux

Prepare this Flux by dividing data on a number of 'rails' matching the provided parallelism parameter, in a round-robin fashion.

parallel(int, int) - Method in class reactor.core.publisher.Flux

Prepare this Flux by dividing data on a number of 'rails' matching the provided parallelism parameter, in a round-robin fashion and using a custom prefetch amount and queue for dealing with the source Flux's values.

parallel() - Static method in class reactor.core.scheduler.Schedulers

The common parallel instance, a Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.

ParallelFlux<T> - Class in reactor.core.publisher

A ParallelFlux publishes to an array of Subscribers, in parallel 'rails' (or 'groups').

ParallelFlux() - Constructor for class reactor.core.publisher.ParallelFlux

parallelism() - Method in class reactor.core.publisher.ParallelFlux

Returns the number of expected parallel Subscribers.

PARENT - Static variable in class reactor.core.Scannable.Attr

Parent key exposes the direct upstream relationship of the scanned component.

parents() - Method in interface reactor.core.Scannable

Return a Stream navigating the Subscription chain (upward).

peek() - Method in interface reactor.core.Fuseable.QueueSubscription

peek() - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

this method is discouraged, consider peeking into a MonoProcessor by turning it into a CompletableFuture

poll() - Method in class reactor.core.publisher.Operators.MonoSubscriber

poll() - Method in class reactor.core.publisher.UnicastProcessor

Deprecated.

PREFETCH - Static variable in class reactor.core.Scannable.Attr

Prefetch is an Integer attribute defining the rate of processing in a component which has capacity to request and hold a backlog of data.

prefix(CONTAINER) - Method in interface reactor.test.ValueFormatters.Extractor

Return the prefix to use in the container's String representation, given the original container.

premain(String, Instrumentation) - Static method in class reactor.tools.agent.ReactorDebugAgent

Deprecated.

to discourage the usage from user's code

processExistingClasses() - Static method in class reactor.tools.agent.ReactorDebugAgent

produced(AtomicLongFieldUpdater<T>, T, long) - Static method in class reactor.core.publisher.Operators

Concurrent subtraction bound to 0, mostly used to decrement a request tracker by the amount produced by the operator.

propagate(Throwable) - Static method in class reactor.core.Exceptions

Prepare an unchecked RuntimeException that should be propagated downstream through Subscriber.onError(Throwable).

publish() - Method in class reactor.core.publisher.Flux

Prepare a ConnectableFlux which shares this Flux sequence and dispatches values to subscribers in a backpressure-aware manner.

publish(int) - Method in class reactor.core.publisher.Flux

Prepare a ConnectableFlux which shares this Flux sequence and dispatches values to subscribers in a backpressure-aware manner.

publish(Function<? super Flux<T>, ? extends Publisher<? extends R>>) - Method in class reactor.core.publisher.Flux

Shares a sequence for the duration of a function that may transform it and consume it as many times as necessary without causing multiple subscriptions to the upstream.

publish(Function<? super Flux<T>, ? extends Publisher<? extends R>>, int) - Method in class reactor.core.publisher.Flux

Shares a sequence for the duration of a function that may transform it and consume it as many times as necessary without causing multiple subscriptions to the upstream.

publish(Function<? super Mono<T>, ? extends Mono<? extends R>>) - Method in class reactor.core.publisher.Mono

Share a Mono for the duration of a function that may transform it and consume it as many times as necessary without causing multiple subscriptions to the upstream.

PublisherProbe<T> - Interface in reactor.test.publisher

A test utility that allow to easily obtain an instrumented Publisher (Mono or Flux) for tests involving control flow.

PublisherProbe.DefaultPublisherProbe<T> - Class in reactor.test.publisher

publisherToFlowPublisher(Publisher<T>) - Static method in class reactor.adapter.JdkFlowAdapter

Return a java Flow.Publisher from a Flux

publishNext() - Method in class reactor.core.publisher.Flux

Deprecated.

use Flux.shareNext() instead, or use `publish().next()` if you need to `connect(). To be removed in 3.5.0

publishOn(Scheduler) - Method in class reactor.core.publisher.Flux

Run onNext, onComplete and onError on a supplied Scheduler Worker.

publishOn(Scheduler, int) - Method in class reactor.core.publisher.Flux

Run onNext, onComplete and onError on a supplied Scheduler Scheduler.Worker.

publishOn(Scheduler, boolean, int) - Method in class reactor.core.publisher.Flux

Run onNext, onComplete and onError on a supplied Scheduler Scheduler.Worker.

publishOn(Scheduler) - Method in class reactor.core.publisher.Mono

Run onNext, onComplete and onError on a supplied Scheduler Worker.

push(Consumer<? super FluxSink<T>>) - Static method in class reactor.core.publisher.Flux

Programmatically create a Flux with the capability of emitting multiple elements from a single-threaded producer through the FluxSink API.

push(Consumer<? super FluxSink<T>>, FluxSink.OverflowStrategy) - Static method in class reactor.core.publisher.Flux

Programmatically create a Flux with the capability of emitting multiple elements from a single-threaded producer through the FluxSink API.

put(Object, Object) - Method in interface reactor.util.context.Context

Create a new Context that contains all current key/value pairs plus the given key/value pair.

putAll(ContextView) - Method in interface reactor.util.context.Context

Create a new Context by merging the content of this context and a given ContextView.

putAll(Context) - Method in interface reactor.util.context.Context

Deprecated.

will be removed in 3.5, kept for backward compatibility with 3.3. Until then if you need to work around the deprecation, use Context.putAll(ContextView) combined with Context.readOnly()

putAllMap(Map<?, ?>) - Method in interface reactor.util.context.Context

Create a new Context by merging the content of this context and a given Map.

putNonNull(Object, Object) - Method in interface reactor.util.context.Context

Create a new Context that contains all current key/value pairs plus the given key/value pair only if the value is not null.

A B C D E F G H I J K L M N O P Q R S T U V W X Z