Function read

test/integration/change-streams/change_stream.test.ts:882–895

()

      metadata: { requires: { topology: '!single' } },
      test: async function () {
        const read = async () => {
          await changeStream.next();
          await changeStream.next();

          const write = lastWrite();

          const nextP = changeStream.next();
          nextP.catch(() => null);

          await changeStream.close();

          await write;
          await nextP;
        };

        const error = await Promise.all([read(), write()]).then(
          () => null,