diff --git a/node/src/main/scala/com/wavesplatform/network/WriteErrorHandler.scala b/node/src/main/scala/com/wavesplatform/network/WriteErrorHandler.scala index 99cf7fa891..3b5ba39d9d 100644 --- a/node/src/main/scala/com/wavesplatform/network/WriteErrorHandler.scala +++ b/node/src/main/scala/com/wavesplatform/network/WriteErrorHandler.scala @@ -9,7 +9,7 @@ import io.netty.channel._ @Sharable class WriteErrorHandler extends ChannelOutboundHandlerAdapter with ScorexLogging { override def write(ctx: ChannelHandlerContext, msg: AnyRef, promise: ChannelPromise): Unit = - ctx.channel.writeAndFlush( + ctx.write( msg, promise.unvoid().addListener { (chf: ChannelFuture) => if (!chf.isSuccess) {