PHPLIB-1489 Address CursorId in ChangeStream

GromNaN · GromNaN · commit 20870103c67e · 2024-09-18T11:55:33.000+02:00
diff --git a/src/ChangeStream.php b/src/ChangeStream.php
@@ -261,7 +261,7 @@ private function onIteration(bool $incrementKey): void
          * have been received in the last response. Therefore, we can unset the
          * resumeCallable. This will free any reference to Watch as well as the
          * only reference to any implicit session created therein. */
-        if ((string) $this->getCursorId() === '0') {
+        if ((string) $this->getCursorId(true) === '0') {
             $this->resumeCallable = null;
         }
 

Original file line number	Diff line number	Diff line change
`@@ -261,7 +261,7 @@ private function onIteration(bool $incrementKey): void`
`261`	`261`	`* have been received in the last response. Therefore, we can unset the`
`262`	`262`	`* resumeCallable. This will free any reference to Watch as well as the`
`263`	`263`	`* only reference to any implicit session created therein. */`
`264`		`- if ((string) $this->getCursorId() === '0') {`
	`264`	`+ if ((string) $this->getCursorId(true) === '0') {`
`265`	`265`	`$this->resumeCallable = null;`
`266`	`266`	`}`
`267`	`267`