chore: fix closed

nbbeeken · nbbeeken · commit 3004589745f1 · 2024-12-11T15:12:09.000-05:00
diff --git a/src/change_stream.ts b/src/change_stream.ts
@@ -794,7 +794,7 @@ export class ChangeStream<
   }
 
   async *[Symbol.asyncIterator](): AsyncGenerator<TChange, void, void> {
-    if (this.isClosed) {
+    if (this.closed) {
       return;
     }
 
@@ -843,7 +843,7 @@ export class ChangeStream<
    * @throws MongoChangeStreamError if the underlying cursor or the change stream is closed
    */
   stream(options?: CursorStreamOptions): Readable & AsyncIterable<TChange> {
-    if (this.isClosed) {
+    if (this.closed) {
       throw new MongoChangeStreamError(CHANGESTREAM_CLOSED_ERROR);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -794,7 +794,7 @@ export class ChangeStream<`
`794`	`794`	`}`
`795`	`795`
`796`	`796`	`async *[Symbol.asyncIterator](): AsyncGenerator<TChange, void, void> {`
`797`		`- if (this.isClosed) {`
	`797`	`+ if (this.closed) {`
`798`	`798`	`return;`
`799`	`799`	`}`
`800`	`800`
`@@ -843,7 +843,7 @@ export class ChangeStream<`
`843`	`843`	`* @throws MongoChangeStreamError if the underlying cursor or the change stream is closed`
`844`	`844`	`*/`
`845`	`845`	`stream(options?: CursorStreamOptions): Readable & AsyncIterable<TChange> {`
`846`		`- if (this.isClosed) {`
	`846`	`+ if (this.closed) {`
`847`	`847`	`throw new MongoChangeStreamError(CHANGESTREAM_CLOSED_ERROR);`
`848`	`848`	`}`
`849`	`849`