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

B

backoff(long, Duration) - 类 中的静态方法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.

backoffFunctionNotTransient() - 类 中的方法reactor.core.publisher.FluxRetryWhenTest

backoffFunctionTransient() - 类 中的方法reactor.core.publisher.FluxRetryWhenTest

backoffSchedulerDefaultIsLazilyResolved() - 类 中的方法reactor.util.retry.RetryBackoffSpecTest

backoffSchedulerIsEagerlyCaptured() - 类 中的方法reactor.util.retry.RetryBackoffSpecTest

backoffSchedulerNullResetToDefaultSupplier() - 类 中的方法reactor.util.retry.RetryBackoffSpecTest

backoffSchedulerSupplier - 类 中的变量reactor.util.retry.RetryBackoffSpec

The configured Supplier of Scheduler on which to execute backoffs.

backpressure() - 类 中的方法reactor.core.publisher.FluxGroupByTest

BACKPRESSURE_ERROR_QUEUE_FULL - 类 中的静态变量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.

backpressureConditionalTest() - 类 中的方法reactor.core.publisher.FluxSwitchOnFirstTest

backpressured() - 类 中的方法reactor.core.publisher.FluxDetachTest

backpressured() - 类 中的方法reactor.core.publisher.FluxOnBackpressureLatestTest

backpressured() - 类 中的方法reactor.core.publisher.MonoDetachTest

backpressuredAsyncFusedCancelled() - 类 中的方法reactor.core.publisher.FluxZipTest

backpressuredAsyncFusedCancelled2() - 类 中的方法reactor.core.publisher.FluxZipTest

backpressuredAsyncFusedComplete() - 类 中的方法reactor.core.publisher.FluxZipTest

backpressuredAsyncFusedError() - 类 中的方法reactor.core.publisher.FluxZipTest

backpressuredAsyncFusedErrorHideAll() - 类 中的方法reactor.core.publisher.FluxZipTest

backpressuredComplex() - 类 中的方法reactor.core.publisher.FluxOnBackpressureLatestTest

backpressureDrawbackOnConditionalInTransformTest() - 类 中的方法reactor.core.publisher.FluxSwitchOnFirstTest

backpressuredScalarThenCancel() - 类 中的方法reactor.core.publisher.FluxFlatMapTest

backpressuredThenCancel() - 类 中的方法reactor.core.publisher.FluxFlatMapTest

backpressureExactlyOne() - 类 中的方法reactor.core.publisher.FluxFilterWhenTest

backpressureExactlyOne() - 类 中的方法reactor.core.publisher.MonoFilterWhenTest

backpressureHiddenConditionalTest() - 类 中的方法reactor.core.publisher.FluxSwitchOnFirstTest

backpressureTest() - 类 中的方法reactor.core.publisher.FluxSwitchOnFirstTest

backpressureWithDrop() - 类 中的方法reactor.core.publisher.FluxOnBackpressureLatestTest

badPrefetch() - 类 中的方法reactor.core.publisher.FluxMergeSequentialTest

BaseOperatorTest<I,PI extends org.reactivestreams.Publisher<? extends I>,O,PO extends org.reactivestreams.Publisher<? extends O>> - reactor.test.publisher中的类

BaseOperatorTest() - 类 的构造器reactor.test.publisher.BaseOperatorTest

BaseSubscriber<T> - 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() - 类 的构造器reactor.core.publisher.BaseSubscriber

baseSubscriberFineTuneBackpressure() - 类 中的方法reactor.guide.GuideTests

BaseSubscriberTest - reactor.core.publisher中的类

BaseSubscriberTest() - 类 的构造器reactor.core.publisher.BaseSubscriberTest

BasicSchedulersStressTest - reactor.core.scheduler中的类

BasicSchedulersStressTest() - 类 的构造器reactor.core.scheduler.BasicSchedulersStressTest

BasicSchedulersStressTest.ParallelSchedulerDisposeGracefullyAndDisposeStressTest - reactor.core.scheduler中的类

BasicSchedulersStressTest.ParallelSchedulerDisposeGracefullyStressTest - reactor.core.scheduler中的类

BasicSchedulersStressTest.ParallelSchedulerStartDisposeStressTest - reactor.core.scheduler中的类

BasicSchedulersStressTest.SingleSchedulerDisposeGracefullyAndDisposeStressTest - reactor.core.scheduler中的类

BasicSchedulersStressTest.SingleSchedulerDisposeGracefullyStressTest - reactor.core.scheduler中的类

BasicSchedulersStressTest.SingleSchedulerStartDisposeStressTest - reactor.core.scheduler中的类

basicTest() - 类 中的方法reactor.core.publisher.MonoRunnableTest

