reactor.test.publisher

类 MonoOperatorTest.Scenario<I,O>

java.lang.Object

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

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

封闭类:

MonoOperatorTest<I,O>

public static final class MonoOperatorTest.Scenario<I,O>
extends OperatorScenario<I,Mono<I>,O,Mono<O>>

方法概要

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

覆盖:

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

shouldHitDropErrorHookAfterTerminate

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

覆盖:

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

shouldAssertPostTerminateState

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

覆盖:

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

fusionMode

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

覆盖:

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

fusionModeThreadBarrier

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

覆盖:

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

prefetch

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

覆盖:

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

producerEmpty

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

覆盖:

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

producerNever

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

覆盖:

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

producer

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

覆盖:

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

producerError

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

覆盖:

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

droppedError

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

覆盖:

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

droppedItem

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

覆盖:

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

receiverEmpty

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

覆盖:

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

receive

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

覆盖:

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

receiveValues

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

覆盖:

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

receive

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

覆盖:

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

receiverDemand

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

覆盖:

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

description

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

覆盖:

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

verifier

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

覆盖:

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

applyAllOptions

public MonoOperatorTest.Scenario<I,O> applyAllOptions(@Nullable
                                                      OperatorScenario<I,Mono<I>,O,Mono<O>> source)

覆盖:

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