Use EmitterProcessor in the FluxMessageChannel#3104

Merged

garyrussell merged 9 commits intospring-projects:masterfrom

artembilan:EmitterProcessor_for_FluxMessageChannel

Dec 3, 2019

Commits on Dec 3, 2019

GH-3107: Add errorOnTimeout for TcpInboundGateway
artembilan
committed
Use EmitterProcessor in the FluxMessageChannel
artembilan
committed
* Use `flux.onComplete()` instead of iteration over subscribers
artembilan
committed
* Use `delaySubscription()` for subscribing publishers in the `FluxMessageChannel`
artembilan
committed
Revert "GH-3107: Add errorOnTimeout for TcpInboundGateway"
artembilan
committed
* Refactor `FluxMessageChannel` to use `ReplayProcessor` for `subscribedSignal`.
artembilan
committed
* Use `Flux.subscribe(Consumer)` instead of `doOnNext(Consumer).subscribe()`
artembilan
committed
* Emit `subscribedSignal` value after `.subscribe(subscriber)`
artembilan
committed
* Use `this.processor.hasDownstreams()` as a value to emit for `subscribedSignal`.
artembilan
committed