public abstract class ReduceOperatorTest<I,O> extends BaseOperatorTest<I,Flux<I>,O,Mono<O>>
限定符和类型 | 类和说明 |
---|---|
static class |
ReduceOperatorTest.Scenario<I,O> |
构造器和说明 |
---|
ReduceOperatorTest() |
限定符和类型 | 方法和说明 |
---|---|
ReduceOperatorTest.Scenario<I,O> |
scenario(java.util.function.Function<Flux<I>,? extends Mono<O>> scenario) |