Explicitly flush after write in test connections

neo4j · Apr 30, 2018 · 2d8a5f3 · 2d8a5f3
1 parent aa44e12
commit 2d8a5f3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/community/bolt/src/test/java/org/neo4j/bolt/v1/transport/socket/client/SocketConnection.java b/community/bolt/src/test/java/org/neo4j/bolt/v1/transport/socket/client/SocketConnection.java
@@ -65,6 +65,7 @@ public TransportConnection connect( HostnamePort address ) throws IOException
     public TransportConnection send( byte[] rawBytes ) throws IOException
     {
         out.write( rawBytes );
+        out.flush();
         return this;
     }
 

diff --git a/...ity/bolt/src/test/java/org/neo4j/bolt/v1/transport/socket/client/WebSocketConnection.java b/...ity/bolt/src/test/java/org/neo4j/bolt/v1/transport/socket/client/WebSocketConnection.java
@@ -103,6 +103,7 @@ public TransportConnection send( byte[] rawBytes ) throws IOException
         // ownership
         ByteBuffer wrap = ByteBuffer.wrap( Arrays.copyOf( rawBytes, rawBytes.length ) );
         server.sendBytes( wrap );
+        server.flush();
         return this;
     }