From c85d0cc857782821745d9b848024464b6924028d Mon Sep 17 00:00:00 2001 From: Ivan Mashonskii Date: Fri, 7 Jun 2024 16:37:41 +0300 Subject: [PATCH] Refactor NetworkServer --- .../scala/com/wavesplatform/network/WriteErrorHandler.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/node/src/main/scala/com/wavesplatform/network/WriteErrorHandler.scala b/node/src/main/scala/com/wavesplatform/network/WriteErrorHandler.scala index 99cf7fa8917..3b5ba39d9d7 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) {