Remove hide() from FluxMessageChannel

The Reactor Core has a fix for the https://github.com/reactor/reactor-core/issues/1290
so, we can simply remove a `hide()` call for the `publish()` in `Flux`
This commit is contained in:
Artem Bilan
2018-08-30 12:46:14 -04:00
parent 230d12d425
commit e4fe39b20b

View File

@@ -85,7 +85,6 @@ public class FluxMessageChannel extends AbstractMessageChannel
.onErrorContinue((throwable, o) -> logger.warn("Error during processing event: " + o, throwable)
)
.doOnComplete(() -> this.publishers.remove(publisher))
.hide() // TODO remove after upgrade to Reactor 3.1.9.RELEASE or later
.publish();
this.publishers.put(publisher, connectableFlux);