From f9f7140e18c41f49315b953a6ae7294b4c1d446e Mon Sep 17 00:00:00 2001 From: ehmicky Date: Mon, 22 Jul 2024 23:20:13 +0100 Subject: [PATCH] Fix stream-related tests with Node 22.5.0 (#1136) --- test/convert/duplex.js | 10 ++++++---- test/convert/readable.js | 5 +++-- test/convert/writable.js | 5 +++-- 3 files changed, 12 insertions(+), 8 deletions(-) diff --git a/test/convert/duplex.js b/test/convert/duplex.js index 176fa4847d..dd71ce371a 100644 --- a/test/convert/duplex.js +++ b/test/convert/duplex.js @@ -149,11 +149,12 @@ test('.duplex() can pipe to errored stream with Stream.pipeline()', async t => { outputStream.destroy(cause); await assertPromiseError(t, pipeline(inputStream, stream, outputStream), cause); + await t.throwsAsync(finishedStream(stream)); await assertStreamError(t, inputStream, cause); - const error = await assertStreamError(t, stream, {cause}); + const error = await assertStreamError(t, stream, cause); await assertStreamReadError(t, outputStream, cause); - await assertSubprocessError(t, subprocess, error); + await assertSubprocessError(t, subprocess, {cause: error}); }); test('.duplex() can be piped to errored stream with Stream.pipeline()', async t => { @@ -166,11 +167,12 @@ test('.duplex() can be piped to errored stream with Stream.pipeline()', async t inputStream.destroy(cause); await assertPromiseError(t, pipeline(inputStream, stream, outputStream), cause); + await t.throwsAsync(finishedStream(stream)); await assertStreamError(t, inputStream, cause); - const error = await assertStreamError(t, stream, {cause}); + const error = await assertStreamError(t, stream, cause); await assertStreamReadError(t, outputStream, cause); - await assertSubprocessError(t, subprocess, error); + await assertSubprocessError(t, subprocess, {cause: error}); }); test('.duplex() can be used with Stream.compose()', async t => { diff --git a/test/convert/readable.js b/test/convert/readable.js index 465f1c98f9..3b9454cb46 100644 --- a/test/convert/readable.js +++ b/test/convert/readable.js @@ -232,10 +232,11 @@ test('.readable() can pipe to errored stream with Stream.pipeline()', async t => outputStream.destroy(cause); await assertPromiseError(t, pipeline(stream, outputStream), cause); + await t.throwsAsync(finishedStream(stream)); - const error = await assertStreamError(t, stream, {cause}); + const error = await assertStreamError(t, stream, cause); await assertStreamReadError(t, outputStream, cause); - await assertSubprocessError(t, subprocess, error); + await assertSubprocessError(t, subprocess, {cause: error}); }); test('.readable() can be used with Stream.compose()', async t => { diff --git a/test/convert/writable.js b/test/convert/writable.js index 54ae6594f6..8df45fbeb3 100644 --- a/test/convert/writable.js +++ b/test/convert/writable.js @@ -242,10 +242,11 @@ test('.writable() can pipe to errored stream with Stream.pipeline()', async t => inputStream.destroy(cause); await assertPromiseError(t, pipeline(inputStream, stream), cause); + await t.throwsAsync(finishedStream(stream)); await assertStreamError(t, inputStream, cause); - const error = await assertStreamError(t, stream, {cause}); - await assertSubprocessError(t, subprocess, error); + const error = await assertStreamError(t, stream, cause); + await assertSubprocessError(t, subprocess, {cause: error}); }); test('.writable() can be used with Stream.compose()', async t => {