reactor.test.publisher

类 ParallelOperatorTest<I,O>

java.lang.Object

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

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

直接已知子类:

ParallelReduceSeedTest

public abstract class ParallelOperatorTest<I,O>
extends BaseOperatorTest<I,ParallelFlux<I>,O,ParallelFlux<O>>

作者:

Stephane Maldini

嵌套类概要

嵌套类

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

构造器概要

构造器

构造器和说明
ParallelOperatorTest()

方法概要

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

构造器详细资料

ParallelOperatorTest

public ParallelOperatorTest()

方法详细资料

scenario

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