Catch Throwable instead of Exception

voryx · Mar 6, 2022 · 078c9ca · 078c9ca
1 parent 20563df
commit 078c9ca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Client.php b/src/Client.php
@@ -204,7 +204,7 @@ public function _reconnect(Observable $attempts)
         $maxRetries        = 150;
 
         return $attempts
-            ->flatMap(function (\Exception $ex) use ($maxRetryDelay, $retryDelayGrowth, $initialRetryDelay) {
+            ->flatMap(function (\Throwable $ex) use ($maxRetryDelay, $retryDelayGrowth, $initialRetryDelay) {
                 $delay   = min($maxRetryDelay, pow($retryDelayGrowth, ++$this->currentRetryCount) + $initialRetryDelay);
                 $seconds = number_format((float)$delay / 1000, 3, '.', '');
                 echo 'Error: ', $ex->getMessage(), PHP_EOL, "Reconnecting in ${seconds} seconds...", PHP_EOL;