Function test

test/integration/change-streams/change_stream.test.ts:174–186

()

  it('should close the listeners after the cursor is closed', {
    metadata: { requires: { topology: 'replicaset' } },
    async test() {
      const collection = db.collection('closesListeners');
      const changeStream = collection.watch(pipeline);
      const willBeChanges = on(changeStream, 'change');
      await once(changeStream.cursor, 'init');
      await collection.insertOne({ a: 1 });

      await willBeChanges.next();
      expect(changeStream.cursorStream?.listenerCount('data')).to.equal(1);

      await changeStream.close();
      expect(changeStream.cursorStream).to.not.exist;
    }
  });

  it('contains a wallTime date property on the change', {