void |
FluxUsingWhenTest.apiCancel(Flux<java.lang.String> transactionToCancel) |
void |
FluxUsingWhenTest.apiCommit(Flux<java.lang.String> fullTransaction) |
void |
FluxUsingWhenTest.apiCommitFailure(Flux<java.lang.String> fullTransaction) |
void |
FluxUsingWhenTest.apiRollback(Flux<java.lang.String> transactionWithError) |
void |
FluxUsingWhenTest.apiRollbackFailure(Flux<java.lang.String> transactionWithError) |
void |
FluxUsingWhenTest.apiRollbackGeneratingNull(Flux<java.lang.String> transactionWithError) |
void |
FluxUsingWhenTest.cancelWithHandler(Flux<java.lang.String> source) |
void |
FluxUsingWhenTest.cancelWithoutHandlerAppliesCommit(Flux<java.lang.String> source)
已过时。
|
void |
FluxUsingWhenTest.commitGeneratingNull(Flux<java.lang.String> fullTransaction) |
void |
FluxUsingWhenTest.contextPropagationOnCancel(Flux<java.lang.String> source) |
void |
FluxUsingWhenTest.contextPropagationOnCancelWithNoHandler(Flux<java.lang.String> source) |
void |
FluxUsingWhenTest.contextPropagationOnCommit(Mono<java.lang.String> source) |
void |
FluxUsingWhenTest.contextPropagationOnRollback(Mono<java.lang.String> source) |
void |
FluxPublishTest.dataDroppedIfAutoconnectZero(boolean replayTerminalSignal) |
void |
FluxPublishTest.dataDroppedIfConnectImmediately(boolean replayTerminalSignal) |
void |
FluxPublishTest.disconnect(boolean replayTerminalSignal) |
void |
FluxPublishTest.disconnectBackpressured(boolean replayTerminalSignal) |
void |
FluxSwitchMapTest.doswitch(int prefetch) |
void |
FluxPublishTest.error(boolean replayTerminalSignal) |
void |
FluxPublishTest.fusedMapInvalid(boolean replayTerminalSignal) |
void |
FluxSwitchMapTest.innerError(int prefetch) |
void |
FluxSwitchMapTest.mainCompletesBefore(int prefetch) |
void |
FluxSwitchMapTest.mainError(int prefetch) |
void |
FluxSwitchMapTest.mapperReturnsNull(int prefetch) |
void |
FluxSwitchMapTest.mapperThrows(int prefetch) |
void |
FluxPublishTest.normalAsyncFused(boolean replayTerminalSignal) |
void |
FluxPublishTest.normalBackpressuredAsyncFused(boolean replayTerminalSignal) |
void |
FluxPublishTest.normalBackpressuredSyncFused(boolean replayTerminalSignal) |
void |
FluxPublishTest.normalSyncFused(boolean replayTerminalSignal) |
void |
FluxSwitchMapTest.noswitch(int prefetch) |
void |
FluxPublishTest.retry(boolean replayTerminalSignal) |
void |
FluxPublishTest.retryWithPublishOn(boolean replayTerminalSignal) |
void |
FluxPublishTest.subscriberContextPropagation(boolean replayTerminalSignal) |
void |
FluxSwitchMapTest.switchOnNextDynamically(int prefetch) |
void |
FluxSwitchMapTest.switchOnNextDynamicallyOnNext(int prefetch) |
void |
FluxPublishTest.syncFusionFromInfiniteStream(boolean replayTerminalSignal) |
void |
FluxPublishTest.syncFusionFromInfiniteStreamAndTake(boolean replayTerminalSignal) |
void |
FluxPublishTest.syncFusionMultiple(boolean replayTerminalSignal) |
void |
FluxPublishTest.syncFusionSingle(boolean replayTerminalSignal) |
void |
FluxZipTest.testTwoErrors(boolean firstIsScalar,
boolean secondIsScalar,
java.lang.String expectedMessage) |
void |
FluxZipTest.testTwoErrorsFusion(boolean firstIsFuseable,
boolean secondIsFuseable,
java.lang.String expectedMessage) |
void |
ContextLossDetectionTest.transformDeferredDetectsContextLoss(reactor.core.publisher.ContextLossDetectionTest.ContextTestCase fn) |
void |
ContextLossDetectionTest.transformDeferredDetectsContextLossWithDefaultContext(reactor.core.publisher.ContextLossDetectionTest.ContextTestCase fn) |
void |
ContextLossDetectionTest.transformDeferredDetectsContextLossWithEmptyContext(reactor.core.publisher.ContextLossDetectionTest.ContextTestCase fn) |
void |
ContextLossDetectionTest.transformDeferredDetectsContextLossWithRSSubscriber(reactor.core.publisher.ContextLossDetectionTest.ContextTestCase fn) |