only discard results that are not consumed yet

Author: transistive

src/Bolt/BoltConnection.php

@@ -45,7 +45,6 @@ final class BoltConnection implements ConnectionInterface
     /** @psalm-readonly */
     private BoltFactory $factory;
 
-    private int $ownerCount = 0;
     private string $serverState = 'DISCONNECTED';
     /** @var list<WeakReference<CypherList>> */
     private array $subscribedResults = [];

src/Bolt/BoltResult.php

@@ -146,7 +146,7 @@ public function rewind(): void
 
     public function __destruct()
     {
-        if (in_array($this->connection->getServerState(), ['STREAMING', 'TX_STREAMING'], true)) {
+        if ($this->valid() && in_array($this->connection->getServerState(), ['STREAMING', 'TX_STREAMING'], true)) {
             $this->discard();
         }
     }

src/Bolt/Session.php

@@ -40,7 +40,7 @@
  */
 final class Session implements SessionInterface
 {
-    /** @psalm-readonly  */
+    /** @psalm-readonly */
     private SessionConfiguration $config;
     /**
      * @psalm-readonly
@@ -56,7 +56,7 @@ final class Session implements SessionInterface
     private FormatterInterface $formatter;
     /** @psalm-readonly */
     private UriInterface $uri;
-    /** @psalm-readonly  */
+    /** @psalm-readonly */
     private AuthenticateInterface $auth;
 
     /**
@@ -164,6 +164,7 @@ private function acquireConnection(TransactionConfiguration $config, SessionConf
         // Since the client should not run indefinitely, we just multiply the client side by two, just in case
         $timeout = $config->getTimeout();
         if ($timeout) {
+            $timeout = ($timeout < 30) ? 30 : $timeout;
             $connection->setTimeout($timeout * 2);
         }