jstests/noPassthrough/change_stream_resume_before_add_shard.js
// sees the subsequent events in the correct expected order.
sees the subsequent events in the correct expected order.
sees the subsequent events in the correct expected order .
function assertCanResumeFromEachEvent(eventList) {
    for (let i = 0; i < eventList.length; ++i) {
        const resumedStream = coll.watch([], {resumeAfter: eventList[i]._id});
        for (let j = i + 1; j < eventList.length; ++j) {
            assert.soon(() => resumedStream.hasNext());
            assert.docEq(resumedStream.next(), eventList[j]);
        }
        resumedStream.close();
    }
}
function assertCanResumeFromEachEvent ( eventList ) { for ( let i = 0 ; i < eventList . length ; ++ i ) { const resumedStream = coll . watch ( [ ] , { resumeAfter : eventList [ i ] . _id } ) ; for ( let j = i + 1 ; j < eventList . length ; ++ j ) { assert . soon ( ( ) => resumedStream . hasNext ( ) ) ; assert . docEq ( resumedStream . next ( ) , eventList [ j ] ) ; } resumedStream . close ( ) ; } }
sees the subsequent events in the correct expected order.
sees the subsequent events in the correct expected order .