before() - 类 中的静态方法reactor.core.publisher.BlockingTests

before() - 类 中的方法reactor.core.publisher.FluxDoFinallyTest

before() - 类 中的方法reactor.core.publisher.FluxIntervalTest

before() - 类 中的方法reactor.core.publisher.FluxMergeSequentialTest

before() - 类 中的方法reactor.core.publisher.FluxOnBackpressureBufferStrategyTest

before() - 类 中的静态方法reactor.core.publisher.FluxPublishOnTest

before() - 类 中的静态方法reactor.core.publisher.loop.FluxPublishOnLoop

before() - 类 中的方法reactor.core.publisher.MonoDoFinallyTest

beforeClass() - 类 中的静态方法reactor.core.publisher.ContextLossDetectionTest

beforeEach(ExtensionContext) - 类 中的方法reactor.core.TestLoggerExtension

beforeTestExecution(ExtensionContext) - 类 中的方法reactor.test.AutoDisposingExtension

behaveAsJoin() - 类 中的方法reactor.core.publisher.FluxGroupJoinTest

BiPredicateAndOfferStressTest() - 类 的构造器reactor.util.concurrent.MpscLinkedQueueStressTest.BiPredicateAndOfferStressTest

BiPredicateAndPollAtGrowthBoundaryStressTest() - 类 的构造器reactor.util.concurrent.SpscLinkedArrayQueueStressTest.BiPredicateAndPollAtGrowthBoundaryStressTest

BiPredicateAndPollStressTest() - 类 的构造器reactor.util.concurrent.MpscLinkedQueueStressTest.BiPredicateAndPollStressTest

BiPredicateAndPollStressTest() - 类 的构造器reactor.util.concurrent.SpscLinkedArrayQueueStressTest.BiPredicateAndPollStressTest

BiPredicateTwoActorsStressTest() - 类 的构造器reactor.util.concurrent.MpscLinkedQueueStressTest.BiPredicateTwoActorsStressTest

BiPredicateTwoProducersOneConsumerStressTest() - 类 的构造器reactor.util.concurrent.MpscLinkedQueueStressTest.BiPredicateTwoProducersOneConsumerStressTest

block() - 类 中的方法reactor.core.publisher.Mono

定阅此Mono并无限期阻塞，直到接收到下一个信号并返回该值 Subscribe to this Mono and block indefinitely until a next signal is received.

block(Duration) - 类 中的方法reactor.core.publisher.Mono

订阅此Mono并阻塞，直到收到下一个信号或超时到期。

block() - 类 中的方法reactor.core.publisher.MonoProcessor

已过时。

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

block(Duration) - 类 中的方法reactor.core.publisher.MonoProcessor

已过时。

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

block() - 接口 中的方法reactor.test.subscriber.TestSubscriber

Block until an assertable end state has been reached.

block(Duration) - 接口 中的方法reactor.test.subscriber.TestSubscriber

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

blockFirst() - 类 中的方法reactor.core.publisher.Flux

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

blockFirst(Duration) - 类 中的方法reactor.core.publisher.Flux

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

blockingFirst() - 类 中的方法reactor.core.publisher.BlockingTests

blockingFirst2() - 类 中的方法reactor.core.publisher.BlockingTests

blockingFirstEarlyComplete() - 类 中的方法reactor.core.publisher.BlockingTests

blockingFirstError() - 类 中的方法reactor.core.publisher.BlockingTests

blockingFirstError2() - 类 中的方法reactor.core.publisher.BlockingTests

blockingFirstTimeout() - 类 中的方法reactor.core.publisher.BlockingTests

BlockingIterableTest - reactor.core.publisher中的类

BlockingIterableTest() - 类 的构造器reactor.core.publisher.BlockingIterableTest

blockingLast() - 类 中的方法reactor.core.publisher.BlockingTests

blockingLast2() - 类 中的方法reactor.core.publisher.BlockingTests

blockingLastEarlyComplete() - 类 中的方法reactor.core.publisher.BlockingTests

blockingLastError() - 类 中的方法reactor.core.publisher.BlockingTests

blockingLastError2() - 类 中的方法reactor.core.publisher.BlockingTests

blockingLastInterrupted() - 类 中的方法reactor.core.publisher.BlockingTests

blockingLastTimeout() - 类 中的方法reactor.core.publisher.BlockingTests

BlockingOptionalMonoSubscriberTest - reactor.core.publisher中的类

BlockingOptionalMonoSubscriberTest() - 类 的构造器reactor.core.publisher.BlockingOptionalMonoSubscriberTest

BlockingSingleSubscriberTest - reactor.core.publisher中的类

