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

send abort to close test connection

Browse source
This commit is contained in:
Vaci Koblizek 2020-11-14 10:31:59 +00:00
parent f0d4d9d75a
commit 6e066d43c2
2 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
runtime-rpc/src/main/java/org/capnproto/VatNetwork.java
View file

@ -1,6 +1,5 @@
package org.capnproto; package org.capnproto;
import java.io.IOException;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
public interface VatNetwork<VatId> public interface VatNetwork<VatId>

9
runtime-rpc/src/test/java/org/capnproto/RpcTest.java
View file

@ -33,10 +33,11 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionException; import java.util.concurrent.CompletionException;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
import static org.capnproto.RpcState.FromException;
public class RpcTest { public class RpcTest {
final class TestNetwork { static final class TestNetwork {
final Map<String, TestNetworkAdapter> map = new HashMap<>(); final Map<String, TestNetworkAdapter> map = new HashMap<>();
int received = 0; int received = 0;
@ -51,7 +52,7 @@ public class RpcTest {
} }
} }
final class TestNetworkAdapter static final class TestNetworkAdapter
implements VatNetwork<Test.TestSturdyRef.Reader> { implements VatNetwork<Test.TestSturdyRef.Reader> {
@Override @Override
@ -169,6 +170,10 @@ public class RpcTest {
@Override @Override
public void close() { public void close() {
var msg = newOutgoingMessage(0);
var abort = msg.getBody().initAs(RpcProtocol.Message.factory).initAbort();
FromException(RpcException.disconnected(""), abort);
msg.send();
} }
} }