类的使用
reactor.test.publisher.FluxOperatorTest.Scenario

使用FluxOperatorTest.Scenario的程序包

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

reactor.test.publisher中FluxOperatorTest.Scenario的使用

返回FluxOperatorTest.Scenario的reactor.test.publisher中的方法

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