diff options
Diffstat (limited to 'jstests')
| -rw-r--r-- | jstests/libs/change_stream_util.js | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/jstests/libs/change_stream_util.js b/jstests/libs/change_stream_util.js index a78900f3d03..1f44ae43b5c 100644 --- a/jstests/libs/change_stream_util.js +++ b/jstests/libs/change_stream_util.js @@ -243,16 +243,17 @@ function ChangeStreamTest(_db, name = "ChangeStreamTest") { /** * Retrieves the next batch in the change stream and confirms that it is empty. */ - self.assertNoChange = function(cursor) { - cursor = self.getNextBatch(cursor); - assert.eq(0, cursor.nextBatch.length, () => "Cursor had changes: " + tojson(cursor)); + self.assertNoChange = + function(cursor) { + cursor = self.getNextBatch(cursor); + assert.eq(0, cursor.nextBatch.length, () => "Cursor had changes: " + tojson(cursor)); } - /** - * Gets the next document in the change stream. This always executes a 'getMore' first. - * If the current batch has a document in it, that one will be ignored. - */ - self.getOneChange = function(cursor, expectInvalidate = false) { + /** + * Gets the next document in the change stream. This always executes a 'getMore' first. + * If the current batch has a document in it, that one will be ignored. + */ + self.getOneChange = function(cursor, expectInvalidate = false) { changes = self.assertNextChangesEqual({ cursor: cursor, expectedNumChanges: 1, |