diff --git a/runtime/src/main/java/org/capnproto/RpcSystem.java b/runtime/src/main/java/org/capnproto/RpcSystem.java index a47bdea..7fe1f44 100644 --- a/runtime/src/main/java/org/capnproto/RpcSystem.java +++ b/runtime/src/main/java/org/capnproto/RpcSystem.java @@ -41,14 +41,14 @@ public abstract class RpcSystem { new RpcState(bootstrapInterface, connection, onDisconnect)); } - private final CompletableFuture doAcceptLoop() { + private CompletableFuture doAcceptLoop() { return this.network.baseAccept().thenCompose(connection -> { this.accept(connection); return this.doAcceptLoop(); }); } - private final CompletableFuture doMessageLoop() { + private CompletableFuture doMessageLoop() { var accept = this.getAcceptLoop(); for (var conn : connections.values()) { accept = accept.acceptEither(conn.getMessageLoop(), x -> {});