BlockingSingleSubscriberTest() - 类 的构造器reactor.core.publisher.BlockingSingleSubscriberTest

blockingTasksWith100kLimit() - 类 中的方法reactor.core.scheduler.BoundedElasticSchedulerTest

BlockingTests - reactor.core.publisher中的类

BlockingTests() - 类 的构造器reactor.core.publisher.BlockingTests

blockLast() - 类 中的方法reactor.core.publisher.Flux

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

blockLast(Duration) - 类 中的方法reactor.core.publisher.Flux

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

blockOnNeverResourceCanBeCancelled() - 类 中的方法reactor.core.publisher.FluxUsingWhenTest

blockOnNeverResourceCanBeCancelled() - 类 中的方法reactor.core.publisher.MonoUsingWhenTest

blockOptional() - 类 中的方法reactor.core.publisher.Mono

订阅此Mono并无限期阻塞，直到收到下一个信号或 Mono 完成为空。

blockOptional(Duration) - 类 中的方法reactor.core.publisher.Mono

订阅此Mono并阻塞，直到收到下一个信号、Mono 完成为空或超时到期。

boundaryFused() - 类 中的方法reactor.core.publisher.FluxPublishTest

boundaryFusion() - 类 中的方法reactor.core.publisher.AbstractFluxConcatMapTest

boundaryFusionDelayError() - 类 中的方法reactor.core.publisher.AbstractFluxConcatMapTest

bounded() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest

boundedAfter() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest

boundedElastic() - 类 中的静态方法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.

BoundedElasticBusyStructureBenchmark - reactor.core.scheduler中的类

BoundedElasticBusyStructureBenchmark() - 类 的构造器reactor.core.scheduler.BoundedElasticBusyStructureBenchmark

BoundedElasticSchedulerBlockhoundTest - reactor.core.scheduler中的类

BoundedElasticSchedulerBlockhoundTest() - 类 的构造器reactor.core.scheduler.BoundedElasticSchedulerBlockhoundTest

boundedElasticSchedulerDefaultBlockingOk() - 类 中的方法reactor.core.scheduler.SchedulersTest

BoundedElasticSchedulerTest - reactor.core.scheduler中的类

BoundedElasticSchedulerTest() - 类 的构造器reactor.core.scheduler.BoundedElasticSchedulerTest

boundedElasticSchedulerThreadCheck() - 类 中的方法reactor.core.scheduler.SchedulersTest

boundedFused() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest

boundedFusedAfter() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest

boundedFusedError() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest

boundedInitialOverflowIsDetected() - 类 中的方法reactor.test.StepVerifierTests

boundedLong() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest

boundedLongError() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest

boundedOnSubscribeAndState() - 类 中的方法reactor.core.publisher.SinkManyReplayProcessorTest

boundedQueue() - 类 中的方法reactor.core.publisher.FluxPublishOnTest

boundedQueueFilter() - 类 中的方法reactor.core.publisher.FluxPublishOnTest

boundedQueueFilterLoop() - 类 中的方法reactor.core.publisher.loop.FluxPublishOnLoop

boundedQueueLoop() - 类 中的方法reactor.core.publisher.loop.FluxPublishOnLoop

boundedRequestOverflowIsDetected() - 类 中的方法reactor.test.StepVerifierTests

breadthFirst() - 类 中的方法reactor.core.publisher.FluxExpandTest

breadthFirst() - 类 中的方法reactor.core.publisher.MonoExpandTest

breadthFirstAsync() - 类 中的方法reactor.core.publisher.FluxExpandTest

breadthFirstAsync() - 类 中的方法reactor.core.publisher.MonoExpandTest

bubble(Throwable) - 类 中的静态方法reactor.core.Exceptions

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

bubble() - 类 中的方法reactor.core.ExceptionsTest

buffer() - 类 中的方法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) - 类 中的方法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>) - 类 中的方法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) - 类 中的方法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>) - 类 中的方法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<?>) - 类 中的方法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>) - 类 中的方法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) - 类 中的方法reactor.core.publisher.Flux

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

buffer(Duration, Duration) - 类 中的方法reactor.core.publisher.Flux

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

buffer(Duration, Scheduler) - 类 中的方法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) - 类 中的方法reactor.core.publisher.Flux

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

BUFFERED - 类 中的静态变量reactor.core.Scannable.Attr

A Integer attribute implemented by components with a backlog capacity.

bufferedCanCompleteIfOpenNeverCompletesDropping() - 类 中的方法reactor.core.publisher.FluxBufferWhenTest

bufferedCanCompleteIfOpenNeverCompletesOverlapping() - 类 中的方法reactor.core.publisher.FluxBufferWhenTest

