Commit de8388dc authored by Jeremy Mikola's avatar Jeremy Mikola

Merge pull request #624

parents 75f0fb80 ec96af45
...@@ -183,6 +183,10 @@ class ChangeStream implements Iterator ...@@ -183,6 +183,10 @@ class ChangeStream implements Iterator
return false; return false;
} }
if ($exception->hasErrorLabel('NonResumableChangeStreamError')) {
return false;
}
if (in_array($exception->getCode(), [self::$errorCodeCappedPositionLost, self::$errorCodeCursorKilled, self::$errorCodeInterrupted])) { if (in_array($exception->getCode(), [self::$errorCodeCappedPositionLost, self::$errorCodeCursorKilled, self::$errorCodeInterrupted])) {
return false; return false;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment