[2023/02/14 17:26:15.606]   1) ChangeStream resumability
[2023/02/14 17:26:15.606]        iterator api
[2023/02/14 17:26:15.606]          #next
[2023/02/14 17:26:15.606]            supports consecutive resumes on error code 11600 InterruptedAtShutdown:
[2023/02/14 17:26:15.606]       AssertionError: expected [ CommandStartedEvent{ address: '127.0.0.1:27017', connectionId: 1, serviceId: undefined, requestId: 1984, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': {} } ], cursor: {}, lsid: { id: new Binary(Buffer.from("48301e6a0f6c40b0a48102e763f9aced", "hex"), 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1676395109, i: 3 }), signature: { hash: new Binary(Buffer.from("b2b87cb8572e149d8dce26dcd9a33dad47297574", "hex"), 0), keyId: new Long("7200061670113148932") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ address: '127.0.0.1:27017', connectionId: 2, serviceId: undefined, requestId: 1995, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8263EBC265000000042B0229296E04' } } } ], cursor: {}, lsid: { id: new Binary(Buffer.from("48301e6a0f6c40b0a48102e763f9aced", "hex"), 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1676395109, i: 3 }), signature: { hash: new Binary(Buffer.from("b2b87cb8572e149d8dce26dcd9a33dad47297574", "hex"), 0), keyId: new Long("7200061670113148932") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ address: '127.0.0.1:27017', connectionId: 3, serviceId: undefined, requestId: 2005, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8263EBC265000000042B0229296E04' } } } ], cursor: {}, lsid: { id: new Binary(Buffer.from("48301e6a0f6c40b0a48102e763f9aced", "hex"), 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1676395109, i: 3 }), signature: { hash: new Binary(Buffer.from("b2b87cb8572e149d8dce26dcd9a33dad47297574", "hex"), 0), keyId: new Long("7200061670113148932") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ address: '127.0.0.1:27017', connectionId: 4, serviceId: undefined, requestId: 2015, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8263EBC265000000042B0229296E04' } } } ], cursor: {}, lsid: { id: new Binary(Buffer.from("48301e6a0f6c40b0a48102e763f9aced", "hex"), 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1676395109, i: 3 }), signature: { hash: new Binary(Buffer.from("b2b87cb8572e149d8dce26dcd9a33dad47297574", "hex"), 0), keyId: new Long("7200061670113148932") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ address: '127.0.0.1:27017', connectionId: 5, serviceId: undefined, requestId: 2030, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8263EBC265000000042B0229296E04' } } } ], cursor: {}, lsid: { id: new Binary(Buffer.from("48301e6a0f6c40b0a48102e763f9aced", "hex"), 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1676395111, i: 1 }), signature: { hash: new Binary(Buffer.from("ed3fba45221c795d569c18f2c34269d838927d2a", "hex"), 0), keyId: new Long("7200061670113148932") } }, '$db': 'resumabilty_tests' } } ] to have a length of 6 but got 5
[2023/02/14 17:26:15.606]       + expected - actual
[2023/02/14 17:26:15.606]       -5
[2023/02/14 17:26:15.606]       +6
[2023/02/14 17:26:15.606]       
[2023/02/14 17:26:15.606]       at Context.<anonymous> (test/integration/change-streams/change_stream.test.ts:1946:45)
[2023/02/14 17:26:15.606]       at runMicrotasks (<anonymous>)
[2023/02/14 17:26:15.606]       at processTicksAndRejections (internal/process/task_queues.js:97:5)