Skip to content

Commit a45349f

Browse files
committed
test: use watch
1 parent f28f64a commit a45349f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

test/types/change_stream.test-d.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
import { expectError, expectType } from 'tsd';
22

33
import type {
4-
ChangeStream,
54
ChangeStreamCollModDocument,
65
ChangeStreamCreateDocument,
76
ChangeStreamCreateIndexDocument,
@@ -219,14 +218,15 @@ expectType<AsyncGenerator<ChangeStreamDocument<Schema>, void, void>>(
219218
);
220219

221220
// Change type returned to user is equivalent across next/tryNext/on/once/addListener
222-
declare let changeStream: ChangeStream<Schema>;
221+
const changeStream = collection.watch();
223222
expectType<ChangeStreamDocument<Schema> | null>(await changeStream.tryNext());
224223
expectType<ChangeStreamDocument<Schema>>(await changeStream.next());
225224
changeStream.on('change', change => expectType<ChangeStreamDocument<Schema>>(change));
226225
changeStream.once('change', change => expectType<ChangeStreamDocument<Schema>>(change));
227226
changeStream.addListener('change', change => expectType<ChangeStreamDocument<Schema>>(change));
228227

229-
declare let changeStreamNoSchema: ChangeStream;
228+
declare const noSchemaCollection: Collection;
229+
const changeStreamNoSchema = noSchemaCollection.watch();
230230
expectType<ChangeStreamDocument<Document> | null>(await changeStreamNoSchema.tryNext());
231231
expectType<ChangeStreamDocument<Document>>(await changeStreamNoSchema.next());
232232
changeStreamNoSchema.on('change', change => expectType<ChangeStreamDocument<Document>>(change));

0 commit comments

Comments
 (0)