nodejs
diff --git a/‎lib/stream/consumers.js‎
Lines changed: 3 additions & 0 deletions b/‎lib/stream/consumers.js‎
Lines changed: 3 additions & 0 deletions
diff --git a/‎test/parallel/test-stream-consumers.js‎
Lines changed: 14 additions & 0 deletions b/‎test/parallel/test-stream-consumers.js‎
Lines changed: 14 additions & 0 deletions
@@ -63,6 +63,9 @@ async function text(stream) {
     else
       str += dec.decode(chunk, { stream: true });
   }
+  // Flush the streaming TextDecoder so that any pending
+  // incomplete multibyte characters are handled.
+  str += dec.decode(undefined, { stream: false });
   return str;
 }
 
 
@@ -232,3 +232,17 @@ const kArrayBuffer =
   stream.write({});
   stream.end({});
 }
+
+{
+  const stream = new TransformStream();
+  text(stream.readable).then(common.mustCall((str) => {
+    // Incomplete utf8 character is flushed as a replacement char
+    assert.strictEqual(str.charCodeAt(0), 0xfffd);
+  }));
+  const writer = stream.writable.getWriter();
+  Promise.all([
+    writer.write(new Uint8Array([0xe2])),
+    writer.write(new Uint8Array([0x82])),
+    writer.close(),
+  ]).then(common.mustCall());
+}
Original file line number	Diff line number	Diff line change
@@ -63,6 +63,9 @@ async function text(stream) {
63	63	else
64	64	str += dec.decode(chunk, { stream: true });
65	65	}
	66	+ // Flush the streaming TextDecoder so that any pending
	67	+ // incomplete multibyte characters are handled.
	68	+ str += dec.decode(undefined, { stream: false });
66	69	return str;
67	70	}
68	71