reactor.core.publisher

类 ParallelFluxTest

java.lang.Object

reactor.core.publisher.ParallelFluxTest

public class ParallelFluxTest
extends java.lang.Object

字段概要

字段

限定符和类型	字段和说明
AutoDisposingExtension	afterTest

构造器概要

构造器

构造器和说明
ParallelFluxTest()

方法概要

限定符和类型	方法和说明
void	asChangesParallelism()
void	collectSortedList()
void	collectSortedListBothEmpty()
void	collectSortedListLeftEmpty()
void	collectSortedListLeftLarger()
void	collectSortedListRightEmpty()
void	collectSortedListRightLarger()
void	concatMapUnordered()
void	doOnEachContext()
void	flatMapUnordered()
void	from()
void	fromFuseableUsesThreadBarrier()
void	fromNegativeParallelismRejected()
void	fromNegativePrefetchRejected()
void	fromNullPublisherArrayRejected()
void	fromNullPublisherRejected()
void	fromPublisherDefaultPrefetchIsSmallBufferSize()
void	fromPublishersDefaultPrefetchIsMinusOne()
void	fromPublishersSequentialSubscribe()
void	fromSourceHasCpuParallelism()
void	fromZeroLengthArrayPublishersRejected()
void	fromZeroParallelismRejected()
void	fromZeroPrefetchRejected()
void	fromZeroPublishersRejected()
void	groupMerge()
void	hooks()
void	parallelMode()
void	parallelModeFused()
void	parallelSubscribeAndDispose()
void	runOnNegativePrefetchRejected()
void	runOnZeroPrefetchRejected()
void	sequentialMode()
void	sequentialModeFused()
void	sequentialNegativePrefetchRejected()
void	sequentialZeroPrefetchRejected()
void	sorted()
void	subscribeOnNextOnErrorErrorsOnAllRails()
void	subscribeWithCoreSubscriber()
void	testConcatMapDelayError()
void	testConcatMapDelayErrorPrefetch()
void	testConcatMapDelayErrorPrefetchDelayUntilEnd()
void	testConcatMapPrefetch()
void	testDoOnEachSignal()
void	testDoOnEachSignalNullConsumer()
void	testDoOnEachSignalToSubscriber()
void	testDoOnEachSignalWithError()
void	testFlatMapDelayError()
void	testFlatMapDelayErrorMaxConcurrency()
void	testParallelism()
void	testPeekCancel()
void	testPeekComplete()
void	testPeekError()
void	testPublisherSubscribeUsesSequential()
void	transformChangesPrefetch()
void	transformGroups()
void	transformGroupsMaintainsParallelism()
void	transformGroupsMaintainsParallelismAndPrefetch()
void	validateTooFewSubscribers()
void	validateTooManySubscribers()

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

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

字段详细资料

afterTest

@RegisterExtension
public AutoDisposingExtension afterTest

构造器详细资料

ParallelFluxTest

public ParallelFluxTest()

方法详细资料

sequentialMode

@Test
 @Tag(value="slow")
public void sequentialMode()

sequentialModeFused

@Test
 @Tag(value="slow")
public void sequentialModeFused()

parallelMode

@Test
 @Tag(value="slow")
public void parallelMode()

parallelModeFused

@Test
 @Tag(value="slow")
public void parallelModeFused()

collectSortedList

@Test
public void collectSortedList()

sorted

@Test
public void sorted()

groupMerge

@Test
public void groupMerge()

from

@Test
public void from()

concatMapUnordered

@Test
public void concatMapUnordered()

flatMapUnordered

@Test
public void flatMapUnordered()

testDoOnEachSignal

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

抛出:

java.lang.InterruptedException

testDoOnEachSignalWithError

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

抛出:

java.lang.InterruptedException

testDoOnEachSignalNullConsumer

@Test
public void testDoOnEachSignalNullConsumer()

testDoOnEachSignalToSubscriber

@Test
public void testDoOnEachSignalToSubscriber()

transformGroups