bufferLimit() - 类 中的方法reactor.core.publisher.FluxOnBackpressureBufferTimeoutTest

bufferOverflowErrorDelayed() - 类 中的方法reactor.core.publisher.FluxOnBackpressureBufferTest

bufferOverflowOverflowDelayedWithErrorStrategy() - 类 中的方法reactor.core.publisher.FluxOnBackpressureBufferStrategyTest

BufferOverflowStrategy - reactor.core.publisher中的枚举

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

bufferSizeIsAlsoPrefetch() - 类 中的方法reactor.core.publisher.FluxFilterWhenTest

bufferSupplierReturnsNUll() - 类 中的方法reactor.core.publisher.FluxBufferBoundaryTest

bufferSupplierReturnsNull() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest

bufferSupplierThrows() - 类 中的方法reactor.core.publisher.FluxBufferBoundaryTest

bufferSupplierThrows() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest

bufferSupplierThrowsLater() - 类 中的方法reactor.core.publisher.FluxBufferBoundaryTest

bufferSupplierThrowsLater() - 类 中的方法reactor.core.publisher.FluxBufferPredicateTest

bufferTimeout(int, Duration) - 类 中的方法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>) - 类 中的方法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) - 类 中的方法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>) - 类 中的方法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>) - 类 中的方法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) - 类 中的方法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() - 类 中的方法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>) - 类 中的方法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>) - 类 中的方法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>>) - 类 中的方法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>) - 类 中的方法reactor.core.publisher.Flux

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

bufferWhen() - 类 中的方法reactor.core.publisher.TailCallSubscribeTest

bufferWhile(Predicate<? super T>) - 类 中的方法reactor.core.publisher.Flux

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

bufferWillAccumulateMultipleListsOfValues() - 类 中的方法reactor.core.publisher.FluxBufferBoundaryTest

bufferWillAcumulateMultipleListsOfValuesOverlap() - 类 中的方法reactor.core.publisher.FluxBufferWhenTest

bufferWillRerouteAsManyElementAsSpecified() - 类 中的方法reactor.core.publisher.FluxBufferTest

bufferWillSubdivideAnInputFlux() - 类 中的方法reactor.core.publisher.FluxBufferTest

bufferWillSubdivideAnInputFluxGapTime() - 类 中的方法reactor.core.publisher.FluxBufferWhenTest

bufferWillSubdivideAnInputFluxOverlap() - 类 中的方法reactor.core.publisher.FluxBufferTest

bufferWillSubdivideAnInputFluxOverlapTime() - 类 中的方法reactor.core.publisher.FluxBufferWhenTest

bufferWillSubdivideAnInputFluxOverlapTime2() - 类 中的方法reactor.core.publisher.FluxBufferWhenTest

bufferWillSubdivideAnInputFluxSameTime() - 类 中的方法reactor.core.publisher.FluxBufferWhenTest

bufferWillSubdivideAnInputFluxTime() - 类 中的方法reactor.core.publisher.FluxBufferBoundaryTest

bufferWillSubdivideAnInputFluxTime2() - 类 中的方法reactor.core.publisher.FluxBufferBoundaryTest

bufferWithTimeoutAccumulateOnSize() - 类 中的方法reactor.core.publisher.FluxBufferTimeoutTest

bufferWithTimeoutAccumulateOnTime() - 类 中的方法reactor.core.publisher.FluxBufferTimeoutTest

bufferWithTimeoutThrowingExceptionOnTimeOrSizeIfDownstreamDemandIsLow() - 类 中的方法reactor.core.publisher.FluxBufferTimeoutTest

bufferWithTimeoutWhenDownstreamDemandIsLow() - 类 中的方法reactor.core.publisher.FluxWindowTimeoutTest

build() - 类 中的方法reactor.test.subscriber.TestSubscriberBuilder

Create a TestSubscriber according to this builder.

buildConditional(Predicate<? super T>) - 类 中的方法reactor.test.subscriber.TestSubscriberBuilder

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

builder() - 接口 中的静态方法reactor.test.subscriber.TestSubscriber

Create a TestSubscriber with tuning.

builderCanBeUsedAsTemplate() - 类 中的方法reactor.util.retry.RetryBackoffSpecTest

builderCanBeUsedAsTemplate() - 类 中的方法reactor.util.retry.RetrySpecTest

builderMethodsProduceNewInstances() - 类 中的方法reactor.util.retry.RetryBackoffSpecTest

builderMethodsProduceNewInstances() - 类 中的方法reactor.util.retry.RetrySpecTest

busyLooping(Duration) - 接口 中的静态方法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 Y Z