reactor.core.publisher

类 AbstractFluxConcatMapTest

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.AbstractFluxConcatMapTest

直接已知子类:

FluxConcatMapTest

@Timeout(value=5L)
public abstract class AbstractFluxConcatMapTest
extends FluxOperatorTest<java.lang.String,java.lang.String>

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
AbstractFluxConcatMapTest()

方法概要

限定符和类型	方法和说明
void	asyncFusionMapToNull()
void	asyncFusionMapToNullFilter()
void	boundaryFusion()
void	boundaryFusionDelayError()
void	concatDelayErrorWithFluxError()
void	concatDelayErrorWithMonoError()
void	concatMapDelayErrorWithFluxError()
void	concatMapDelayErrorWithMonoError()
void	discardDelayedInnerOnDrainMapperError()
void	discardDelayedOnDrainMapperError()
void	discardOnDrainMapperError()
void	errorModeContinueDelayErrors()
void	errorModeContinueDelayErrorsWithCallable()
void	errorModeContinueInternalError()
void	errorModeContinueInternalErrorHidden()
void	errorModeContinueInternalErrorMono()
void	errorModeContinueInternalErrorMonoAsync()
void	errorModeContinueInternalErrorStopStrategy()
void	errorModeContinueInternalErrorStopStrategyAsync()
void	errorModeContinueNullPublisher()
void	errorModeContinueWithCallable()
void	innerErrorsBoundary()
void	innerErrorsEnd()
void	innerErrorsImmediate()
void	mainErrorsBoundary()
void	mainErrorsImmediate()
void	normal()
void	normal2()
void	normalBoundary()
void	normalBoundary2()
void	normalLongRun()
void	normalLongRun2()
void	normalLongRunBoundary()
void	normalLongRunBoundary2()
void	normalLongRunJust()
void	normalLongRunJustBoundary()
void	publisherOfPublisher()
void	publisherOfPublisherDelay()
void	publisherOfPublisherDelayEnd()
void	publisherOfPublisherDelayEnd2()
void	publisherOfPublisherDelayEnd3()
void	publisherOfPublisherDelayEndError()
void	publisherOfPublisherDelayEndError2()
void	publisherOfPublisherDelayEndNot3()
void	publisherOfPublisherDelayError()
void	publisherOfPublisherDelayError2()
void	scalarAndRangeBackpressured()
void	singleSubscriberOnlyBoundary()
void	syncFusionMapToNull()
void	syncFusionMapToNullFilter()

从类继承的方法 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

构造器详细资料

AbstractFluxConcatMapTest

public AbstractFluxConcatMapTest()

方法详细资料

normal

@Test
public void normal()

normal2

@Test
public void normal2()

normalBoundary

@Test
public void normalBoundary()

normalBoundary2

@Test
public void normalBoundary2()

normalLongRun

@Test
public void normalLongRun()

normalLongRunJust

@Test
public void normalLongRunJust()

normalLongRun2

@Test
public void normalLongRun2()

normalLongRunBoundary

@Test
public void normalLongRunBoundary()

normalLongRunJustBoundary

@Test
public void normalLongRunJustBoundary()

normalLongRunBoundary2

@Test
public void normalLongRunBoundary2()

boundaryFusion

@Test
public void boundaryFusion()

boundaryFusionDelayError

@Test
public void boundaryFusionDelayError()

singleSubscriberOnlyBoundary

@Test
public void singleSubscriberOnlyBoundary()

mainErrorsImmediate

@Test
public void mainErrorsImmediate()

mainErrorsBoundary

@Test
public void mainErrorsBoundary()

innerErrorsImmediate

@Test
public void innerErrorsImmediate()

syncFusionMapToNull

@Test
public void syncFusionMapToNull()

syncFusionMapToNullFilter

@Test
public void syncFusionMapToNullFilter()

asyncFusionMapToNull

@Test
public void asyncFusionMapToNull()

asyncFusionMapToNullFilter

@Test
public void asyncFusionMapToNullFilter()

scalarAndRangeBackpressured

@Test
public void scalarAndRangeBackpressured()

publisherOfPublisherDelayError2

@Test
public void publisherOfPublisherDelayError2()

concatDelayErrorWithFluxError

@Test
public void concatDelayErrorWithFluxError()

concatDelayErrorWithMonoError

@Test
public void concatDelayErrorWithMonoError()

errorModeContinueNullPublisher

@Test
public void errorModeContinueNullPublisher()

errorModeContinueInternalError

@Test
public void errorModeContinueInternalError()

errorModeContinueInternalErrorHidden

@Test
public void errorModeContinueInternalErrorHidden()

errorModeContinueWithCallable

@Test
public void errorModeContinueWithCallable()

errorModeContinueDelayErrors

@Test
public void errorModeContinueDelayErrors()

errorModeContinueDelayErrorsWithCallable

@Test
public void errorModeContinueDelayErrorsWithCallable()

errorModeContinueInternalErrorStopStrategy

@Test
public void errorModeContinueInternalErrorStopStrategy()

errorModeContinueInternalErrorStopStrategyAsync

@Test
public void errorModeContinueInternalErrorStopStrategyAsync()

errorModeContinueInternalErrorMono

@Test
public void errorModeContinueInternalErrorMono()

errorModeContinueInternalErrorMonoAsync

@Test
public void errorModeContinueInternalErrorMonoAsync()

discardOnDrainMapperError

@Test
public void discardOnDrainMapperError()

discardDelayedOnDrainMapperError

@Test
public void discardDelayedOnDrainMapperError()

discardDelayedInnerOnDrainMapperError

@Test
public void discardDelayedInnerOnDrainMapperError()

publisherOfPublisherDelayEnd

@Test
public void publisherOfPublisherDelayEnd()

publisherOfPublisherDelayEnd2

@Test
public void publisherOfPublisherDelayEnd2()

publisherOfPublisherDelayEndNot3

@Test
public void publisherOfPublisherDelayEndNot3()

publisherOfPublisherDelayEndError

@Test
public void publisherOfPublisherDelayEndError()

publisherOfPublisherDelayEndError2

@Test
public void publisherOfPublisherDelayEndError2()

publisherOfPublisherDelayEnd3

@Test
public void publisherOfPublisherDelayEnd3()

innerErrorsBoundary

@Test
public void innerErrorsBoundary()

innerErrorsEnd

@Test
public void innerErrorsEnd()

publisherOfPublisherDelay

@Test
public void publisherOfPublisherDelay()

publisherOfPublisherDelayError

@Test
public void publisherOfPublisherDelayError()

concatMapDelayErrorWithFluxError

@Test
public void concatMapDelayErrorWithFluxError()

concatMapDelayErrorWithMonoError

@Test
public void concatMapDelayErrorWithMonoError()

publisherOfPublisher

@Test
public void publisherOfPublisher()