diff --git a/test/integration/change-streams/change_stream.test.ts b/test/integration/change-streams/change_stream.test.ts index aecdbbb7466..000d7ba41b1 100644 --- a/test/integration/change-streams/change_stream.test.ts +++ b/test/integration/change-streams/change_stream.test.ts @@ -826,38 +826,6 @@ describe('Change Streams', function () { } }); - it('when invoked with callbacks', { - metadata: { requires: { topology: 'replicaset' } }, - test: function (done) { - const ops = []; - changeStream.next(() => { - changeStream.next(() => { - ops.push(lastWrite()); - - // explicitly close the change stream after the write has begun - ops.push(changeStream.close()); - - changeStream.next(err => { - try { - expect(err) - .property('message') - .to.match(/ChangeStream is closed/); - Promise.all(ops).then(() => done(), done); - } catch (e) { - done(e); - } - }); - }); - }); - - ops.push( - write().catch(() => { - // ignore - }) - ); - } - }); - it.skip('when invoked using eventEmitter API', { metadata: { requires: { topology: 'replicaset' }