Toggle navigation
Home
org.neo4j.bolt.v1.transport.socket.client.TransportConnection to org.neo4j.bolt.v1.transport.integration.Neo4jWithSocket
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'neo4j'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
TypeSafeMatcher<TransportConnection>
to
TypeSafeMatcher<Neo4jWithSocket>
Update Anonymous class
{ @Override protected boolean matchesSafely( TransportConnection connection){ try { connection.recv(1); } catch ( Exception e) { return e instanceof IOException; } return false; } @Override public void describeTo( Description description){ description.appendText("Eventually Disconnects"); } }
to
{ @Override public void describeTo( org.hamcrest.Description description){ description.appendText("Eventually close all transactions"); } @Override protected boolean matchesSafely( Neo4jWithSocket server){ BooleanSupplier condition=() -> getActiveTransactions(server).size() == 0; try { Predicates.await(condition,2,TimeUnit.SECONDS); return true; } catch ( Exception e) { return false; } } private Set<KernelTransactionHandle> getActiveTransactions( Neo4jWithSocket server){ GraphDatabaseAPI gdb=(GraphDatabaseAPI)server.graphDatabaseService(); return gdb.getDependencyResolver().resolveDependency(KernelTransactions.class).activeTransactions(); } }
Rename Variable
serverImmediatelyDisconnects
to
eventuallyClosesTransaction