diff options
Diffstat (limited to 'jstests/change_streams/lookup_post_image.js')
| -rw-r--r-- | jstests/change_streams/lookup_post_image.js | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/jstests/change_streams/lookup_post_image.js b/jstests/change_streams/lookup_post_image.js index ee5d90bf158..0f75ad073e9 100644 --- a/jstests/change_streams/lookup_post_image.js +++ b/jstests/change_streams/lookup_post_image.js @@ -17,7 +17,7 @@ // Test that not specifying 'fullDocument' does include a 'fullDocument' in the result for an // insert. let cursor = cst.startWatchingChanges( - {pipeline: [{$changeStream: {}}], collection: coll, includeTs: true}); + {pipeline: [{$changeStream: {}}], collection: coll, includeToken: true}); assert.writeOK(coll.insert({_id: "fullDocument not specified"})); let latestChange = cst.getOneChange(cursor); assert.eq(latestChange.operationType, "insert"); @@ -45,7 +45,7 @@ cursor = cst.startWatchingChanges({ collection: coll, pipeline: [{$changeStream: {fullDocument: "default"}}], - includeTs: true + includeToken: true }); assert.writeOK(coll.insert({_id: "fullDocument is default"})); latestChange = cst.getOneChange(cursor); @@ -74,7 +74,7 @@ cursor = cst.startWatchingChanges({ collection: coll, pipeline: [{$changeStream: {fullDocument: "updateLookup"}}], - includeTs: true + includeToken: true }); assert.writeOK(coll.insert({_id: "fullDocument is lookup"})); latestChange = cst.getOneChange(cursor); @@ -103,7 +103,7 @@ collection: coll, pipeline: [{$changeStream: {fullDocument: "updateLookup"}}, {$match: {operationType: "update"}}], - includeTs: true + includeToken: true }); assert.writeOK(coll.update({_id: "fullDocument is lookup"}, {$set: {updatedAgain: true}})); assert.writeOK(coll.remove({_id: "fullDocument is lookup"})); |