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

only tap incoming

Browse source
This commit is contained in:
Vaci Koblizek 2020-10-21 22:27:12 +01:00
parent 05dc84b675
commit 83a4d4dc9e
2 changed files with 0 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
runtime/src/main/java/org/capnproto/TwoPartyVatNetwork.java
View file

@ -9,7 +9,6 @@ public class TwoPartyVatNetwork
VatNetwork.Connection { VatNetwork.Connection {
public interface MessageTap { public interface MessageTap {
void outgoing(OutgoingRpcMessage message, RpcTwoPartyProtocol.Side side);
void incoming(IncomingRpcMessage message, RpcTwoPartyProtocol.Side side); void incoming(IncomingRpcMessage message, RpcTwoPartyProtocol.Side side);
} }

8
runtime/src/test/java/org/capnproto/TwoPartyTest.java
View file

@ -46,14 +46,6 @@ class Tap implements TwoPartyVatNetwork.MessageTap {
final RpcDumper dumper = new RpcDumper(); final RpcDumper dumper = new RpcDumper();
@Override
public void outgoing(OutgoingRpcMessage message, RpcTwoPartyProtocol.Side side) {
var text = this.dumper.dump(message.getBody().asReader().getAs(RpcProtocol.Message.factory), side);
if (text.length() > 0) {
System.out.println(text);
}
}
@Override @Override
public void incoming(IncomingRpcMessage message, RpcTwoPartyProtocol.Side side) { public void incoming(IncomingRpcMessage message, RpcTwoPartyProtocol.Side side) {
var text = this.dumper.dump(message.getBody().getAs(RpcProtocol.Message.factory), side); var text = this.dumper.dump(message.getBody().getAs(RpcProtocol.Message.factory), side);