summaryrefslogtreecommitdiff
path: root/jstests/change_streams/error_label.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/change_streams/error_label.js')
-rw-r--r--jstests/change_streams/error_label.js40
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