Dave Syer 5aeba1ea96 Convert Consumer<Foo> to Function<Flux<Foo>,Mono<Void>> ...

This results in a better experience for users because the consumer
that they write is only applied to a Flux that is subscribed to
by the framework once. It gives better control over the flow of
foos, e.g. if some component wants to subscribe on a thread.

2018-03-26 10:06:13 +01:00

..

main

Convert Consumer<Foo> to Function<Flux<Foo>,Mono<Void>>

2018-03-26 10:06:13 +01:00

test/java/org/springframework/cloud/function/stream

Extract common logic in invokers into base class

2018-03-20 17:40:06 +00:00