reactor.test.publisher

类 FluxOperatorTest<I,O>

java.lang.Object

reactor.test.publisher.BaseOperatorTest<I,Flux<I>,O,Flux<O>>

reactor.test.publisher.FluxOperatorTest<I,O>

直接已知子类:

AbstractFluxConcatMapTest, FluxBufferBoundaryTest, FluxBufferTest, FluxCombineLatestTest, FluxDematerializeTest, FluxDistinctTest, FluxDistinctUntilChangedTest, FluxFilterFuseableTest, FluxFilterTest, FluxFlattenIterableTest, FluxGroupByTest, FluxHandleTest, FluxIndexedFuseableTest, FluxIndexTest, FluxMapSignalTest, FluxMapTest, FluxMaterializeTest, FluxOnBackpressureBufferTest, FluxPeekTest, FluxPublishMulticastTest, FluxPublishOnTest, FluxPublishTest, FluxReplayTest, FluxScanSeedTest, FluxScanTest, FluxSkipLastTest, FluxSkipTest, FluxSkipUntilOtherTest, FluxSkipUntilTest, FluxSkipWhileTest, FluxUsingTest, FluxWindowPredicateTest, FluxWindowTest, FluxZipIterableTest, FluxZipTest

public abstract class FluxOperatorTest<I,O>
extends BaseOperatorTest<I,Flux<I>,O,Flux<O>>

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxOperatorTest()

方法概要

限定符和类型	方法和说明
FluxOperatorTest.Scenario<I,O>	scenario(java.util.function.Function<Flux<I>,? extends Flux<O>> 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

构造器详细资料

FluxOperatorTest

public FluxOperatorTest()

方法详细资料

scenario

public final FluxOperatorTest.Scenario<I,O> scenario(java.util.function.Function<Flux<I>,? extends Flux<O>> scenario)