Skip to content

Commit cda5fe4

Browse files
committed
fix: stream cannot use cursor's next because it reaches exhaustion error in changestream prose test
1 parent 7f024ab commit cda5fe4

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)