reactor.core.publisher

类 FluxPublishOnTest

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

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

字段概要

字段

限定符和类型	字段和说明
static java.util.concurrent.ExecutorService	exec

构造器概要

构造器

构造器和说明
FluxPublishOnTest()

方法概要

限定符和类型	方法和说明
static void	after()
static void	before()
void	boundedQueue()
void	boundedQueueFilter()
void	callableEvaluatedTheRightTime()
void	callablePath()
void	classicJust()
void	classicJustBackpressured()
void	crossRange()
void	crossRangeHidden()
void	crossRangeMax()
void	crossRangeMaxHidden()
void	crossRangeMaxUnbounded()
void	crossRangePerfDefault()
void	diamond()
void	empty()
void	error()
void	errorDelayed()
void	errorHide()
void	failPrefetch()
void	filtered()
void	filtered1()
void	limitRate()
void	limitRateDisabledLowTide()
void	limitRateWithCloseLowTide()
void	limitRateWithVeryLowTide()
void	mapManyFlushesAllValuesThoroughly()
void	mapNotifiesOnce() See #294 the consumer received more or less calls than expected Better reproducible with big thread pools, e.g. 128 threads
void	mappedAsyncSourceWithNull()
void	mappedAsyncSourceWithNullPostFilter()
void	mappedFilteredSyncSourceWithNull()
void	mappedFilteredSyncSourceWithNull2()
void	mappedsyncSourceWithNull()
void	mappedsyncSourceWithNull2()
void	mappedsyncSourceWithNull2Hidden()
void	mappedsyncSourceWithNullHidden()
void	mappedsyncSourceWithNullPostFilterHidden()
void	normal()
void	normalAsyncFused()
void	normalAsyncFusedBackpressured()
void	normalBackpressured()
void	normalBackpressured1()
void	normalFilteredBackpressured()
void	normalFilteredBackpressured1()
void	normalSyncFused()
void	normalSyncFusedBackpressured()
void	prefetchAmountOnly()
void	publishOnAsyncDetection()
void	publishOnAsyncDetectionConditional()
void	rejectedExecutionExceptionOnDataSignalExecutor()
void	rejectedExecutionExceptionOnDataSignalExecutorService()
void	rejectedExecutionExceptionOnErrorSignalExecutor()
void	rejectedExecutionExceptionOnErrorSignalExecutorService()
void	scanConditionalSubscriber()
void	scanOperator()
void	scanRunOn()
void	scanSubscriber()
void	syncSourceWithNull()
void	syncSourceWithNull2()
void	threadBoundaryPreventsInvalidFusionFilter()
void	threadBoundaryPreventsInvalidFusionMap()
void	withFlatMap()

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

字段详细资料

exec

public static java.util.concurrent.ExecutorService exec

构造器详细资料

FluxPublishOnTest

public FluxPublishOnTest()

方法详细资料

before

@BeforeAll
public static void before()

after

@AfterAll
public static void after()

failPrefetch

@Test
public void failPrefetch()

normal

@Test
public void normal()

normalBackpressured1

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

抛出:

java.lang.Exception

normalBackpressured

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

抛出:

java.lang.Exception

normalSyncFused

@Test
public void normalSyncFused()

normalSyncFusedBackpressured

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

抛出:

java.lang.Exception

normalAsyncFused

@Test
public void normalAsyncFused()

normalAsyncFusedBackpressured

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

抛出:

java.lang.Exception

error

@Test
public void error()

errorHide

@Test
public void errorHide()

empty

@Test
public void empty()

errorDelayed

@Test
public void errorDelayed()

classicJust

@Test
public void classicJust()

classicJustBackpressured

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

抛出:

java.lang.Exception

filtered

@Test
public void filtered()

filtered1

@Test
public void filtered1()

normalFilteredBackpressured

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

抛出:

java.lang.Exception

normalFilteredBackpressured1

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

抛出:

java.lang.Exception

callableEvaluatedTheRightTime

