diff options
Diffstat (limited to 'jstests/change_streams/error_label.js')
-rw-r--r-- | jstests/change_streams/error_label.js | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/jstests/change_streams/error_label.js b/jstests/change_streams/error_label.js index 1c9a00db356..93a8e569d25 100644 --- a/jstests/change_streams/error_label.js +++ b/jstests/change_streams/error_label.js @@ -4,30 +4,30 @@ */ (function() { - "use strict"; +"use strict"; - load("jstests/libs/collection_drop_recreate.js"); // For assertDropAndRecreateCollection. +load("jstests/libs/collection_drop_recreate.js"); // For assertDropAndRecreateCollection. - // Drop and recreate the collections to be used in this set of tests. - const coll = assertDropAndRecreateCollection(db, "change_stream_error_label"); +// Drop and recreate the collections to be used in this set of tests. +const coll = assertDropAndRecreateCollection(db, "change_stream_error_label"); - // Attaching a projection to the Change Stream that filters out the resume token (stored in the - // _id field) guarantees a ChangeStreamFatalError as soon as we get the first change. - const changeStream = coll.watch([{$project: {_id: 0}}], {batchSize: 1}); - assert.commandWorked(coll.insert({a: 1})); +// Attaching a projection to the Change Stream that filters out the resume token (stored in the +// _id field) guarantees a ChangeStreamFatalError as soon as we get the first change. +const changeStream = coll.watch([{$project: {_id: 0}}], {batchSize: 1}); +assert.commandWorked(coll.insert({a: 1})); - const err = assert.throws(function() { - // Call hasNext() until it throws an error or unexpectedly returns true. We need the - // assert.soon() to keep trying here, because the above insert command isn't immediately - // observable to the change stream in sharded configurations. - assert.soon(function() { - return changeStream.hasNext(); - }); +const err = assert.throws(function() { + // Call hasNext() until it throws an error or unexpectedly returns true. We need the + // assert.soon() to keep trying here, because the above insert command isn't immediately + // observable to the change stream in sharded configurations. + assert.soon(function() { + return changeStream.hasNext(); }); +}); - // The hasNext() sends a getMore command, which should generate a ChangeStreamFatalError reply - // that includes the NonResumableChangeStreamError errorLabel. - assert.commandFailedWithCode(err, ErrorCodes.ChangeStreamFatalError); - assert("errorLabels" in err, err); - assert.contains("NonResumableChangeStreamError", err.errorLabels, err); +// The hasNext() sends a getMore command, which should generate a ChangeStreamFatalError reply +// that includes the NonResumableChangeStreamError errorLabel. +assert.commandFailedWithCode(err, ErrorCodes.ChangeStreamFatalError); +assert("errorLabels" in err, err); +assert.contains("NonResumableChangeStreamError", err.errorLabels, err); }());
\ No newline at end of file |