test: add regression test for 51586

mcollina · RafaelGSS · commit 1b8bba8aee49 · 2024-01-19T16:06:05.000-03:00
Signed-off-by: Matteo Collina <hello@matteocollina.com> PR-URL: #51491 Reviewed-By: Vinícius Lourenço Claro Cardoso <contact@viniciusl.com.br> Reviewed-By: Marco Ippolito <marcoippolito54@gmail.com> Reviewed-By: Matthew Aitken <maitken033380023@gmail.com> Reviewed-By: Rafael Gonzaga <rafael.nunu@hotmail.com> Reviewed-By: Moshe Atlow <moshe@atlow.co.il> Reviewed-By: Franziska Hinkelmann <franziska.hinkelmann@gmail.com> Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
diff --git a/test/parallel/test-webstream-structured-clone-no-leftovers.mjs b/test/parallel/test-webstream-structured-clone-no-leftovers.mjs
@@ -0,0 +1,28 @@
+import '../common/index.mjs';
+import { test } from 'node:test';
+import assert from 'node:assert';
+
+test('do not leak promises', async () => {
+ const buf = new Uint8Array(1);
+ const readable = new ReadableStream({
+ start(controller) {
+ controller.enqueue(buf);
+ controller.close();
+ }
+ });
+
+ const [out1, out2] = readable.tee();
+ const cloned = structuredClone(out2, { transfer: [out2] });
+
+ for await (const chunk of cloned) {
+ assert.deepStrictEqual(chunk, buf);
+ }
+
+ for await (const chunk of out2) {
+ assert.deepStrictEqual(chunk, buf);
+ }
+
+ for await (const chunk of out1) {
+ assert.deepStrictEqual(chunk, buf);
+ }
+});

-Original file line number
+Diff line change
@@ @@ -0,0 +1,28 @@ @@
 +import'../common/index.mjs';
 +import{test}from'node:test';
 +importassertfrom'node:assert';
++
 +test('do not leak promises',async()=>{
 +constbuf=newUint8Array(1);
 +constreadable=newReadableStream({
 +start(controller){
 +controller.enqueue(buf);
 +controller.close();
 +}
 +});
++
 +const[out1,out2]=readable.tee();
 +constcloned=structuredClone(out2,{transfer: [out2]});
++
 +forawait(constchunkofcloned){
 +assert.deepStrictEqual(chunk,buf);
 +}
++
 +forawait(constchunkofout2){
 +assert.deepStrictEqual(chunk,buf);
 +}
++
 +forawait(constchunkofout1){
 +assert.deepStrictEqual(chunk,buf);
 +}
 +});