stream: add fast path for utf8

nodejs · Nov 16, 2022 · e27a518 · e27a518
1 parent 7675749
commit e27a518
Showing 1 changed file with 25 additions and 10 deletions.
diff --git a/lib/internal/webstreams/adapters.js b/lib/internal/webstreams/adapters.js
@@ -54,6 +54,7 @@ const {
 const {
   createDeferredPromise,
   kEmptyObject,
+  normalizeEncoding,
 } = require('internal/util');
 
 const {
@@ -73,6 +74,8 @@ const finished = require('internal/streams/end-of-stream');
 
 const { UV_EOF } = internalBinding('uv');
 
+const encoder = new TextEncoder();
+
 /**
  * @typedef {import('../../stream').Writable} Writable
  * @typedef {import('../../stream').Readable} Readable
@@ -255,11 +258,17 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj
 
     write(chunk, encoding, callback) {
       if (typeof chunk === 'string' && decodeStrings && !objectMode) {
-        chunk = Buffer.from(chunk, encoding);
-        chunk = new Uint8Array(
-          chunk.buffer,
-          chunk.byteOffset,
-          chunk.byteLength);
+        const enc = normalizeEncoding(encoding);
+
+        if (enc === 'utf8') {
+          chunk = encoder.encode(chunk);
+        } else {
+          chunk = Buffer.from(chunk, encoding);
+          chunk = new Uint8Array(
+            chunk.buffer,
+            chunk.byteOffset,
+            chunk.byteLength);
+        }
       }
 
       function done(error) {
@@ -674,11 +683,17 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
 
     write(chunk, encoding, callback) {
       if (typeof chunk === 'string' && decodeStrings && !objectMode) {
-        chunk = Buffer.from(chunk, encoding);
-        chunk = new Uint8Array(
-          chunk.buffer,
-          chunk.byteOffset,
-          chunk.byteLength);
+        const enc = normalizeEncoding(encoding);
+
+        if (enc === 'utf8') {
+          chunk = encoder.encode(chunk);
+        } else {
+          chunk = Buffer.from(chunk, encoding);
+          chunk = new Uint8Array(
+            chunk.buffer,
+            chunk.byteOffset,
+            chunk.byteLength);
+        }
       }
 
       function done(error) {