类的使用
reactor.test.publisher.OperatorScenario

使用OperatorScenario的程序包

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

reactor.test.publisher中OperatorScenario的使用

reactor.test.publisher中OperatorScenario的子类

限定符和类型	类和说明
static class	FluxOperatorTest.Scenario<I,O>
static class	MonoOperatorTest.Scenario<I,O>
static class	ParallelOperatorTest.Scenario<I,O>
static class	ReduceOperatorTest.Scenario<I,O>

返回OperatorScenario的reactor.test.publisher中的方法

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

参数类型为OperatorScenario的reactor.test.publisher中的方法

限定符和类型	方法和说明
FluxOperatorTest.Scenario<I,O>	FluxOperatorTest.Scenario.applyAllOptions(OperatorScenario<I,Flux<I>,O,Flux<O>> source)
ReduceOperatorTest.Scenario<I,O>	ReduceOperatorTest.Scenario.applyAllOptions(OperatorScenario<I,Flux<I>,O,Mono<O>> source)
MonoOperatorTest.Scenario<I,O>	MonoOperatorTest.Scenario.applyAllOptions(OperatorScenario<I,Mono<I>,O,Mono<O>> source)
ParallelOperatorTest.Scenario<I,O>	ParallelOperatorTest.Scenario.applyAllOptions(OperatorScenario<I,ParallelFlux<I>,O,ParallelFlux<O>> source)
OperatorScenario<I,PI,O,PO>	OperatorScenario.applyAllOptions(OperatorScenario<I,PI,O,PO> source)