reactor.core.publisher

类 FluxHandleTest

java.lang.Object

reactor.test.publisher.BaseOperatorTest<I,Flux<I>,O,Flux<O>>

reactor.test.publisher.FluxOperatorTest<java.lang.String,java.lang.String>

reactor.core.publisher.FluxHandleTest

public class FluxHandleTest
extends FluxOperatorTest<java.lang.String,java.lang.String>

嵌套类概要

从类继承的嵌套类/接口 reactor.test.publisher.FluxOperatorTest

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxHandleTest()

方法概要

限定符和类型	方法和说明
void	completeAfterErrorFused()
void	completeAfterErrorFusedConditional()
void	completeAfterErrorNormal()
void	completeAfterErrorNormalConditional()
void	dropHandleFusedSync()
void	errorAfterCompleteFused()
void	errorAfterCompleteFusedConditional()
void	errorAfterCompleteNormal()
void	errorAfterCompleteNormalConditional()
void	errorPropagated()
void	errorSignal()
void	failureStrategyResumeConditionalExceptionSignalled()
void	failureStrategyResumeConditionalExceptionSignalledFuseable()
void	failureStrategyResumeConditionalExceptionThrown()
void	failureStrategyResumeConditionalExceptionThrownFuseable()
void	failureStrategyResumeConditionalTryOnNextExceptionSignalled()
void	failureStrategyResumeConditionalTryOnNextExceptionThrown()
void	failureStrategyResumeExceptionSignalled()
void	failureStrategyResumeExceptionSignalledFuesable()
void	failureStrategyResumeExceptionThrown()
void	failureStrategyResumeExceptionThrownFuseable()
void	failureStrategyResumeTryOnNextExceptionSignalled()
void	failureStrategyResumeTryOnNextExceptionThrown()
void	filterNullMapResult()
void	filterNullMapResultAsyncFusion()
void	filterNullMapResultSyncFusion()
void	handleBackpressuredBothConditional()
void	handleBackpressuredSourceConditional()
void	handleBackpressuredTargetConditional()
void	nextAfterCompleteFused()
void	nextAfterCompleteFusedConditional()
void	nextAfterCompleteNormal()
void	nextAfterCompleteNormalConditional()
void	nextAfterErrorFused()
void	nextAfterErrorFusedConditional()
void	nextAfterErrorNormal()
void	nextAfterErrorNormalConditional()
void	nextAfterNextFused()
void	nextAfterNextFusedConditional()
void	nextAfterNextNormal()
void	nextAfterNextNormalConditional()
void	normal()
void	normalAsyncFusion()
void	normalHide()
void	normalSyncFusion()
void	prematureCompleteFusedSync()
void	runtimeExceptionFused()
void	scanConditionalSubscriber()
void	scanFuseableConditionalSubscriber()
void	scanFuseableOperator()
void	scanFuseableSubscriber()
void	scanOperator()
void	scanSubscriber()

从类继承的方法 reactor.test.publisher.FluxOperatorTest

scenario

从类继承的方法 reactor.test.publisher.BaseOperatorTest

assertPrePostState, cancelOnSubscribe, errorOnSubscribe, initDefaultScenario, sequenceOfNextAndCancel, sequenceOfNextAndComplete, sequenceOfNextAndError, sequenceOfNextWithCallbackError

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FluxHandleTest

public FluxHandleTest()

方法详细资料

normal

@Test
public void normal()

normalHide

@Test
public void normalHide()

filterNullMapResult

@Test
public void filterNullMapResult()

normalSyncFusion

@Test
public void normalSyncFusion()

normalAsyncFusion

@Test
public void normalAsyncFusion()

filterNullMapResultSyncFusion

@Test
public void filterNullMapResultSyncFusion()

filterNullMapResultAsyncFusion

@Test
public void filterNullMapResultAsyncFusion()

errorSignal

@Test
public void errorSignal()

errorPropagated

@Test
public void errorPropagated()

handleBackpressuredBothConditional

@Test
public void handleBackpressuredBothConditional()

handleBackpressuredSourceConditional

