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