fix Cumulator ut error

ctripcorp · Apr 15, 2024 · 3d896ce · 3d896ce
1 parent 1dd285e
commit 3d896ce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...oxy/src/test/java/com/ctrip/xpipe/redis/proxy/integrate/AbstractProxyIntegrationTest.java b/...oxy/src/test/java/com/ctrip/xpipe/redis/proxy/integrate/AbstractProxyIntegrationTest.java
@@ -205,7 +205,7 @@ public ReceiveHandler(AtomicReference<ByteBuf> buffer) {
         public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
             ByteBuf byteBuf = (ByteBuf) msg;
             byteBuf.retain();
-            cumulator.cumulate(ctx.channel().alloc(), cumulation, byteBuf);
+            cumulation = cumulator.cumulate(ctx.channel().alloc(), cumulation, byteBuf);
             buffer.set(cumulation);
             super.channelRead(ctx, msg);
         }