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

B

backoff(long, Duration) - Static method in class reactor.util.retry.Retry

A RetryBackoffSpec preconfigured for exponential backoff strategy with jitter, given a maximum number of retry attempts and a minimum Duration for the backoff.

backoffSchedulerSupplier - Variable in class reactor.util.retry.RetryBackoffSpec

The configured Supplier of Scheduler on which to execute backoffs.

BACKPRESSURE_ERROR_QUEUE_FULL - Static variable in class reactor.core.Exceptions

A common error message used when a reactive streams source doesn't seem to respect backpressure signals, resulting in an operator's internal queue to be full.

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

A simple base class for a Subscriber implementation that lets the user perform a BaseSubscriber.request(long) and BaseSubscriber.cancel() on it directly.

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

block() - Method in class reactor.core.publisher.Mono

Subscribe to this Mono and block indefinitely until a next signal is received.

block(Duration) - Method in class reactor.core.publisher.Mono

Subscribe to this Mono and block until a next signal is received or a timeout expires.

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

Deprecated.

Block the calling thread indefinitely, waiting for the completion of this MonoProcessor.

block(Duration) - Method in class reactor.core.publisher.MonoProcessor

Deprecated.

Block the calling thread for the specified time, waiting for the completion of this MonoProcessor.

block() - Method in interface reactor.test.subscriber.TestSubscriber

Block until an assertable end state has been reached.

block(Duration) - Method in interface reactor.test.subscriber.TestSubscriber

Block until an assertable end state has been reached, or a timeout Duration has elapsed.

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

Subscribe to this Flux and block indefinitely until the upstream signals its first value or completes.

blockFirst(Duration) - Method in class reactor.core.publisher.Flux

Subscribe to this Flux and block until the upstream signals its first value, completes or a timeout expires.

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

Subscribe to this Flux and block indefinitely until the upstream signals its last value or completes.

blockLast(Duration) - Method in class reactor.core.publisher.Flux

Subscribe to this Flux and block until the upstream signals its last value, completes or a timeout expires.

blockOptional() - Method in class reactor.core.publisher.Mono

Subscribe to this Mono and block indefinitely until a next signal is received or the Mono completes empty.

blockOptional(Duration) - Method in class reactor.core.publisher.Mono

Subscribe to this Mono and block until a next signal is received, the Mono completes empty or a timeout expires.

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

The common boundedElastic instance, a Scheduler that dynamically creates a bounded number of ExecutorService-based Workers, reusing them once the Workers have been shut down.

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

Prepare an unchecked RuntimeException that will bubble upstream if thrown by an operator.

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

Collect all incoming values into a single List buffer that will be emitted by the returned Flux once this Flux completes.

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

Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the given max size is reached or once this Flux completes.

buffer(int, Supplier<C>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the given max size is reached or once this Flux completes.

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

Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the given max size is reached or once this Flux completes.

buffer(int, int, Supplier<C>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the given max size is reached or once this Flux completes.

buffer(Publisher<?>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers, as delimited by the signals of a companion Publisher this operator will subscribe to.

buffer(Publisher<?>, Supplier<C>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple user-defined Collection buffers, as delimited by the signals of a companion Publisher this operator will subscribe to.

buffer(Duration) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers that will be emitted by the returned Flux every bufferingTimespan.

buffer(Duration, Duration) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers created at a given openBufferEvery period.

buffer(Duration, Scheduler) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers that will be emitted by the returned Flux every bufferingTimespan, as measured on the provided Scheduler.

buffer(Duration, Duration, Scheduler) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers created at a given openBufferEvery period, as measured on the provided Scheduler.

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

A Integer attribute implemented by components with a backlog capacity.

BufferOverflowStrategy - Enum in reactor.core.publisher

Strategies to deal with overflow of a buffer during backpressure buffering.

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

Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses.

bufferTimeout(int, Duration, Supplier<C>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses.

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

Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses, as measured on the provided Scheduler.

bufferTimeout(int, Duration, Scheduler, Supplier<C>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses, as measured on the provided Scheduler.

bufferTimeout(int, Duration, boolean) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses.

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

Collect incoming values into multiple List buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses, as measured on the provided Scheduler.

bufferTimeout(int, Duration, Supplier<C>, boolean) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses.

bufferTimeout(int, Duration, Scheduler, Supplier<C>, boolean) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple user-defined Collection buffers that will be emitted by the returned Flux each time the buffer reaches a maximum size OR the maxTime Duration elapses, as measured on the provided Scheduler.

bufferUntil(Predicate<? super T>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers that will be emitted by the resulting Flux each time the given predicate returns true.

bufferUntil(Predicate<? super T>, boolean) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers that will be emitted by the resulting Flux each time the given predicate returns true.

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

Collect subsequent repetitions of an element (that is, if they arrive right after one another) into multiple List buffers that will be emitted by the resulting Flux.

bufferUntilChanged(Function<? super T, ? extends V>) - Method in class reactor.core.publisher.Flux

Collect subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function, into multiple List buffers that will be emitted by the resulting Flux.

bufferUntilChanged(Function<? super T, ? extends V>, BiPredicate<? super V, ? super V>) - Method in class reactor.core.publisher.Flux

Collect subsequent repetitions of an element (that is, if they arrive right after one another), as compared by a key extracted through the user provided Function and compared using a supplied BiPredicate, into multiple List buffers that will be emitted by the resulting Flux.

bufferWhen(Publisher<U>, Function<? super U, ? extends Publisher<V>>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers started each time an opening companion Publisher emits.

bufferWhen(Publisher<U>, Function<? super U, ? extends Publisher<V>>, Supplier<C>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple user-defined Collection buffers started each time an opening companion Publisher emits.

bufferWhile(Predicate<? super T>) - Method in class reactor.core.publisher.Flux

Collect incoming values into multiple List buffers that will be emitted by the resulting Flux.

build() - Method in class reactor.test.subscriber.TestSubscriberBuilder

Create a TestSubscriber according to this builder.

buildConditional(Predicate<? super T>) - Method in class reactor.test.subscriber.TestSubscriberBuilder

Create a Fuseable.ConditionalSubscriber variant of TestSubscriber according to this builder.

builder() - Static method in interface reactor.test.subscriber.TestSubscriber

Create a TestSubscriber with tuning.

busyLooping(Duration) - Static method in interface reactor.core.publisher.Sinks.EmitFailureHandler

Create an Sinks.EmitFailureHandler which will busy loop in case of concurrent use of the sink (Sinks.EmitResult.FAIL_NON_SERIALIZED, up to a deadline.

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