fix EventStoreConnectionLogicHandler on closed connection

prooph · Jun 14, 2024 · 3937da5 · 3937da5
1 parent 4d88dbb
commit 3937da5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/Internal/EventStoreConnectionLogicHandler.php b/src/Internal/EventStoreConnectionLogicHandler.php
@@ -13,6 +13,7 @@
 
 namespace Prooph\EventStoreClient\Internal;
 
+use Amp\ByteStream\ClosedException;
 use Amp\DeferredFuture;
 use Closure;
 use Exception;
@@ -174,7 +175,8 @@ function (TcpConnectionErrorMessage $message): void {
             function (TcpConnectionClosedMessage $message): void {
                 $this->tcpConnectionClosed($message->tcpPackageConnection());
 
-                if ($message->exception()) {
+                // if connection was closed, don't throw that exception, we do retry instead
+                if ($message->exception() && ! $message->exception() instanceof ClosedException) {
                     throw $message->exception();
                 }
             }