lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-05-26 00:40:51 +08:00
parent 59b08684a8
commit 1e60adf5bb
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/redkale/net/http/WebSocketGroup.java
View File

@@ -117,7 +117,7 @@ public final class WebSocketGroup {
future = future.thenCombine(s.sendPacket(packet), (a, b) -> a | (Integer) b); 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; return future == null ? CompletableFuture.completedFuture(0) : future;
} }