This commit is contained in:
@@ -101,7 +101,7 @@ public final class WebSocketGroup {
|
|||||||
if (future == null) {
|
if (future == null) {
|
||||||
future = s.sendPacket(packet);
|
future = s.sendPacket(packet);
|
||||||
} else {
|
} 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;
|
return future == null ? CompletableFuture.completedFuture(0) : future;
|
||||||
|
|||||||
Reference in New Issue
Block a user