@Test
public void transformGroups()

transformGroupsMaintainsParallelismAndPrefetch

@Test
public void transformGroupsMaintainsParallelismAndPrefetch()

transformGroupsMaintainsParallelism

@Test
public void transformGroupsMaintainsParallelism()

fromSourceHasCpuParallelism

@Test
public void fromSourceHasCpuParallelism()

fromZeroParallelismRejected

@Test
public void fromZeroParallelismRejected()

fromNegativeParallelismRejected

@Test
public void fromNegativeParallelismRejected()

fromZeroPrefetchRejected

@Test
public void fromZeroPrefetchRejected()

fromNegativePrefetchRejected

@Test
public void fromNegativePrefetchRejected()

fromZeroPublishersRejected

@Test
public void fromZeroPublishersRejected()

fromZeroLengthArrayPublishersRejected

@Test
public void fromZeroLengthArrayPublishersRejected()

fromNullPublisherRejected

@Test
public void fromNullPublisherRejected()

fromNullPublisherArrayRejected

@Test
public void fromNullPublisherArrayRejected()

fromFuseableUsesThreadBarrier

@Test
public void fromFuseableUsesThreadBarrier()

runOnZeroPrefetchRejected

@Test
public void runOnZeroPrefetchRejected()

runOnNegativePrefetchRejected

@Test
public void runOnNegativePrefetchRejected()

sequentialZeroPrefetchRejected

@Test
public void sequentialZeroPrefetchRejected()

sequentialNegativePrefetchRejected

@Test
public void sequentialNegativePrefetchRejected()

subscribeOnNextOnErrorErrorsOnAllRails

@Test
public void subscribeOnNextOnErrorErrorsOnAllRails()

validateTooFewSubscribers

@Test
public void validateTooFewSubscribers()

validateTooManySubscribers

@Test
public void validateTooManySubscribers()

fromPublishersDefaultPrefetchIsMinusOne

@Test
public void fromPublishersDefaultPrefetchIsMinusOne()

fromPublisherDefaultPrefetchIsSmallBufferSize

@Test
public void fromPublisherDefaultPrefetchIsSmallBufferSize()

fromPublishersSequentialSubscribe

@Test
public void fromPublishersSequentialSubscribe()

asChangesParallelism

@Test
public void asChangesParallelism()

transformChangesPrefetch

@Test
public void transformChangesPrefetch()

testPeekComplete

@Test
public void testPeekComplete()

testPeekError

@Test
public void testPeekError()

testPeekCancel

@Test
public void testPeekCancel()

testConcatMapPrefetch

@Test
public void testConcatMapPrefetch()

testConcatMapDelayError

@Test
public void testConcatMapDelayError()

testConcatMapDelayErrorPrefetch

@Test
public void testConcatMapDelayErrorPrefetch()

testConcatMapDelayErrorPrefetchDelayUntilEnd

@Test
public void testConcatMapDelayErrorPrefetchDelayUntilEnd()

testFlatMapDelayError

@Test
public void testFlatMapDelayError()

testFlatMapDelayErrorMaxConcurrency

@Test
public void testFlatMapDelayErrorMaxConcurrency()

testPublisherSubscribeUsesSequential

@Test
public void testPublisherSubscribeUsesSequential()

collectSortedListBothEmpty

@Test
public void collectSortedListBothEmpty()

collectSortedListRightLarger

@Test
public void collectSortedListRightLarger()

collectSortedListLeftLarger

@Test
public void collectSortedListLeftLarger()

collectSortedListLeftEmpty

@Test
public void collectSortedListLeftEmpty()

collectSortedListRightEmpty

@Test
public void collectSortedListRightEmpty()

testParallelism

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

抛出:

java.lang.Exception

parallelSubscribeAndDispose

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

抛出:

java.lang.InterruptedException

hooks

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

抛出:

java.lang.Exception

subscribeWithCoreSubscriber

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

抛出:

java.lang.Exception

doOnEachContext

@Test
public void doOnEachContext()