[2023/02/22 14:55:32.376]   1) ChangeStream resumability
[2023/02/22 14:55:32.376]        iterator api
[2023/02/22 14:55:32.376]          #next
[2023/02/22 14:55:32.376]            supports consecutive resumes on error code 91 ShutdownInProgress:
[2023/02/22 14:55:32.376]       AssertionError: expected [ CommandStartedEvent{ address: '127.0.0.1:27018', connectionId: 1, serviceId: undefined, requestId: 1365, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': {} } ], cursor: {}, lsid: { id: new Binary(Buffer.from("7d5d84b3d9f54a43b996d69b3ce5187d", "hex"), 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1677077209, i: 3 }), signature: { hash: new Binary(Buffer.from("d64b451679e83887ae4453197e6c357133d35b62", "hex"), 0), keyId: new Long("7202991310255423492") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ address: '127.0.0.1:27018', connectionId: 2, serviceId: undefined, requestId: 1380, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8263F62AD9000000042B0229296E04' } } } ], cursor: {}, lsid: { id: new Binary(Buffer.from("7d5d84b3d9f54a43b996d69b3ce5187d", "hex"), 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1677077218, i: 1 }), signature: { hash: new Binary(Buffer.from("464bc1ad5103ad98a5b1a99e722441592ccbde34", "hex"), 0), keyId: new Long("7202991310255423492") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ address: '127.0.0.1:27018', connectionId: 4, serviceId: undefined, requestId: 1388, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8263F62AE2000000012B0229296E04' } } } ], cursor: {}, lsid: { id: new Binary(Buffer.from("7d5d84b3d9f54a43b996d69b3ce5187d", "hex"), 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1677077228, i: 1 }), signature: { hash: new Binary(Buffer.from("d3f16f6d542c80df837cdbf0656622319cf243e6", "hex"), 0), keyId: new Long("7202991310255423492") } }, '$db': 'resumabilty_tests' } } ] to have a length of 6 but got 3
[2023/02/22 14:55:32.376]       + expected - actual
[2023/02/22 14:55:32.376]       -3
[2023/02/22 14:55:32.376]       +6
[2023/02/22 14:55:32.376]       
[2023/02/22 14:55:32.376]       at Context.<anonymous> (test/integration/change-streams/change_stream.test.ts:1908:45)
[2023/02/22 14:55:32.376]       at runMicrotasks (<anonymous>)
[2023/02/22 14:55:32.376]       at processTicksAndRejections (internal/process/task_queues.js:95:5)

[2023/04/26 21:30:30.694]   1) ChangeStream resumability
[2023/04/26 21:30:30.694]        iterator api
[2023/04/26 21:30:30.694]          #hasNext
[2023/04/26 21:30:30.694]            supports consecutive resumes on error code 91 ShutdownInProgress:
[2023/04/26 21:30:30.694]       AssertionError: expected [ CommandStartedEvent{ name: 'commandStarted', address: '127.0.0.1:27017', connectionId: 1, serviceId: undefined, requestId: 2987, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': {} } ], cursor: {}, lsid: { id: Binary.createFromBase64("9dnHnwFEQXOgejmgsj2cKg==", 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1682544246, i: 8 }), signature: { hash: Binary.createFromBase64("N7UK3NskH3gucofnJk1XSCPuxgo=", 0), keyId: new Long("7226472111211020292") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ name: 'commandStarted', address: '127.0.0.1:27017', connectionId: 2, serviceId: undefined, requestId: 2998, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8264499676000000092B0229296E04' } } } ], cursor: {}, lsid: { id: Binary.createFromBase64("9dnHnwFEQXOgejmgsj2cKg==", 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1682544246, i: 8 }), signature: { hash: Binary.createFromBase64("N7UK3NskH3gucofnJk1XSCPuxgo=", 0), keyId: new Long("7226472111211020292") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ name: 'commandStarted', address: '127.0.0.1:27017', connectionId: 3, serviceId: undefined, requestId: 3006, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8264499676000000092B0229296E04' } } } ], cursor: {}, lsid: { id: Binary.createFromBase64("9dnHnwFEQXOgejmgsj2cKg==", 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1682544246, i: 8 }), signature: { hash: Binary.createFromBase64("N7UK3NskH3gucofnJk1XSCPuxgo=", 0), keyId: new Long("7226472111211020292") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ name: 'commandStarted', address: '127.0.0.1:27017', connectionId: 4, serviceId: undefined, requestId: 3017, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8264499676000000092B0229296E04' } } } ], cursor: {}, lsid: { id: Binary.createFromBase64("9dnHnwFEQXOgejmgsj2cKg==", 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1682544248, i: 1 }), signature: { hash: Binary.createFromBase64("ZZeRjGWAi301W7y+nzm6IAZkx8A=", 0), keyId: new Long("7226472111211020292") } }, '$db': 'resumabilty_tests' } }, CommandStartedEvent{ name: 'commandStarted', address: '127.0.0.1:27017', connectionId: 5, serviceId: undefined, requestId: 3033, databaseName: 'resumabilty_tests', commandName: 'aggregate', command: { aggregate: 'foo', pipeline: [ { '$changeStream': { resumeAfter: { _data: '8264499678000000012B0229296E04' } } } ], cursor: {}, lsid: { id: Binary.createFromBase64("9dnHnwFEQXOgejmgsj2cKg==", 4) }, '$clusterTime': { clusterTime: new Timestamp({ t: 1682544248, i: 2 }), signature: { hash: Binary.createFromBase64("ZZeRjGWAi301W7y+nzm6IAZkx8A=", 0), keyId: new Long("7226472111211020292") } }, '$db': 'resumabilty_tests' } } ] to have a length of 6 but got 5
[2023/04/26 21:30:30.694]       + expected - actual
[2023/04/26 21:30:30.694]       -5
[2023/04/26 21:30:30.694]       +6
[2023/04/26 21:30:30.694]       
[2023/04/26 21:30:30.694]       at Context.<anonymous> (test/integration/change-streams/change_stream.test.ts:2130:45)
[2023/04/26 21:30:30.694]       at runMicrotasks (<anonymous>)
[2023/04/26 21:30:30.694]       at processTicksAndRejections (internal/process/task_queues.js:95:5)