From d4297ee5537f398398b189ee7c9bdac26e903766 Mon Sep 17 00:00:00 2001 From: "Mickey. J Winters" Date: Tue, 20 Sep 2022 14:18:46 +0000 Subject: SERVER-69785 robustify change_streams_per_shard_cursor.js (cherry-picked from 1219ff764c932f16a68c7ba1afd9b925f9f876c8) --- jstests/noPassthrough/change_streams_per_shard_cursor.js | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/jstests/noPassthrough/change_streams_per_shard_cursor.js b/jstests/noPassthrough/change_streams_per_shard_cursor.js index bece83e65c7..dcd56fc80e9 100644 --- a/jstests/noPassthrough/change_streams_per_shard_cursor.js +++ b/jstests/noPassthrough/change_streams_per_shard_cursor.js @@ -98,7 +98,7 @@ let c = pscWatch(sdb, "coll", shardId); for (let i = 1; i <= 4; i++) { sdb.coll.insertOne({location: 2, i}); assert(!c.isExhausted()); - assert(c.hasNext()); + assert.soon(() => c.hasNext()); c.next(); } assert(!c.hasNext()); @@ -108,12 +108,12 @@ c = pscWatch(sdb, 1, shardId); sdb.coll.insertOne({location: 3}); assert(!c.isExhausted()); -assert(c.hasNext()); +assert.soon(() => c.hasNext()); c.next(); sdb.coll2.insertOne({location: 4}); assert(!c.isExhausted()); -assert(c.hasNext()); +assert.soon(() => c.hasNext()); c.next(); assert(!c.hasNext()); @@ -129,7 +129,7 @@ assert(!c.hasNext()); sdb.toBeCreated.insertOne({location: 8}); assert(!c.isExhausted()); -assert(c.hasNext()); +assert.soon(() => c.hasNext()); c.next(); assert(!c.hasNext()); @@ -164,7 +164,7 @@ c = pscWatch(sdb, "coll", shardId); sdb.coll.insertOne({location: 5, _id: -2}); assert(!c.isExhausted()); -assert(c.hasNext()); +assert.soon(() => c.hasNext()); c.next(); sdb.coll.insertOne({location: 6, _id: 2}); @@ -176,12 +176,12 @@ c = pscWatch(sdb.getSiblingDB("admin"), 1, shardId, {}, {allChangesForCluster: t sdb.coll.insertOne({location: 7, _id: -3}); assert(!c.isExhausted()); -assert(c.hasNext()); +assert.soon(() => c.hasNext()); c.next(); sdb.coll2.insertOne({location: 8, _id: -4}); assert(!c.isExhausted()); -assert(c.hasNext()); +assert.soon(() => c.hasNext()); c.next(); sdb.coll.insertOne({location: 9, _id: 3}); -- cgit v1.2.1