reactor.core.publisher

类 FluxConcatMapTest

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

reactor.core.publisher.FluxConcatMapTest

public class FluxConcatMapTest
extends AbstractFluxConcatMapTest

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxConcatMapTest()

方法概要

限定符和类型	方法和说明
void	allEmptyBackpressured()
void	discardDelayedOnCallableInnerErrorWithPrefetch()
void	discardDelayedOnDrainMapperError() TODO this test overrides the base one because FluxConcatMap only discards the first element and not all (bug?)
void	discardDelayedOnInnerErrorWithPrefetch()
void	discardDelayedOnNextQueueReject()
void	discardOnCancel()
void	discardOnError()
void	discardOnInnerErrorCallableWithPrefetch()
void	discardOnInnerErrorWithPrefetch()
void	discardOnNextQueueReject()
void	issue422()
void	prefetchMaxTranslatesToUnboundedRequest()
void	prefetchMaxTranslatesToUnboundedRequest2()
void	scanConcatMapDelayed()
void	scanConcatMapImmediate()
void	scanConcatMapImmediateError()
void	scanConcatMapInner()
void	scanOperator()
void	singleSubscriberOnly()
void	singleSubscriberOnlyBoundary()

从类继承的方法 reactor.core.publisher.AbstractFluxConcatMapTest

asyncFusionMapToNull, asyncFusionMapToNullFilter, boundaryFusion, boundaryFusionDelayError, concatDelayErrorWithFluxError, concatDelayErrorWithMonoError, concatMapDelayErrorWithFluxError, concatMapDelayErrorWithMonoError, discardDelayedInnerOnDrainMapperError, discardOnDrainMapperError, errorModeContinueDelayErrors, errorModeContinueDelayErrorsWithCallable, errorModeContinueInternalError, errorModeContinueInternalErrorHidden, errorModeContinueInternalErrorMono, errorModeContinueInternalErrorMonoAsync, errorModeContinueInternalErrorStopStrategy, errorModeContinueInternalErrorStopStrategyAsync, errorModeContinueNullPublisher, errorModeContinueWithCallable, innerErrorsBoundary, innerErrorsEnd, innerErrorsImmediate, mainErrorsBoundary, mainErrorsImmediate, normal, normal2, normalBoundary, normalBoundary2, normalLongRun, normalLongRun2, normalLongRunBoundary, normalLongRunBoundary2, normalLongRunJust, normalLongRunJustBoundary, publisherOfPublisher, publisherOfPublisherDelay, publisherOfPublisherDelayEnd, publisherOfPublisherDelayEnd2, publisherOfPublisherDelayEnd3, publisherOfPublisherDelayEndError, publisherOfPublisherDelayEndError2, publisherOfPublisherDelayEndNot3, publisherOfPublisherDelayError, publisherOfPublisherDelayError2, scalarAndRangeBackpressured, syncFusionMapToNull, 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

构造器详细资料

FluxConcatMapTest

public FluxConcatMapTest()

方法详细资料

singleSubscriberOnly

@Test
public void singleSubscriberOnly()

singleSubscriberOnlyBoundary

@Test
public void singleSubscriberOnlyBoundary()

覆盖:

singleSubscriberOnlyBoundary 在类中 AbstractFluxConcatMapTest

allEmptyBackpressured

@Test
public void allEmptyBackpressured()

issue422

@Test
public void issue422()

prefetchMaxTranslatesToUnboundedRequest

@Test
public void prefetchMaxTranslatesToUnboundedRequest()

prefetchMaxTranslatesToUnboundedRequest2

@Test
public void prefetchMaxTranslatesToUnboundedRequest2()

scanOperator

@Test
public void scanOperator()

scanConcatMapDelayed

@Test
public void scanConcatMapDelayed()

scanConcatMapImmediate

@Test
public void scanConcatMapImmediate()

scanConcatMapImmediateError

@Test
public void scanConcatMapImmediateError()

scanConcatMapInner

@Test
public void scanConcatMapInner()

discardOnNextQueueReject

@Test
public void discardOnNextQueueReject()

discardOnError

@Test
public void discardOnError()

discardOnInnerErrorWithPrefetch

@Test
public void discardOnInnerErrorWithPrefetch()

discardOnInnerErrorCallableWithPrefetch

@Test
public void discardOnInnerErrorCallableWithPrefetch()

discardDelayedOnInnerErrorWithPrefetch

@Test
public void discardDelayedOnInnerErrorWithPrefetch()

discardDelayedOnCallableInnerErrorWithPrefetch

@Test
public void discardDelayedOnCallableInnerErrorWithPrefetch()

discardOnCancel

@Test
public void discardOnCancel()

discardDelayedOnNextQueueReject

@Test
public void discardDelayedOnNextQueueReject()

discardDelayedOnDrainMapperError

@Test
public void discardDelayedOnDrainMapperError()

TODO this test overrides the base one because FluxConcatMap only discards the first element and not all (bug?)

覆盖:

discardDelayedOnDrainMapperError 在类中 AbstractFluxConcatMapTest