diff --git a/runtime-rpc/src/main/java/org/capnproto/TwoPartyVatNetwork.java b/runtime-rpc/src/main/java/org/capnproto/TwoPartyVatNetwork.java index 70df26d..9af830c 100644 --- a/runtime-rpc/src/main/java/org/capnproto/TwoPartyVatNetwork.java +++ b/runtime-rpc/src/main/java/org/capnproto/TwoPartyVatNetwork.java @@ -70,9 +70,7 @@ public class TwoPartyVatNetwork var result = this.previousWrite.whenComplete((void_, exc) -> { try { - if (this.channel instanceof AsynchronousSocketChannel) { - ((AsynchronousSocketChannel)this.channel).shutdownOutput(); - } + this.channel.shutdownOutput(); } catch (Exception ignored) { }