reactor.core.publisher

类 FluxFlatMapTest

java.lang.Object

reactor.core.publisher.FluxFlatMapTest

public class FluxFlatMapTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxFlatMapTest()

方法概要

限定符和类型	方法和说明
void	assertOnSubscribeStateMainAndInner()
void	assertOnSubscribeStateMainAndInner2()
void	assertOnSubscribeStateMainAndInner3()
void	assertOnSubscribeStateMainScalar()
void	asyncInnerFusion()
void	backpressuredScalarThenCancel()
void	backpressuredThenCancel()
void	completePublisherDelay()
void	completePublisherDelayCancel()
void	defaultPrefetch()
void	delayedBackpressuredScalar()
void	delayedUnboundedScalarThenCancel()
void	delayErrorWithFluxError()
void	delayErrorWithMonoError()
void	errorModeContinueDelayErrors()
void	errorModeContinueDelayErrorsWithCallable()
void	errorModeContinueInternalError()
void	errorModeContinueInternalErrorHidden()
void	errorModeContinueInternalErrorMono()
void	errorModeContinueInternalErrorMonoAsync()
void	errorModeContinueInternalErrorStopStrategy()
void	errorModeContinueInternalErrorStopStrategyAsync()
void	errorModeContinueLargerThanConcurrencySourceMappedCallableFails()
void	errorModeContinueNullPublisher()
void	errorModeContinueScalarSourceFails()
void	errorModeContinueScalarSourceMappedCallableFails()
void	errorModeContinueScalarSourceMapperFails()
void	errorModeContinueWithCallable()
void	failAsyncInnerFusion()
void	failCallable()
void	failDoubleErrorSilent()
void	failMap()
void	failMaxConcurrency()
void	failNextOnTerminated()
void	failNull()
void	failOverflow()
void	failOverflowCancelledWhileActive()
void	failOverflowScalar()
void	failOverflowScalarThenError()
void	failOverflowWhileActiveScalar()
void	failOverflowWhileActiveScalarThenError()
void	failPrefetch()
void	failPublisher()
void	failPublisherDelay()
void	failScalarCallable()
void	failScalarMap()
void	failScalarMapCallableError()
void	failScalarMapNull()
void	failsyncInnerFusion()
void	flatMapDelayErrors()
void	flatmapInnerShouldntRequestInFusionModeSync()
void	flatMapOfJust()
void	flatMapOfJustBackpressured()
void	flatMapOfJustBackpressured1()
void	flatMapOfMixed()
void	flatMapOfMixedBackpressured()
void	flatMapOfMixedBackpressured1()
void	flatMapUnbounded()
void	ignoreConcurrentHiddenComplete()
void	ignoreDoubleComplete()
void	ignoreDoubleOnSubscribe()
void	ignoreDoubleOnSubscribeInner()
void	ignoreRequestZeroThenRequestOneByOne()
void	ignoreSyncFusedRequest()
void	innerEmpty()
void	innerError()
void	innerMapSyncFusion()
void	mainEmpty()
void	mainError()
void	noInnerReordering()
void	noOuterScalarReordering()
void	normal()
void	normalBackpressured()
void	normalInnerArrayMoreThanDefaultArraySize4()
void	normalQueueOpt()
void	normalQueueOptBackpressured()
void	noWrappingOfCheckedExceptions_hide()
void	noWrappingOfCheckedExceptions()
void	nullValue()
void	onOperatorError()
void	prematureCancel()
void	prematureCancel2()
void	prematureCancelInnerArrayMoreThanDefaultArraySize4()
void	prematureCompleteMaxPrefetch()
void	prematureInnerCancel()
void	prematureScalarMapCallableEmptyComplete()
void	prematureScalarMapCallableJust()
void	prematureScalarMapCallableNullComplete()
void	progressiveRequest()
void	scanInner()
void	scanMain()
void	scanMainLargeBuffered()
void	scanOperator()
void	singleSubscriberOnly()
void	suppressFusionIfExpected()
void	suppressFusionIfExpectedError()
void	syncFusionArray()
void	syncFusionIterable()
void	syncFusionRange()
void	testFairness()
void	testMaxConcurrency1()
void	testMaxConcurrency2()

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

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

构造器详细资料

FluxFlatMapTest

public FluxFlatMapTest()

方法详细资料

flatmapInnerShouldntRequestInFusionModeSync

@Test
public void flatmapInnerShouldntRequestInFusionModeSync()

normal

@Test
public void normal()

normalBackpressured

@Test
public void normalBackpressured()

mainError

@Test
public void mainError()

innerError

@Test
public void innerError()

normalQueueOpt

@Test
public void normalQueueOpt()

normalQueueOptBackpressured

@Test
public void normalQueueOptBackpressured()

nullValue

@Test
public void nullValue()

mainEmpty

@Test
public void mainEmpty()

innerEmpty

@Test
public void innerEmpty()

flatMapOfJust

@Test
public void flatMapOfJust()

flatMapOfMixed

@Test
public void flatMapOfMixed()

flatMapOfMixedBackpressured

@Test
public void flatMapOfMixedBackpressured()

flatMapOfMixedBackpressured1

@Test
public void flatMapOfMixedBackpressured1()

flatMapOfJustBackpressured

@Test
public void flatMapOfJustBackpressured()

flatMapOfJustBackpressured1

@Test
public void flatMapOfJustBackpressured1()

testMaxConcurrency1

@Test
public void testMaxConcurrency1()

testMaxConcurrency2

@Test
public void testMaxConcurrency2()

singleSubscriberOnly

@Test
public void singleSubscriberOnly()

flatMapUnbounded

@Test
public void flatMapUnbounded()

syncFusionIterable

@Test
public void syncFusionIterable()

syncFusionRange

