reactor.core.publisher

类 FluxFlattenIterableTest

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

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxFlattenIterableTest()

方法概要

限定符和类型	方法和说明
void	asyncDrainWithPollFailure()
void	concatMapIterableDoOnDiscardMonoSource()
void	concatMapIterableDoOnDiscardOnClear()
void	concatMapIterableDoOnDiscardScalarSource()
void	concatMapIterableDoOnDiscardTestDrainAsync()
void	concatMapIterableDoOnDiscardTestDrainSync()
void	empty()
void	errorModeContinueInternalErrorFused()
void	errorModeContinueInternalErrorNotFused()
void	errorModeContinueNullPublisherFused()
void	errorModeContinueNullPublisherNotFused()
void	errorModeContinueSingleElementFused()
void	errorModeContinueSingleElementNotFused()
void	failPrefetch()
void	fullFusion()
void	just()
void	longRunning()
void	longRunningNoFusion()
void	normal()
void	normalBackpressured()
void	normalBackpressuredNoFusion()
void	normalNoFusion()
void	scanOperator()
void	scanSubscriber()
void	syncDrainWithPollFailure()
void	testDrainAsyncCompletesSeveralBatches() See https://github.com/reactor/reactor-core/issues/453
void	testDrainSyncCompletesSeveralBatches() See https://github.com/reactor/reactor-core/issues/453
void	testPublishingTwice() See https://github.com/reactor/reactor-core/issues/508

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

构造器详细资料

FluxFlattenIterableTest

public FluxFlattenIterableTest()

方法详细资料

failPrefetch

@Test
public void failPrefetch()

normal

@Test
public void normal()

normalBackpressured

@Test
public void normalBackpressured()

normalNoFusion

@Test
public void normalNoFusion()

normalBackpressuredNoFusion

@Test
public void normalBackpressuredNoFusion()

longRunning

@Test
public void longRunning()

longRunningNoFusion

@Test
public void longRunningNoFusion()

fullFusion

@Test
public void fullFusion()

just

@Test
public void just()

empty

@Test
public void empty()

testDrainSyncCompletesSeveralBatches

@Test
public void testDrainSyncCompletesSeveralBatches()

See https://github.com/reactor/reactor-core/issues/453

testDrainAsyncCompletesSeveralBatches

@Test
public void testDrainAsyncCompletesSeveralBatches()

See https://github.com/reactor/reactor-core/issues/453

testPublishingTwice

@Test
public void testPublishingTwice()

See https://github.com/reactor/reactor-core/issues/508

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()

asyncDrainWithPollFailure

public void asyncDrainWithPollFailure()

syncDrainWithPollFailure

@Test
public void syncDrainWithPollFailure()

errorModeContinueNullPublisherNotFused

@Test
public void errorModeContinueNullPublisherNotFused()

errorModeContinueInternalErrorNotFused

@Test
public void errorModeContinueInternalErrorNotFused()

errorModeContinueSingleElementNotFused

@Test
public void errorModeContinueSingleElementNotFused()

errorModeContinueNullPublisherFused

@Test
public void errorModeContinueNullPublisherFused()

errorModeContinueInternalErrorFused

@Test
public void errorModeContinueInternalErrorFused()

errorModeContinueSingleElementFused

@Test
public void errorModeContinueSingleElementFused()

concatMapIterableDoOnDiscardTestDrainSync

@Test
public void concatMapIterableDoOnDiscardTestDrainSync()

concatMapIterableDoOnDiscardTestDrainAsync

@Test
public void concatMapIterableDoOnDiscardTestDrainAsync()

concatMapIterableDoOnDiscardScalarSource

@Test
public void concatMapIterableDoOnDiscardScalarSource()

concatMapIterableDoOnDiscardMonoSource

@Test
public void concatMapIterableDoOnDiscardMonoSource()

concatMapIterableDoOnDiscardOnClear

@Test
public void concatMapIterableDoOnDiscardOnClear()