We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
ChangeStream.bufferedCount
1 parent cfb0bbd commit e2b76faCopy full SHA for e2b76fa
1 file changed
src/change_stream.ts
@@ -705,6 +705,11 @@ export class ChangeStream<
705
return this.cursor?.resumeToken;
706
}
707
708
+ /** Returns the currently buffered documents length of the underlying cursor. */
709
+ get bufferedCount(): number | undefined {
710
+ return this.cursor?.bufferedCount();
711
+ }
712
+
713
/** Check if there is any document still available in the Change Stream */
714
async hasNext(): Promise<boolean> {
715
this._setIsIterator();
0 commit comments