Skip to content

Commit 195bd62

Browse files
committed
fix: stream cannot use cursor's next because it reaches exhaustion error in changestream prose test
1 parent 24b7678 commit 195bd62

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/cursor/abstract_cursor.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -961,7 +961,7 @@ class ReadableCursorStream extends Readable {
961961

962962
private _readNext() {
963963
// eslint-disable-next-line github/no-then
964-
this._cursor.next().then(
964+
next(this._cursor, { blocking: true, transform: true, shift: true }).then(
965965
result => {
966966
if (result == null) {
967967
this.push(null);

0 commit comments

Comments
 (0)