jstests/libs/change_stream_rewrite_util.js
// Verifies the number of change streams events returned from a particular shard.
Verifies the number of change streams events returned from a particular shard.
Verifies the number of change streams events returned from a particular shard .
function assertNumChangeStreamDocsReturnedFromShard(stats, shardName, expectedTotalReturned) {
    assert(stats.shards.hasOwnProperty(shardName), stats);
    const stages = stats.shards[shardName].stages;
    const lastStage = stages[stages.length - 1];
    assert.eq(lastStage.nReturned, expectedTotalReturned, stages);
}
function assertNumChangeStreamDocsReturnedFromShard ( stats , shardName , expectedTotalReturned ) { assert ( stats . shards . hasOwnProperty ( shardName ) , stats ) ; const stages = stats . shards [ shardName ] . stages ; const lastStage = stages [ stages . length - 1 ] ; assert . eq ( lastStage . nReturned , expectedTotalReturned , stages ) ; }
Verifies the number of change streams events returned from a particular shard.
Verifies the number of change streams events returned from a particular shard .