reactor.core.publisher

类 FluxMergeSequentialTest

java.lang.Object

reactor.core.publisher.FluxMergeSequentialTest

public class FluxMergeSequentialTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxMergeSequentialTest()

方法概要

限定符和类型	方法和说明
void	badPrefetch()
void	before()
void	cancellingSequentiallyFlatMappedMonos()
void	cancellingSequentiallyMergedMonos()
void	flatMapSequentialDelayErrorWithFluxError()
void	flatMapSequentialDelayErrorWithMonoError()
void	longEager()
void	mainErrorsDelayEnd()
void	mainErrorsImmediate()
void	mappingBadPrefetch()
void	maxConcurrencyAndPrefetch()
void	mergeEmpty()
void	mergeOne()
void	mergeSequentialDelayErrorWithFluxError()
void	mergeSequentialDelayErrorWithMonoError()
void	mergeSequentialIterable()
void	mergeSequentialLargeBadQueueSize()
void	mergeSequentialLargeUnorderedEach100()
void	mergeSequentialMaxConcurrencyAndPrefetch()
void	mergeSequentialOne()
void	mergeSequentialPublisher()
void	mergeSequentialPublisher2()
void	mergeSequentialTwo()
void	mergeSequentialTwoDelayError()
void	mergeSequentialTwoDelayIterableError()
void	mergeSequentialTwoDelayPublisherError()
void	mergeSequentialTwoPrefetch()
void	mergeSequentialZero()
void	normal()
void	normalBackpressured()
void	normalDelayEnd()
void	normalDelayEndBackpressured()
void	scanInner()
void	scanMain()
void	scanOperator()
void	testAsynchronousRun()
void	testBackpressure()
void	testEagerness2()
void	testEagerness3()
void	testEagerness4()
void	testEagerness5()
void	testEagerness6()
void	testEagerness7()
void	testEagerness8()
void	testEagerness9()
void	testInnerEmpty()
void	testInnerError()
void	testInvalidCapacityHint()
void	testInvalidMaxConcurrent()
void	testMainError()
void	testMapperThrows()
void	testMaxConcurrent5()
void	testPrefetchIsBounded()
void	testReentrantWork()
void	testSimple()
void	testSimple2()

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

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

构造器详细资料

FluxMergeSequentialTest

public FluxMergeSequentialTest()

方法详细资料

before

@BeforeEach
public void before()

normal

@Test
public void normal()

normalBackpressured

@Test
public void normalBackpressured()

normalDelayEnd

@Test
public void normalDelayEnd()

normalDelayEndBackpressured

@Test
public void normalDelayEndBackpressured()

mainErrorsDelayEnd

@Test
public void mainErrorsDelayEnd()

mainErrorsImmediate

@Test
public void mainErrorsImmediate()

longEager

@Test
public void longEager()

testSimple

@Test
public void testSimple()

testSimple2

@Test
public void testSimple2()

testEagerness2

@Test
public void testEagerness2()

testEagerness3

@Test
public void testEagerness3()

testEagerness4

@Test
public void testEagerness4()

testEagerness5

@Test
public void testEagerness5()

testEagerness6

@Test
public void testEagerness6()

testEagerness7

@Test
public void testEagerness7()

testEagerness8

@Test
public void testEagerness8()

testEagerness9

@Test
public void testEagerness9()

testMainError

@Test
public void testMainError()

testInnerError

@Test
public void testInnerError()

testInnerEmpty

@Test
public void testInnerEmpty()

testMapperThrows

@Test
public void testMapperThrows()

testInvalidCapacityHint

@Test
public void testInvalidCapacityHint()

testInvalidMaxConcurrent

@Test
public void testInvalidMaxConcurrent()

testBackpressure

@Test
public void testBackpressure()

testAsynchronousRun

@Test
public void testAsynchronousRun()

testReentrantWork

@Test
public void testReentrantWork()

testPrefetchIsBounded

@Test
public void testPrefetchIsBounded()

testMaxConcurrent5

@Test
public void testMaxConcurrent5()

maxConcurrencyAndPrefetch

@Test
public void maxConcurrencyAndPrefetch()

mergeSequentialPublisher

@Test
public void mergeSequentialPublisher()

mergeSequentialMaxConcurrencyAndPrefetch

@Test
public void mergeSequentialMaxConcurrencyAndPrefetch()

badPrefetch

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

抛出:

java.lang.Exception

mappingBadPrefetch

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

抛出:

java.lang.Exception

mergeSequentialZero

@Test
public void mergeSequentialZero()

mergeSequentialOne

@Test
public void mergeSequentialOne()

mergeSequentialTwo

@Test
public void mergeSequentialTwo()

mergeSequentialTwoPrefetch

@Test
public void mergeSequentialTwoPrefetch()

mergeSequentialTwoDelayError

@Test
public void mergeSequentialTwoDelayError()

mergeSequentialIterable

@Test
public void mergeSequentialIterable()

mergeSequentialTwoDelayIterableError

@Test
public void mergeSequentialTwoDelayIterableError()

mergeSequentialPublisher2

@Test
public void mergeSequentialPublisher2()

mergeSequentialTwoDelayPublisherError

@Test
public void mergeSequentialTwoDelayPublisherError()

mergeSequentialLargeUnorderedEach100

@Test
public void mergeSequentialLargeUnorderedEach100()

mergeSequentialLargeBadQueueSize

@Test
public void mergeSequentialLargeBadQueueSize()

mergeEmpty

@Test
public void mergeEmpty()

mergeOne

@Test
public void mergeOne()

flatMapSequentialDelayErrorWithFluxError

@Test
public void flatMapSequentialDelayErrorWithFluxError()

flatMapSequentialDelayErrorWithMonoError

@Test
public void flatMapSequentialDelayErrorWithMonoError()

mergeSequentialDelayErrorWithFluxError

@Test
public void mergeSequentialDelayErrorWithFluxError()

mergeSequentialDelayErrorWithMonoError

@Test
public void mergeSequentialDelayErrorWithMonoError()

cancellingSequentiallyMergedMonos

@Test
public void cancellingSequentiallyMergedMonos()

cancellingSequentiallyFlatMappedMonos

@Test
public void cancellingSequentiallyFlatMappedMonos()

scanOperator

@Test
public void scanOperator()

scanMain

@Test
public void scanMain()

scanInner

@Test
public void scanInner()