serverscanning/capnproto-java-rpc
16
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

serialise write and correct chaining

Browse source
This commit is contained in:
Vaci Koblizek 2020-11-20 20:08:31 +00:00
parent 1cadca604e
commit 52892478ef
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
runtime-rpc/src/main/java/org/capnproto/TwoPartyVatNetwork.java
View file

@ -133,6 +133,10 @@ public class TwoPartyVatNetwork
} }
} }
private synchronized void write(MessageBuilder message) {
this.previousWrite = this.previousWrite.thenCompose(void_ -> Serialize.writeAsync(channel, message));
}
final class OutgoingMessage implements OutgoingRpcMessage { final class OutgoingMessage implements OutgoingRpcMessage {
private final MessageBuilder message; private final MessageBuilder message;
@ -156,7 +160,7 @@ public class TwoPartyVatNetwork
@Override @Override
public void send() { public void send() {
previousWrite = previousWrite.thenRun(() -> Serialize.writeAsync(channel, message)); write(message);
} }
@Override @Override