类的使用
reactor.test.publisher.ParallelOperatorTest.Scenario

使用ParallelOperatorTest.Scenario的程序包

程序包	说明
reactor.test.publisher	Components supporting the creation of test-oriented Publishers.

reactor.test.publisher中ParallelOperatorTest.Scenario的使用

返回ParallelOperatorTest.Scenario的reactor.test.publisher中的方法

限定符和类型	方法和说明
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.applyAllOptions(OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>> source)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.description(java.lang.String description)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.droppedError(java.lang.RuntimeException e)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.droppedItem(I item)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.fusionMode(int fusionMode)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.fusionModeThreadBarrier(int fusionModeThreadBarrier)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.prefetch(int prefetch)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.producer(int n, java.util.function.IntFunction<? extends I> producer)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.producerEmpty()
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.producerError(java.lang.RuntimeException e)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.producerNever()
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.receive(java.util.function.Consumer<? super O>... receivers)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.receive(int i, java.util.function.IntFunction<? extends O> receivers)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.receiverDemand(long d)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.receiverEmpty()
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.receiveValues(O... receivers)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.scenario(java.util.function.Function<ParallelFlux<I>,? extends ParallelFlux<O>> scenario)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.shouldAssertPostTerminateState(boolean shouldAssertPostTerminateState)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.shouldHitDropErrorHookAfterTerminate(boolean shouldHitDropErrorHookAfterTerminate)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.shouldHitDropNextHookAfterTerminate(boolean shouldHitDropNextHookAfterTerminate)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.verifier(java.util.function.Consumer<StepVerifier.Step<O>> verifier)