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