|
|
@ -61,9 +61,11 @@ public class ReactorNettyTcpConnection<P> implements TcpConnection<P> { |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public ListenableFuture<Void> send(Message<P> message) { |
|
|
|
public ListenableFuture<Void> send(Message<P> message) { |
|
|
|
ByteBuf byteBuf = this.inbound.channel().alloc().buffer(); |
|
|
|
ByteBuf byteBuf = this.inbound.alloc() |
|
|
|
|
|
|
|
.buffer(); |
|
|
|
this.encoder.accept(byteBuf, message); |
|
|
|
this.encoder.accept(byteBuf, message); |
|
|
|
return new MonoToListenableFutureAdapter<>(this.outbound.send(Mono.just(byteBuf))); |
|
|
|
return new MonoToListenableFutureAdapter<>(this.outbound.send(Mono.just(byteBuf) |
|
|
|
|
|
|
|
.then())); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|