diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 98d25cf82..06108e5a6 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -244,7 +244,7 @@ public abstract class WebSocketNode { } return future == null ? CompletableFuture.completedFuture(0) : future; }); - return localFuture.thenCombine(remoteFuture, (a, b) -> a + b); + return localFuture == null ? remoteFuture : localFuture.thenCombine(remoteFuture, (a, b) -> a + b); } //--------------------------------------------------------------------------------