call pull_all immediatly when running neo4j 3

Author: transistive

docker-compose.yml

@@ -60,7 +60,7 @@ services:
     neo4j:
         networks:
             - neo4j
-        image: neo4j:4.4-enterprise
+        image: neo4j:3.5-enterprise
         healthcheck:
             test: "wget -q --method=HEAD http://localhost:7474 || exit 1"
             interval: 30s
@@ -76,7 +76,7 @@ services:
         env_file:
           - .env
     core1:
-        image: neo4j:4.4-enterprise
+        image: neo4j:3.5-enterprise
         healthcheck:
             test: "wget -q --method=HEAD http://localhost:7474 || exit 1"
             interval: 30s
@@ -97,7 +97,7 @@ services:
           - .env
 
     core2:
-        image: neo4j:4.4-enterprise
+        image: neo4j:3.5-enterprise
         healthcheck:
             test: "wget -q --method=HEAD http://localhost:7474 || exit 1"
             interval: 30s
@@ -118,7 +118,7 @@ services:
           - .env
 
     core3:
-        image: neo4j:4.4-enterprise
+        image: neo4j:3.5-enterprise
         healthcheck:
             test: "wget -q --method=HEAD http://localhost:7474 || exit 1"
             interval: 30s
@@ -139,7 +139,7 @@ services:
           - .env
 
     readreplica1:
-        image: neo4j:4.4-enterprise
+        image: neo4j:3.5-enterprise
         healthcheck:
             test: "wget -q --method=HEAD http://localhost:7474 || exit 1"
             interval: 30s

src/Bolt/BoltResult.php

@@ -13,6 +13,7 @@
 
 namespace Laudis\Neo4j\Bolt;
 
+use Laudis\Neo4j\Enum\ConnectionProtocol;
 use function array_key_exists;
 use function array_splice;
 use Bolt\protocol\V4;
@@ -44,6 +45,9 @@ public function __construct(BoltConnection $connection, int $fetchSize, int $qid
         $this->fetchSize = $fetchSize;
         $this->qid = $qid;
         $this->connection->incrementOwner();
+        if ($this->connection->getProtocol() === ConnectionProtocol::BOLT_V3()) {
+            $this->pull();
+        }
     }
 
     public function getFetchSize(): int

tests/Integration/TransactionIntegrationTest.php

@@ -397,4 +397,17 @@ public function testCorrectConnectionReuse(string $alias): void
         /** @psalm-suppress MixedArgument */
         self::assertCount(3, $cache[$key]);
     }
+
+    /**
+     * @dataProvider connectionAliases
+     *
+     * @doesNotPerformAssertions
+     */
+    public function testTransactionRunNoConsumeResult(string $alias): void
+    {
+        $tsx = $this->getClient()->beginTransaction([], $alias);
+        $tsx->run('MATCH (x) RETURN x');
+        $tsx->run('MATCH (x) RETURN x');
+        $tsx->commit();
+    }
 }