@Test
public void callableEvaluatedTheRightTime()

diamond

@Test
public void diamond()

prefetchAmountOnly

@Test
public void prefetchAmountOnly()

boundedQueue

@Test
public void boundedQueue()

boundedQueueFilter

@Test
public void boundedQueueFilter()

withFlatMap

@Test
public void withFlatMap()

syncSourceWithNull

@Test
public void syncSourceWithNull()

syncSourceWithNull2

@Test
public void syncSourceWithNull2()

mappedsyncSourceWithNull

@Test
public void mappedsyncSourceWithNull()

mappedsyncSourceWithNullHidden

@Test
public void mappedsyncSourceWithNullHidden()

mappedsyncSourceWithNullPostFilterHidden

@Test
public void mappedsyncSourceWithNullPostFilterHidden()

mappedsyncSourceWithNull2

@Test
public void mappedsyncSourceWithNull2()

mappedsyncSourceWithNull2Hidden

@Test
public void mappedsyncSourceWithNull2Hidden()

mappedFilteredSyncSourceWithNull

@Test
public void mappedFilteredSyncSourceWithNull()

mappedFilteredSyncSourceWithNull2

@Test
public void mappedFilteredSyncSourceWithNull2()

mappedAsyncSourceWithNull

@Test
public void mappedAsyncSourceWithNull()

mappedAsyncSourceWithNullPostFilter

@Test
public void mappedAsyncSourceWithNullPostFilter()

crossRangeHidden

@Test
public void crossRangeHidden()

crossRange

@Test
public void crossRange()

crossRangeMaxHidden

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

抛出:

java.lang.Exception

crossRangeMax

@Test
public void crossRangeMax()

crossRangeMaxUnbounded

@Test
public void crossRangeMaxUnbounded()

threadBoundaryPreventsInvalidFusionMap

@Test
public void threadBoundaryPreventsInvalidFusionMap()

threadBoundaryPreventsInvalidFusionFilter

@Test
public void threadBoundaryPreventsInvalidFusionFilter()

crossRangePerfDefault

@Test
public void crossRangePerfDefault()

limitRate

@Test
public void limitRate()

limitRateWithCloseLowTide

@Test
public void limitRateWithCloseLowTide()

limitRateWithVeryLowTide

@Test
public void limitRateWithVeryLowTide()

rejectedExecutionExceptionOnDataSignalExecutor

@Test
 @Timeout(value=5L)
public void rejectedExecutionExceptionOnDataSignalExecutor()
                                                                                throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

rejectedExecutionExceptionOnErrorSignalExecutor

@Test
 @Disabled
public void rejectedExecutionExceptionOnErrorSignalExecutor()
                                                                        throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

rejectedExecutionExceptionOnDataSignalExecutorService

@Test
 @Timeout(value=5L)
 @Disabled
public void rejectedExecutionExceptionOnDataSignalExecutorService()
                                                                                                   throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

rejectedExecutionExceptionOnErrorSignalExecutorService

@Test
public void rejectedExecutionExceptionOnErrorSignalExecutorService()

mapNotifiesOnce

@Test
public void mapNotifiesOnce()
                            throws java.lang.InterruptedException

See #294 the consumer received more or less calls than expected Better reproducible with big thread pools, e.g. 128 threads

抛出:

java.lang.InterruptedException - on interrupt

mapManyFlushesAllValuesThoroughly

@Test
public void mapManyFlushesAllValuesThoroughly()
                                              throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

callablePath

@Test
public void callablePath()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()
                           throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

scanConditionalSubscriber

@Test
public void scanConditionalSubscriber()

publishOnAsyncDetection

@Test
public void publishOnAsyncDetection()

publishOnAsyncDetectionConditional

@Test
public void publishOnAsyncDetectionConditional()

limitRateDisabledLowTide

@Test
public void limitRateDisabledLowTide()
                                     throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

scanRunOn

@Test
public void scanRunOn()