diff --git a/src/org/redkale/net/http/WebSocketGroup.java b/src/org/redkale/net/http/WebSocketGroup.java index 554244c51..af072f111 100644 --- a/src/org/redkale/net/http/WebSocketGroup.java +++ b/src/org/redkale/net/http/WebSocketGroup.java @@ -101,7 +101,7 @@ public final class WebSocketGroup { if (future == null) { future = s.sendPacket(packet); } else { - future.thenCombine(s.sendPacket(packet), (a, b) -> a | (Integer) b); + future = future.thenCombine(s.sendPacket(packet), (a, b) -> a | (Integer) b); } } return future == null ? CompletableFuture.completedFuture(0) : future;