PHPLIB-433: Check for NonResumableChangeStreamError label

ec96af45 · Jeremy Mikola · 75f0fb80 · ec96af45
Commit ec96af45 authored Jun 21, 2019 by Jeremy Mikola
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

ChangeStream.php src/ChangeStream.php +4 -0

No files found.
--- a/src/ChangeStream.php
+++ b/src/ChangeStream.php
@@ -183,6 +183,10 @@ class ChangeStream implements Iterator
            return false;
        }

+        if ($exception->hasErrorLabel('NonResumableChangeStreamError')) {
+            return false;
+        }
+
        if (in_array($exception->getCode(), [self::$errorCodeCappedPositionLost, self::$errorCodeCursorKilled, self::$errorCodeInterrupted])) {
            return false;
        }