stream: add pipeline test for destroy of returned stream · nodejs/node@0185e3a · GitHub

nodejs / node Public

• Notifications You must be signed in to change notification settings
• Fork 36.6k
• Star 120k

• Code
• Issues 636
• Pull requests 761
• Actions
• Projects
• Security and quality
• Insights

Additional navigation options

Commit 0185e3a

Browse filesBrowse the repository at this point in the historyBrowse files

ronag

authored and

MylesBorins

committed

stream: add pipeline test for destroy of returned stream

Adds a test to ensure that destroying the returned stream of pipeline will cause a premature close error. PR-URL: #32425 Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com>

1 parent b5e4adf commit 0185e3a
Copy full SHA for 0185e3a

1 file changed

+17Lines changed: 17 additions & 0 deletions

File tree

Expand file treeCollapse file tree

Open diff view settings

Filter options

• test/parallel
  • test-stream-pipeline.js

Expand file treeCollapse file tree

Open diff view settings

Collapse file

‎test/parallel/test-stream-pipeline.js‎

Copy file name to clipboardExpand all lines: test/parallel/test-stream-pipeline.js

+17Lines changed: 17 additions & 0 deletions

Original file line number	Diff line number	Diff line change
@@ -1032,3 +1032,20 @@ const { promisify } = require('util');
1032	1032	}));
1033	1033	src.push(null);
1034	1034	}
	1035	+
	1036	+ {
	1037	+ const src = new PassThrough();
	1038	+ const dst = pipeline(
	1039	+ src,
	1040	+ async function * (source) {
	1041	+ for await (const chunk of source) {
	1042	+ yield chunk;
	1043	+ }
	1044	+ },
	1045	+ common.mustCall((err) => {
	1046	+ assert.strictEqual(err.code, 'ERR_STREAM_PREMATURE_CLOSE');
	1047	+ })
	1048	+ );
	1049	+ src.push('asd');
	1050	+ dst.destroy();
	1051	+ }

0 commit comments

Comments

0 (0)