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

修复WebSocketEngine的future = future.whenComplete问题

Browse Source
This commit is contained in:
Redkale
2018-07-27 20:35:48 +08:00
parent 0952150328
commit aa2685d6e4
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/net/http/WebSocketEngine.java
View File

@@ -243,7 +243,7 @@ public class WebSocketEngine {
} }
} }
} }
if (future != null) future = future.whenComplete((rs, ex) -> context.offerBuffer(packet.sendBuffers)); if (future != null) future.whenComplete((rs, ex) -> context.offerBuffer(packet.sendBuffers));
return future == null ? CompletableFuture.completedFuture(RETCODE_GROUP_EMPTY) : future; return future == null ? CompletableFuture.completedFuture(RETCODE_GROUP_EMPTY) : future;
} else { } else {
CompletableFuture<Integer> future = null; CompletableFuture<Integer> future = null;
@@ -302,7 +302,7 @@ public class WebSocketEngine {
} }
} }
} }
if (future != null) future = future.whenComplete((rs, ex) -> context.offerBuffer(packet.sendBuffers)); if (future != null) future.whenComplete((rs, ex) -> context.offerBuffer(packet.sendBuffers));
return future == null ? CompletableFuture.completedFuture(RETCODE_GROUP_EMPTY) : future; return future == null ? CompletableFuture.completedFuture(RETCODE_GROUP_EMPTY) : future;
} else { } else {
CompletableFuture<Integer> future = null; CompletableFuture<Integer> future = null;