@Test
public void handleBackpressuredSourceConditional()

handleBackpressuredTargetConditional

@Test
public void handleBackpressuredTargetConditional()

prematureCompleteFusedSync

@Test
public void prematureCompleteFusedSync()

dropHandleFusedSync

@Test
public void dropHandleFusedSync()

scanOperator

@Test
public void scanOperator()

scanFuseableOperator

@Test
public void scanFuseableOperator()

scanSubscriber

@Test
public void scanSubscriber()

scanConditionalSubscriber

@Test
public void scanConditionalSubscriber()

scanFuseableSubscriber

@Test
public void scanFuseableSubscriber()

scanFuseableConditionalSubscriber

@Test
public void scanFuseableConditionalSubscriber()

nextAfterCompleteNormal

@Test
public void nextAfterCompleteNormal()

nextAfterErrorNormal

@Test
public void nextAfterErrorNormal()

errorAfterCompleteNormal

@Test
public void errorAfterCompleteNormal()

completeAfterErrorNormal

@Test
public void completeAfterErrorNormal()

nextAfterNextNormal

@Test
public void nextAfterNextNormal()

nextAfterCompleteNormalConditional

@Test
public void nextAfterCompleteNormalConditional()

nextAfterErrorNormalConditional

@Test
public void nextAfterErrorNormalConditional()

errorAfterCompleteNormalConditional

@Test
public void errorAfterCompleteNormalConditional()

completeAfterErrorNormalConditional

@Test
public void completeAfterErrorNormalConditional()

nextAfterNextNormalConditional

@Test
public void nextAfterNextNormalConditional()

nextAfterCompleteFused

@Test
public void nextAfterCompleteFused()

nextAfterErrorFused

@Test
public void nextAfterErrorFused()

runtimeExceptionFused

@Test
public void runtimeExceptionFused()

errorAfterCompleteFused

@Test
public void errorAfterCompleteFused()

completeAfterErrorFused

@Test
public void completeAfterErrorFused()

nextAfterNextFused

@Test
public void nextAfterNextFused()

nextAfterCompleteFusedConditional

@Test
public void nextAfterCompleteFusedConditional()

nextAfterErrorFusedConditional

@Test
public void nextAfterErrorFusedConditional()

errorAfterCompleteFusedConditional

@Test
public void errorAfterCompleteFusedConditional()

completeAfterErrorFusedConditional

@Test
public void completeAfterErrorFusedConditional()

nextAfterNextFusedConditional

@Test
public void nextAfterNextFusedConditional()

failureStrategyResumeExceptionThrown

@Test
public void failureStrategyResumeExceptionThrown()

failureStrategyResumeExceptionSignalled

@Test
public void failureStrategyResumeExceptionSignalled()

failureStrategyResumeTryOnNextExceptionThrown

@Test
public void failureStrategyResumeTryOnNextExceptionThrown()

failureStrategyResumeTryOnNextExceptionSignalled

@Test
public void failureStrategyResumeTryOnNextExceptionSignalled()

failureStrategyResumeConditionalExceptionThrown

@Test
public void failureStrategyResumeConditionalExceptionThrown()

failureStrategyResumeConditionalExceptionSignalled

@Test
public void failureStrategyResumeConditionalExceptionSignalled()

failureStrategyResumeConditionalTryOnNextExceptionThrown

@Test
public void failureStrategyResumeConditionalTryOnNextExceptionThrown()

failureStrategyResumeConditionalTryOnNextExceptionSignalled

@Test
public void failureStrategyResumeConditionalTryOnNextExceptionSignalled()

failureStrategyResumeExceptionThrownFuseable

@Test
public void failureStrategyResumeExceptionThrownFuseable()

failureStrategyResumeExceptionSignalledFuesable

@Test
public void failureStrategyResumeExceptionSignalledFuesable()

failureStrategyResumeConditionalExceptionThrownFuseable

@Test
public void failureStrategyResumeConditionalExceptionThrownFuseable()

failureStrategyResumeConditionalExceptionSignalledFuseable

@Test
public void failureStrategyResumeConditionalExceptionSignalledFuseable()