From 1e60adf5bb8c179382609f7c60cc6f99e70e4a30 Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Fri, 26 May 2017 00:40:51 +0800 Subject: [PATCH] --- src/org/redkale/net/http/WebSocketGroup.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/org/redkale/net/http/WebSocketGroup.java b/src/org/redkale/net/http/WebSocketGroup.java index ab20f3fe2..176e662c9 100644 --- a/src/org/redkale/net/http/WebSocketGroup.java +++ b/src/org/redkale/net/http/WebSocketGroup.java @@ -117,7 +117,7 @@ public final class WebSocketGroup { future = future.thenCombine(s.sendPacket(packet), (a, b) -> a | (Integer) b); } } - if (more && future != null) future.whenComplete((rs, ex) -> context.offerBuffer(packet.sendBuffers)); + if (more && future != null) future = future.whenComplete((rs, ex) -> context.offerBuffer(packet.sendBuffers)); return future == null ? CompletableFuture.completedFuture(0) : future; }