Skip to content

Commit 39cefb5

Browse files
committed
One more instance of modified method name in Mono
1 parent fc0841c commit 39cefb5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-messaging/src/main/java/org/springframework/messaging/tcp/reactor/ReactorNettyTcpClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ public ListenableFuture<Void> shutdown() {
195195

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

0 commit comments

Comments
 (0)