From 39cefb5bd7045e72d87edc5fa70da56bdbc82fe2 Mon Sep 17 00:00:00 2001 From: Rossen Stoyanchev Date: Tue, 5 Sep 2017 13:59:45 -0400 Subject: [PATCH] One more instance of modified method name in Mono --- .../messaging/tcp/reactor/ReactorNettyTcpClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java index d788428e83..c9bf7cb78a 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java @@ -195,7 +195,7 @@ public class ReactorNettyTcpClient

implements TcpOperations

{ ChannelGroupFuture close = this.channelGroup.close(); Mono completion = FutureMono.from(close) - .doAfterTerminate((x, e) -> { + .doOnSuccessOrError((x, e) -> { // TODO: https://github.com/reactor/reactor-netty/issues/24 shutdownGlobalResources();