Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1254 from fdesu/fix/reactor-netty-tcp-client-update

Browse Source 
ChannelFutureMono renamed to FutureMono
This commit is contained in:
Rossen Stoyanchev
2016-12-04 20:22:59 -05:00
committed by GitHub
parent 55d4268448 e4ed1f6ffd
commit 0e20360bf9
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -31,7 +31,7 @@ import reactor.core.publisher.Mono;
import reactor.core.publisher.MonoProcessor;
import reactor.core.scheduler.Scheduler;
import reactor.core.scheduler.Schedulers;
import reactor.ipc.netty.ChannelFutureMono;
import reactor.ipc.netty.FutureMono;
import reactor.ipc.netty.NettyContext;
import reactor.ipc.netty.NettyInbound;
import reactor.ipc.netty.NettyOutbound;
@@ -164,7 +164,7 @@ public class ReactorNettyTcpClient<P> implements TcpOperations<P> {
this.stopping = true;
Mono<Void> completion = ChannelFutureMono.from(this.group.close())
Mono<Void> completion = FutureMono.from(this.group.close())
.doAfterTerminate((x, e) -> this.scheduler.shutdown());
return new MonoToListenableFutureAdapter<>(completion);