summaryrefslogtreecommitdiff
path: root/jstests/change_streams
diff options
context:
space:
mode:
authorJames Wahlin <james@mongodb.com>2019-03-20 09:36:58 -0400
committerJames Wahlin <james@mongodb.com>2019-03-21 15:22:15 -0400
commite3970d050b4ff6523317616e76c0dc97d87b332e (patch)
treee6c15432104f029f72675f5e8c362a3abe10ead0 /jstests/change_streams
parenta51f50784adaa0c86ace974247d4d0c088152f8e (diff)
downloadmongo-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.js6
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.");