diff options
author | Mickey. J Winters <mickey.winters@mongodb.com> | 2022-09-20 14:18:46 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-09-20 14:51:43 +0000 |
commit | d4297ee5537f398398b189ee7c9bdac26e903766 (patch) | |
tree | 283517fb29cd9b9da3aedaa8c88535e135cf496d | |
parent | e8ed64ed0440f576fb0c62d0be61f2f5f0749765 (diff) | |
download | mongo-d4297ee5537f398398b189ee7c9bdac26e903766.tar.gz |
SERVER-69785 robustify change_streams_per_shard_cursor.js
(cherry-picked from 1219ff764c932f16a68c7ba1afd9b925f9f876c8)
-rw-r--r-- | jstests/noPassthrough/change_streams_per_shard_cursor.js | 14 |
1 files 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}); |