From e4fe39b20bd6e11b55dfb992085d44eae6df4727 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 30 Aug 2018 12:46:14 -0400 Subject: [PATCH] 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` --- .../springframework/integration/channel/FluxMessageChannel.java | 1 - 1 file changed, 1 deletion(-) diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java index 8f3386ebf5..3c4ea8d5a7 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java @@ -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);