reactor.test.publisher

类 ParallelOperatorTest.Scenario<I,O>

java.lang.Object

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

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

封闭类:

ParallelOperatorTest<I,O>

public static final class ParallelOperatorTest.Scenario<I,O>
extends OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

方法概要

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

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

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

方法详细资料

shouldHitDropNextHookAfterTerminate

public ParallelOperatorTest.Scenario<I,O> shouldHitDropNextHookAfterTerminate(boolean shouldHitDropNextHookAfterTerminate)

覆盖:

shouldHitDropNextHookAfterTerminate 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

shouldHitDropErrorHookAfterTerminate

public ParallelOperatorTest.Scenario<I,O> shouldHitDropErrorHookAfterTerminate(boolean shouldHitDropErrorHookAfterTerminate)

覆盖:

shouldHitDropErrorHookAfterTerminate 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

producerError

public ParallelOperatorTest.Scenario<I,O> producerError(java.lang.RuntimeException e)

覆盖:

producerError 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

droppedError

public ParallelOperatorTest.Scenario<I,O> droppedError(java.lang.RuntimeException e)

覆盖:

droppedError 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

droppedItem

public ParallelOperatorTest.Scenario<I,O> droppedItem(I item)

覆盖:

droppedItem 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

shouldAssertPostTerminateState

public ParallelOperatorTest.Scenario<I,O> shouldAssertPostTerminateState(boolean shouldAssertPostTerminateState)

覆盖:

shouldAssertPostTerminateState 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

fusionMode

public ParallelOperatorTest.Scenario<I,O> fusionMode(int fusionMode)

覆盖:

fusionMode 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

fusionModeThreadBarrier

public ParallelOperatorTest.Scenario<I,O> fusionModeThreadBarrier(int fusionModeThreadBarrier)

覆盖:

fusionModeThreadBarrier 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

prefetch

public ParallelOperatorTest.Scenario<I,O> prefetch(int prefetch)

覆盖:

prefetch 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

producerEmpty

public ParallelOperatorTest.Scenario<I,O> producerEmpty()

覆盖:

producerEmpty 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

producerNever

public ParallelOperatorTest.Scenario<I,O> producerNever()

覆盖:

producerNever 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

producer

public ParallelOperatorTest.Scenario<I,O> producer(int n,
                                                   java.util.function.IntFunction<? extends I> producer)

覆盖:

producer 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

receiverEmpty

public final ParallelOperatorTest.Scenario<I,O> receiverEmpty()

覆盖:

receiverEmpty 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

receive

@SafeVarargs
public final ParallelOperatorTest.Scenario<I,O> receive(java.util.function.Consumer<? super O>... receivers)

覆盖:

receive 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

receiveValues

@SafeVarargs
public final ParallelOperatorTest.Scenario<I,O> receiveValues(O... receivers)

覆盖:

receiveValues 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

receive

public final ParallelOperatorTest.Scenario<I,O> receive(int i,
                                                        java.util.function.IntFunction<? extends O> receivers)

覆盖:

receive 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

receiverDemand

public ParallelOperatorTest.Scenario<I,O> receiverDemand(long d)

覆盖:

receiverDemand 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

description

public ParallelOperatorTest.Scenario<I,O> description(java.lang.String description)

覆盖:

description 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

verifier

public ParallelOperatorTest.Scenario<I,O> verifier(java.util.function.Consumer<StepVerifier.Step<O>> verifier)

覆盖:

verifier 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>

applyAllOptions

public ParallelOperatorTest.Scenario<I,O> applyAllOptions(OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>> source)

覆盖:

applyAllOptions 在类中 OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>>