@Test
public void syncFusionRange()

syncFusionArray

@Test
public void syncFusionArray()

innerMapSyncFusion

@Test
public void innerMapSyncFusion()

defaultPrefetch

@Test
public void defaultPrefetch()

failMaxConcurrency

@Test
public void failMaxConcurrency()

failPrefetch

@Test
public void failPrefetch()

failCallable

@Test
public void failCallable()

failMap

@Test
public void failMap()

failPublisher

@Test
public void failPublisher()

failPublisherDelay

@Test
public void failPublisherDelay()

completePublisherDelayCancel

@Test
public void completePublisherDelayCancel()

completePublisherDelay

@Test
public void completePublisherDelay()

failNull

@Test
public void failNull()

failScalarCallable

@Test
public void failScalarCallable()

failScalarMap

@Test
public void failScalarMap()

failScalarMapNull

@Test
public void failScalarMapNull()

failScalarMapCallableError

@Test
public void failScalarMapCallableError()

prematureScalarMapCallableNullComplete

@Test
public void prematureScalarMapCallableNullComplete()

prematureScalarMapCallableEmptyComplete

@Test
public void prematureScalarMapCallableEmptyComplete()

prematureScalarMapCallableJust

@Test
public void prematureScalarMapCallableJust()

prematureCompleteMaxPrefetch

@Test
public void prematureCompleteMaxPrefetch()

prematureCancel

@Test
public void prematureCancel()

prematureCancel2

@Test
public void prematureCancel2()

failNextOnTerminated

@Test
public void failNextOnTerminated()

ignoreDoubleComplete

@Test
public void ignoreDoubleComplete()

ignoreConcurrentHiddenComplete

@Test
public void ignoreConcurrentHiddenComplete()

ignoreDoubleOnSubscribe

@Test
public void ignoreDoubleOnSubscribe()

ignoreDoubleOnSubscribeInner

@Test
public void ignoreDoubleOnSubscribeInner()

failOverflowScalar

@Test
public void failOverflowScalar()

failOverflow

@Test
public void failOverflow()

failOverflowCancelledWhileActive

@Test
public void failOverflowCancelledWhileActive()

failOverflowScalarThenError

@Test
public void failOverflowScalarThenError()

failOverflowWhileActiveScalar

@Test
public void failOverflowWhileActiveScalar()

failOverflowWhileActiveScalarThenError

@Test
public void failOverflowWhileActiveScalarThenError()

failDoubleErrorSilent

@Test
public void failDoubleErrorSilent()

suppressFusionIfExpected

@Test
public void suppressFusionIfExpected()

ignoreRequestZeroThenRequestOneByOne

@Test
public void ignoreRequestZeroThenRequestOneByOne()

suppressFusionIfExpectedError

@Test
public void suppressFusionIfExpectedError()

backpressuredScalarThenCancel

@Test
public void backpressuredScalarThenCancel()

delayedUnboundedScalarThenCancel

@Test
public void delayedUnboundedScalarThenCancel()

delayedBackpressuredScalar

@Test
public void delayedBackpressuredScalar()

backpressuredThenCancel

@Test
public void backpressuredThenCancel()

assertOnSubscribeStateMainAndInner

@Test
public void assertOnSubscribeStateMainAndInner()

testFairness

@Test
public void testFairness()

noInnerReordering

@Test
public void noInnerReordering()

noOuterScalarReordering

@Test
public void noOuterScalarReordering()

assertOnSubscribeStateMainAndInner2

@Test
public void assertOnSubscribeStateMainAndInner2()

assertOnSubscribeStateMainAndInner3

@Test
public void assertOnSubscribeStateMainAndInner3()

assertOnSubscribeStateMainScalar

@Test
public void assertOnSubscribeStateMainScalar()

ignoreSyncFusedRequest

@Test
public void ignoreSyncFusedRequest()

asyncInnerFusion

@Test
public void asyncInnerFusion()

failAsyncInnerFusion

@Test
public void failAsyncInnerFusion()

failsyncInnerFusion

@Test
public void failsyncInnerFusion()

onOperatorError

@Test
public void onOperatorError()

prematureInnerCancel

@Test
public void prematureInnerCancel()

normalInnerArrayMoreThanDefaultArraySize4

@Test
public void normalInnerArrayMoreThanDefaultArraySize4()

prematureCancelInnerArrayMoreThanDefaultArraySize4

@Test
public void prematureCancelInnerArrayMoreThanDefaultArraySize4()

flatMapDelayErrors

@Test
public void flatMapDelayErrors()
                               throws java.lang.Exception

抛出:

java.lang.Exception

delayErrorWithFluxError

@Test
public void delayErrorWithFluxError()

delayErrorWithMonoError

@Test
public void delayErrorWithMonoError()

scanOperator

@Test
public void scanOperator()

scanMain

@Test
public void scanMain()

scanMainLargeBuffered

@Test
public void scanMainLargeBuffered()

scanInner

@Test
public void scanInner()

progressiveRequest

@Test
 @Disabled
public void progressiveRequest()

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()

errorModeContinueScalarSourceFails

@Test
public void errorModeContinueScalarSourceFails()

errorModeContinueScalarSourceMapperFails

@Test
public void errorModeContinueScalarSourceMapperFails()

errorModeContinueScalarSourceMappedCallableFails

@Test
public void errorModeContinueScalarSourceMappedCallableFails()

errorModeContinueLargerThanConcurrencySourceMappedCallableFails

@Test
public void errorModeContinueLargerThanConcurrencySourceMappedCallableFails()

noWrappingOfCheckedExceptions

@Test
public void noWrappingOfCheckedExceptions()

noWrappingOfCheckedExceptions_hide

@Test
public void noWrappingOfCheckedExceptions_hide()