diff --git a/runtime/src/main/java/org/capnproto/TwoPartyClient.java b/runtime/src/main/java/org/capnproto/TwoPartyClient.java index 1707e03..474dd86 100644 --- a/runtime/src/main/java/org/capnproto/TwoPartyClient.java +++ b/runtime/src/main/java/org/capnproto/TwoPartyClient.java @@ -1,6 +1,7 @@ package org.capnproto; import java.nio.channels.AsynchronousByteChannel; +import java.util.concurrent.CompletableFuture; public class TwoPartyClient { @@ -30,4 +31,8 @@ public class TwoPartyClient { : RpcTwoPartyProtocol.Side.CLIENT); return rpcSystem.bootstrap(vatId.asReader()); } + + public synchronized CompletableFuture runOnce() { + return this.rpcSystem.runOnce(); + } }