@@ -94,14 +94,14 @@ maybeDescribe('examples(change-stream):', function () {
94
94
95
95
// Start Changestream Example 2
96
96
const collection = db . collection ( 'inventory' ) ;
97
- const changeStream = collection . watch ( { fullDocument : 'updateLookup' } ) ;
97
+ const changeStream = collection . watch ( [ ] , { fullDocument : 'updateLookup' } ) ;
98
98
changeStream . on ( 'change' , next => {
99
99
// process next document
100
100
} ) ;
101
101
// End Changestream Example 2
102
102
103
103
// Start Changestream Example 2 Alternative
104
- const changeStreamIterator = collection . watch ( { fullDocument : 'updateLookup' } ) ;
104
+ const changeStreamIterator = collection . watch ( [ ] , { fullDocument : 'updateLookup' } ) ;
105
105
const next = await changeStreamIterator . next ( ) ;
106
106
// End Changestream Example 2 Alternative
107
107
@@ -137,7 +137,7 @@ maybeDescribe('examples(change-stream):', function () {
137
137
const resumeToken = changeStream . resumeToken ;
138
138
changeStream . close ( ) ;
139
139
140
- newChangeStream = collection . watch ( { resumeAfter : resumeToken } ) ;
140
+ newChangeStream = collection . watch ( [ ] , { resumeAfter : resumeToken } ) ;
141
141
newChangeStream . on ( 'change' , next => {
142
142
processChange ( next ) ;
143
143
} ) ;
@@ -151,7 +151,7 @@ maybeDescribe('examples(change-stream):', function () {
151
151
const resumeToken = changeStreamIterator . resumeToken ;
152
152
changeStreamIterator . close ( ) ;
153
153
154
- const newChangeStreamIterator = collection . watch ( { resumeAfter : resumeToken } ) ;
154
+ const newChangeStreamIterator = collection . watch ( [ ] , { resumeAfter : resumeToken } ) ;
155
155
const change2 = await newChangeStreamIterator . next ( ) ;
156
156
// End Changestream Example 3 Alternative
157
157
0 commit comments