I
- input type of target consumerpublic class FluxConsumer<I> extends WrappedFunction<I,Void,reactor.core.publisher.Flux<I>,reactor.core.publisher.Mono<Void>,Consumer<I>>
Consumer
implementation that converts a non-reactive
consumer into a reactive function (Function<Flux<?>, Mono<?>>
).FluxedConsumer
Constructor and Description |
---|
FluxConsumer(Consumer<I> target) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Void> |
apply(reactor.core.publisher.Flux<I> input) |
getTarget
Copyright © 2021 Pivotal Software, Inc.. All rights reserved.