diff --git a/runtime-rpc/src/main/java/org/capnproto/RpcState.java b/runtime-rpc/src/main/java/org/capnproto/RpcState.java index ad3fc9c..3582b70 100644 --- a/runtime-rpc/src/main/java/org/capnproto/RpcState.java +++ b/runtime-rpc/src/main/java/org/capnproto/RpcState.java @@ -205,6 +205,7 @@ final class RpcState { final static class Embargo { final int id; final CompletableFuture disembargo = new CompletableFuture<>(); + Embargo(int id) { this.id = id; } @@ -320,9 +321,7 @@ final class RpcState { } for (var embargo: embargos) { - if (embargo.disembargo != null) { - embargo.disembargo.completeExceptionally(networkExc); - } + embargo.disembargo.completeExceptionally(networkExc); } // Send an abort message, but ignore failure.