reactor.test.publisher

类 OperatorScenario<I,PI extends org.reactivestreams.Publisher<? extends I>,O,PO extends org.reactivestreams.Publisher<? extends O>>

java.lang.Object

reactor.test.publisher.OperatorScenario<I,PI,O,PO>

直接已知子类:

FluxOperatorTest.Scenario, MonoOperatorTest.Scenario, ParallelOperatorTest.Scenario, ReduceOperatorTest.Scenario

public class OperatorScenario<I,PI extends org.reactivestreams.Publisher<? extends I>,O,PO extends org.reactivestreams.Publisher<? extends O>>
extends java.lang.Object

作者:

Stephane Maldini

方法概要

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

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

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

方法详细资料

applyAllOptions

public OperatorScenario<I,PI,O,PO> applyAllOptions(@Nullable
                                                   OperatorScenario<I,PI,O,PO> source)

description

public OperatorScenario<I,PI,O,PO> description(java.lang.String description)

fusionMode

public OperatorScenario<I,PI,O,PO> fusionMode(int fusionMode)

fusionModeThreadBarrier

public OperatorScenario<I,PI,O,PO> fusionModeThreadBarrier(int fusionModeThreadBarrier)

prefetch

public OperatorScenario<I,PI,O,PO> prefetch(int prefetch)

producer

public OperatorScenario<I,PI,O,PO> producer(int n,
                                            java.util.function.IntFunction<? extends I> producer)

producerEmpty

public OperatorScenario<I,PI,O,PO> producerEmpty()

producerNever

public OperatorScenario<I,PI,O,PO> producerNever()

producerError

public OperatorScenario<I,PI,O,PO> producerError(java.lang.RuntimeException producerError)

droppedError

public OperatorScenario<I,PI,O,PO> droppedError(java.lang.RuntimeException producerError)

droppedItem

public OperatorScenario<I,PI,O,PO> droppedItem(I item)

receive

public OperatorScenario<I,PI,O,PO> receive(java.util.function.Consumer<? super O>... receivers)

receive

public OperatorScenario<I,PI,O,PO> receive(int n,
                                           java.util.function.IntFunction<? extends O> receiverMapper)

receiveValues

public OperatorScenario<I,PI,O,PO> receiveValues(O... receivers)

receiverDemand

public OperatorScenario<I,PI,O,PO> receiverDemand(long d)

receiverEmpty

public OperatorScenario<I,PI,O,PO> receiverEmpty()

shouldAssertPostTerminateState

public OperatorScenario<I,PI,O,PO> shouldAssertPostTerminateState(boolean shouldAssertPostTerminateState)

shouldHitDropErrorHookAfterTerminate

public OperatorScenario<I,PI,O,PO> shouldHitDropErrorHookAfterTerminate(boolean shouldHitDropErrorHookAfterTerminate)

shouldHitDropNextHookAfterTerminate

public OperatorScenario<I,PI,O,PO> shouldHitDropNextHookAfterTerminate(boolean shouldHitDropNextHookAfterTerminate)

verifier

public OperatorScenario<I,PI,O,PO> verifier(java.util.function.Consumer<StepVerifier.Step<O>> verifier)