@@ -187,56 +187,6 @@ describe('Change Streams', function () {
187
187
} ) ;
188
188
afterEach ( async ( ) => await mock . cleanup ( ) ) ;
189
189
190
- context ( 'comment tests' , ( ) => {
191
- let client ;
192
- beforeEach ( async function ( ) {
193
- client = await this . configuration . newClient ( { monitorCommands : true } ) . connect ( ) ;
194
- } ) ;
195
-
196
- afterEach ( async function ( ) {
197
- await client . close ( ) ;
198
- } ) ;
199
-
200
- it . only (
201
- 'Test with document comment' ,
202
- {
203
- requires : {
204
- mongodb : '>=4.4.0' ,
205
- topology : '!single'
206
- }
207
- } ,
208
- function ( done ) {
209
- let commandEvents = [ ] ;
210
- const spy = sinon . spy ( client , 'emit' ) ;
211
- client . on ( 'commandSucceeded' , ( ) => { } ) ;
212
- const collection = client . db ( 'test-db' ) . collection ( 'test-collection' ) ;
213
-
214
- withCursor (
215
- collection . watch ( [ ] , { comment : { test : 'name1' } } ) ,
216
- ( cursor , done ) => {
217
- cursor . on ( 'change' , ( ) => console . log ( 'asdf' ) ) ;
218
-
219
- expect ( spy ) . to . have . been . called ( ) ;
220
- expect ( commandEvents ) . to . have . property ( 'length' , 2 ) ;
221
- done ( ) ;
222
- } ,
223
- done
224
- ) ;
225
-
226
- // const changeStream = collection.watch([], { comment: { name: 'test1' } });
227
-
228
- // changeStream.on('change', () => console.log('asdf'));
229
-
230
- // console.error(commandEvents, i);
231
-
232
- // expect(commandEvents).to.have.property('length', 2);
233
-
234
- // client.removeListener(listener);
235
- // changeStream.close();
236
- }
237
- ) ;
238
- } ) ;
239
-
240
190
it ( 'should close the listeners after the cursor is closed' , {
241
191
metadata : { requires : { topology : 'replicaset' , mongodb : '>=3.6' } } ,
242
192
0 commit comments