diff options
author | James Wahlin <james@mongodb.com> | 2019-03-20 09:36:58 -0400 |
---|---|---|
committer | James Wahlin <james@mongodb.com> | 2019-03-21 15:22:15 -0400 |
commit | e3970d050b4ff6523317616e76c0dc97d87b332e (patch) | |
tree | e6c15432104f029f72675f5e8c362a3abe10ead0 /jstests/change_streams | |
parent | a51f50784adaa0c86ace974247d4d0c088152f8e (diff) | |
download | mongo-e3970d050b4ff6523317616e76c0dc97d87b332e.tar.gz |
SERVER-39678 Comprehensive test for resuming a Change Stream with prepared transactions
Diffstat (limited to 'jstests/change_streams')
-rw-r--r-- | jstests/change_streams/change_stream.js | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/jstests/change_streams/change_stream.js b/jstests/change_streams/change_stream.js index 9f41255c599..396504f2439 100644 --- a/jstests/change_streams/change_stream.js +++ b/jstests/change_streams/change_stream.js @@ -186,7 +186,7 @@ cursor = cst.startWatchingChanges({pipeline: [{$changeStream: {}}], collection: db.t1}); let t2cursor = cst.startWatchingChanges({pipeline: [{$changeStream: {}}], collection: db.t2}); assert.writeOK(db.t2.insert({_id: 100, c: 1})); - cst.assertNextChangesEqual({cursor: cursor, expectedChanges: []}); + cst.assertNoChange(cursor); expected = { documentKey: {_id: 100}, fullDocument: {_id: 100, c: 1}, @@ -208,8 +208,8 @@ const dne2cursor = cst.startWatchingChanges({pipeline: [{$changeStream: {}}], collection: db.dne2}); assert.writeOK(db.t2.insert({_id: 101, renameCollection: "test.dne1", to: "test.dne2"})); - cst.assertNextChangesEqual({cursor: dne1cursor, expectedChanges: []}); - cst.assertNextChangesEqual({cursor: dne2cursor, expectedChanges: []}); + cst.assertNoChange(dne1cursor); + cst.assertNoChange(dne2cursor); if (!isMongos) { jsTestLog("Ensuring attempt to read with legacy operations fails."); |