reactor.test.publisher

类 ReduceOperatorTest.Scenario<I,O>

java.lang.Object

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

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

封闭类:

ReduceOperatorTest<I,O>

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

方法概要

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

覆盖:

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

shouldHitDropErrorHookAfterTerminate

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

覆盖:

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

producerError

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

覆盖:

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

droppedError

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

覆盖:

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

droppedItem

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

覆盖:

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

shouldAssertPostTerminateState

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

覆盖:

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

fusionMode

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

覆盖:

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

fusionModeThreadBarrier

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

覆盖:

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

prefetch

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

覆盖:

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

producerEmpty

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

覆盖:

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

producerNever

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

覆盖:

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

producer

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

覆盖:

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

receiverEmpty

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

覆盖:

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

receive

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

覆盖:

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

receiveValues

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

覆盖:

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

receive

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

覆盖:

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

receiverDemand

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

覆盖:

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

description

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

覆盖:

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

verifier

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

覆盖:

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

applyAllOptions

public ReduceOperatorTest.Scenario<I,O> applyAllOptions(OperatorScenario<I,Flux<I>,O,Mono<O>> source)

覆盖:

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