nodejs
diff --git a/‎lib/internal/streams/iter/consumers.js‎
Lines changed: 2 additions & 5 deletions b/‎lib/internal/streams/iter/consumers.js‎
Lines changed: 2 additions & 5 deletions
diff --git a/‎test/parallel/test-stream-iter-consumers-text.js‎
Lines changed: 16 additions & 0 deletions b/‎test/parallel/test-stream-iter-consumers-text.js‎
Lines changed: 16 additions & 0 deletions
@@ -28,7 +28,6 @@ const {
 
 const {
   codes: {
-    ERR_INVALID_ARG_TYPE,
     ERR_INVALID_ARG_VALUE,
     ERR_OUT_OF_RANGE,
   },
@@ -39,6 +38,7 @@ const {
   validateFunction,
   validateInteger,
   validateObject,
+  validateString,
 } = require('internal/validators');
 
 const {
@@ -196,10 +196,7 @@ function validateBaseConsumerOptions(options) {
     validateInteger(options.limit, 'options.limit', 0);
   }
   if (options.encoding !== undefined) {
-    if (typeof options.encoding !== 'string') {
-      throw new ERR_INVALID_ARG_TYPE('options.encoding', 'string',
-                                     options.encoding);
-    }
+    validateString(options.encoding, 'options.encoding');
     try {
       new TextDecoder(options.encoding);
     } catch {
 
@@ -143,6 +143,20 @@ function testTextSyncUnsupportedEncodingThrowsRangeError() {
   );
 }
 
+async function testTextNonStringEncodingThrowsTypeError() {
+  await assert.rejects(
+    () => text(from('hello'), { encoding: 1 }),
+    { code: 'ERR_INVALID_ARG_TYPE' },
+  );
+}
+
+function testTextSyncNonStringEncodingThrowsTypeError() {
+  assert.throws(
+    () => textSync(fromSync('hello'), { encoding: 1 }),
+    { code: 'ERR_INVALID_ARG_TYPE' },
+  );
+}
+
 Promise.all([
   testTextSyncBasic(),
   testTextAsync(),
@@ -159,4 +173,6 @@ Promise.all([
   testTextSyncBOMStripped(),
   testTextUnsupportedEncodingThrowsRangeError(),
   testTextSyncUnsupportedEncodingThrowsRangeError(),
+  testTextNonStringEncodingThrowsTypeError(),
+  testTextSyncNonStringEncodingThrowsTypeError(),
 ]).then(common.mustCall());