Consume query results in stress test

Not consuming them can make the database stop accepting new commands
because its outgoing network buffer is too full. Clients are expected
to consume results within reasonable time, otherwise database can
disable auto-read for the connection.

Author: lutovich

driver/src/test/java/org/neo4j/driver/v1/stress/AbstractStressTestBase.java

@@ -58,6 +58,7 @@
 import org.neo4j.driver.v1.Record;
 import org.neo4j.driver.v1.Session;
 import org.neo4j.driver.v1.StatementResult;
+import org.neo4j.driver.v1.StatementResultCursor;
 import org.neo4j.driver.v1.Transaction;
 import org.neo4j.driver.v1.types.Node;
 import org.neo4j.driver.v1.util.DaemonThreadFactory;
@@ -550,11 +551,11 @@ private static void createNodeInTx( Transaction tx, boolean async, int nodeIndex
 
         if ( async )
         {
-            tx.runAsync( query, params );
+            tx.runAsync( query, params ).thenCompose( StatementResultCursor::consumeAsync );
         }
         else
         {
-            tx.run( query, params );
+            tx.run( query, params ).consume();
         }
     }