reactor.core.publisher.scenarios

类 FluxTests

java.lang.Object

reactor.core.publisher.scenarios.AbstractReactorTest

reactor.core.publisher.scenarios.FluxTests

public class FluxTests
extends AbstractReactorTest

构造器概要

构造器

构造器和说明
FluxTests()

方法概要

限定符和类型	方法和说明
void	analyticsTest()
void	cancelOn()
void	combineWithOneElement()
void	consistentMultithreadingWithPartition()
void	delayEach()
void	delayErrorConcatMapVsFlatMap()
void	delayErrorConcatMapVsFlatMapTwoErrors()
void	discardLocalMultipleFilters()
void	discardLocalOrder()
void	endLessTimer() This test case demonstrates a silent failure of Flux.interval(Duration) when a resolution is specified that is less than the backing Timer class.
void	fluxCreateDemoElasticScheduler()
void	fluxFromFluxSourceDoesntCallAssemblyHook()
void	fluxFromMonoFuseableCallsAssemblyHook()
void	fluxFromMonoNormalCallsAssemblyHook()
void	fluxFromPublisherCallsAssemblyHook()
void	fluxFromScalarEmptyCallsAssemblyHook()
void	fluxFromScalarErrorCallsAssemblyHook()
void	fluxFromScalarJustCallsAssemblyHook()
void	fluxNextCallableCallsAssemblyHook()
void	fluxNextNormalCallsAssemblyHook()
void	fluxNextScalarEmptyCallsAssemblyHook()
void	fluxNextScalarErrorCallsAssemblyHook()
void	fluxNextScalarValuedCallsAssemblyHook()
void	mapLotsOfSubAndCancel()
void	mapPassThru()
void	multiplexUsingDispatchersAndSplit() forkStream / \ < - - - int v v persistenceStream computationStream \ / < - - - List< String > v v joinStream < - - - String splitStream observedSplitStream
void	parallelTests()
void	partitionByHashCodeShouldNeverCreateMoreStreamsThanSpecified() See https://github.com/reactor/reactor/issues/451
void	prematureFlatMapCompletion()
void	promiseAcceptCountAndErrorCountCannotExceedOneInTotal()
void	promiseAcceptCountCannotExceedOne()
void	promiseErrorCountCannotExceedOne()
void	sequenceEqual()
void	shouldCorrectlyDispatchBatchedTimeout()
void	shouldCorrectlyDispatchComplexFlow()
void	shouldNotFlushStreamOnTimeoutPrematurely() original from @oiavorskyl https://github.com/eventBus/eventBus/issues/358
void	shouldNotFlushStreamOnTimeoutPrematurelyAndShouldDoItConsistently() original from @oiavorskyl https://github.com/eventBus/eventBus/issues/358
void	shouldWindowCorrectly()
void	splitBugEventuallyHappens()
void	subscribeOnDispatchOn()
void	testBeyondLongMaxMicroBatching()
void	testComposedErrorHandlingWithMultipleValues()
void	testComposeFromMultipleFilteredValues()
void	testComposeFromMultipleValues()
void	testComposeFromSingleValue()
void	testDoOnEachSignal()
void	testDoOnEachSignalNullConsumer()
void	testDoOnEachSignalSingleNextInstance()
void	testDoOnEachSignalToSubscriber()
void	testDoOnEachSignalWithError()
void	testHandlersErrorsDownstream()
void	testMerge()
void	testParallelAsyncStream2()
void	testParallelWithJava8StreamsInput() https://gist.github.com/nithril/444d8373ce67f0a8b853 Contribution by Nicolas Labrot
void	testReduce()
void	testStreamBatchesResults()
void	testThenPublisherVoid()
void	unimplementedErrorCallback(TestLogger testLogger)
void	zipOfNull()

从类继承的方法 reactor.core.publisher.scenarios.AbstractReactorTest

closeEnv, loadEnv

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

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

构造器详细资料

FluxTests

public FluxTests()

方法详细资料

discardLocalMultipleFilters

@Test
public void discardLocalMultipleFilters()

discardLocalOrder

@Test
public void discardLocalOrder()

delayErrorConcatMapVsFlatMap

@Test
public void delayErrorConcatMapVsFlatMap()

delayErrorConcatMapVsFlatMapTwoErrors

@Test
public void delayErrorConcatMapVsFlatMapTwoErrors()

testDoOnEachSignal

@Test
public void testDoOnEachSignal()

testDoOnEachSignalSingleNextInstance

@Test
public void testDoOnEachSignalSingleNextInstance()

testDoOnEachSignalWithError

@Test
public void testDoOnEachSignalWithError()

testDoOnEachSignalNullConsumer

@Test
public void testDoOnEachSignalNullConsumer()

testDoOnEachSignalToSubscriber

@Test
public void testDoOnEachSignalToSubscriber()

testThenPublisherVoid

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

抛出:

java.lang.InterruptedException

testComposeFromSingleValue

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

抛出:

java.lang.InterruptedException

testComposeFromMultipleValues

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

抛出:

java.lang.InterruptedException

testComposeFromMultipleFilteredValues

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

抛出:

java.lang.InterruptedException

testComposedErrorHandlingWithMultipleValues

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

抛出:

java.lang.InterruptedException

testReduce

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

抛出:

java.lang.InterruptedException

testMerge

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

抛出:

java.lang.InterruptedException

testStreamBatchesResults

@Test
public void testStreamBatchesResults()

testHandlersErrorsDownstream

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

抛出:

java.lang.InterruptedException

promiseAcceptCountCannotExceedOne

@Test
public void promiseAcceptCountCannotExceedOne()

promiseErrorCountCannotExceedOne

@Test
public void promiseErrorCountCannotExceedOne()

promiseAcceptCountAndErrorCountCannotExceedOneInTotal

@Test
public void promiseAcceptCountAndErrorCountCannotExceedOneInTotal()

analyticsTest

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

抛出:

java.lang.Exception

parallelTests

@Test
 @Tag(value="slow")
public void parallelTests()
                                               throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

partitionByHashCodeShouldNeverCreateMoreStreamsThanSpecified

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

See https://github.com/reactor/reactor/issues/451

抛出:

java.lang.Exception - for convenience

shouldNotFlushStreamOnTimeoutPrematurelyAndShouldDoItConsistently

public void shouldNotFlushStreamOnTimeoutPrematurelyAndShouldDoItConsistently()
                                                                       throws java.lang.Exception

original from @oiavorskyl https://github.com/eventBus/eventBus/issues/358

抛出:

java.lang.Exception - for convenience

shouldNotFlushStreamOnTimeoutPrematurely

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

original from @oiavorskyl https://github.com/eventBus/eventBus/issues/358

抛出:

java.lang.Exception - for convenience

prematureFlatMapCompletion

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

抛出:

java.lang.Exception

cancelOn

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

抛出:

java.lang.Exception

sequenceEqual

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

抛出:

java.lang.Exception

zipOfNull

@Test
public void zipOfNull()

shouldCorrectlyDispatchComplexFlow

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

抛出:

java.lang.InterruptedException

testParallelAsyncStream2

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

抛出:

java.lang.InterruptedException

testParallelWithJava8StreamsInput

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

https://gist.github.com/nithril/444d8373ce67f0a8b853 Contribution by Nicolas Labrot

抛出:

java.lang.InterruptedException - on interrupt

testBeyondLongMaxMicroBatching

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

抛出:

java.lang.InterruptedException

shouldWindowCorrectly

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

抛出:

java.lang.InterruptedException

shouldCorrectlyDispatchBatchedTimeout

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

抛出:

java.lang.InterruptedException

mapLotsOfSubAndCancel

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

抛出:

java.lang.InterruptedException

mapPassThru

public void mapPassThru()
                 throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

consistentMultithreadingWithPartition

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

抛出:

java.lang.InterruptedException

fluxCreateDemoElasticScheduler

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

抛出:

java.lang.Exception

subscribeOnDispatchOn

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

抛出:

java.lang.InterruptedException

unimplementedErrorCallback

@Test
public void unimplementedErrorCallback(TestLogger testLogger)

delayEach

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

抛出:

java.lang.InterruptedException

combineWithOneElement

@Test
public void combineWithOneElement()
                                  throws java.lang.InterruptedException,
                                         java.util.concurrent.TimeoutException

抛出:

java.lang.InterruptedException

java.util.concurrent.TimeoutException

endLessTimer

@Test
 @Disabled
public void endLessTimer()
                                     throws java.lang.InterruptedException,
                                            java.util.concurrent.TimeoutException

This test case demonstrates a silent failure of Flux.interval(Duration) when a resolution is specified that is less than the backing Timer class.

抛出:

java.lang.InterruptedException - - on failure.

java.util.concurrent.TimeoutException - - on failure.

by @masterav10 : https://github.com/reactor/reactor/issues/469

multiplexUsingDispatchersAndSplit

@Test
 @Timeout(value=10L)
public void multiplexUsingDispatchersAndSplit()

                 forkStream
                 /        \      < - - - int
                v          v
 persistenceStream        computationStream
                 \        /      < - - - List< String >
                  v      v
                 joinStream      < - - - String
                 splitStream
             observedSplitStream
 

splitBugEventuallyHappens

@Test
 @Disabled
public void splitBugEventuallyHappens()
                                                  throws java.lang.Exception

抛出:

java.lang.Exception

fluxFromFluxSourceDoesntCallAssemblyHook

@Test
public void fluxFromFluxSourceDoesntCallAssemblyHook()

fluxFromScalarJustCallsAssemblyHook

@Test
public void fluxFromScalarJustCallsAssemblyHook()

fluxFromScalarErrorCallsAssemblyHook

@Test
public void fluxFromScalarErrorCallsAssemblyHook()

fluxFromScalarEmptyCallsAssemblyHook

@Test
public void fluxFromScalarEmptyCallsAssemblyHook()

fluxFromMonoFuseableCallsAssemblyHook

@Test
public void fluxFromMonoFuseableCallsAssemblyHook()

fluxFromMonoNormalCallsAssemblyHook

@Test
public void fluxFromMonoNormalCallsAssemblyHook()

fluxFromPublisherCallsAssemblyHook

@Test
public void fluxFromPublisherCallsAssemblyHook()

fluxNextScalarEmptyCallsAssemblyHook

@Test
public void fluxNextScalarEmptyCallsAssemblyHook()

fluxNextScalarValuedCallsAssemblyHook

@Test
public void fluxNextScalarValuedCallsAssemblyHook()

fluxNextScalarErrorCallsAssemblyHook

@Test
public void fluxNextScalarErrorCallsAssemblyHook()

fluxNextCallableCallsAssemblyHook

@Test
public void fluxNextCallableCallsAssemblyHook()

fluxNextNormalCallsAssemblyHook

@Test
public void fluxNextNormalCallsAssemblyHook()