stream: convert premature close to AbortError

AbortError is a more "web" align alternative to
ERR_STREAM_PREMATURE_CLOSE.
PR-URL: #39524
Reviewed-By: Antoine du Hamel <duhamelantoine1995@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>

Author: ronag

lib/internal/webstreams/adapters.js

@@ -50,6 +50,7 @@ const {
 ERR_INVALID_STATE,
 ERR_STREAM_PREMATURE_CLOSE,
 },
+ AbortError,
 }=require('internal/errors');
 
 const{
@@ -120,6 +121,12 @@ function newWritableStreamFromStreamWritable(streamWritable) {
 }
 
 constcleanup=finished(streamWritable,(error)=>{
+if(error?.code==='ERR_STREAM_PREMATURE_CLOSE'){
+consterr=newAbortError();
+err.cause=error;
+error=err;
+}
+
 cleanup();
 // This is a protection against non-standard, legacy streams
 // that happen to emit an error event again after finished is called.
@@ -144,7 +151,7 @@ function newWritableStreamFromStreamWritable(streamWritable) {
 closed=undefined;
 return;
 }
-controller.error(newERR_STREAM_PREMATURE_CLOSE());
+controller.error(newAbortError());
 controller=undefined;
 });
 
@@ -395,6 +402,12 @@ function newReadableStreamFromStreamReadable(streamReadable) {
 streamReadable.pause();
 
 constcleanup=finished(streamReadable,(error)=>{
+if(error?.code==='ERR_STREAM_PREMATURE_CLOSE'){
+consterr=newAbortError();
+err.cause=error;
+error=err;
+}
+
 cleanup();
 // This is a protection against non-standard, legacy streams
 // that happen to emit an error event again after finished is called.

test/parallel/test-whatwg-webstreams-adapters-to-readablestream.js

@@ -59,7 +59,7 @@ const {
 constreader=readableStream.getReader();
 
 assert.rejects(reader.closed,{
-code: 'ERR_STREAM_PREMATURE_CLOSE',
+code: 'ABORT_ERR',
 });
 
 readable.on('end',common.mustNotCall());

test/parallel/test-whatwg-webstreams-adapters-to-readablewritablepair.js

@@ -27,11 +27,11 @@ const {
 constwriter=writable.getWriter();
 
 assert.rejects(reader.closed,{
-code: 'ERR_STREAM_PREMATURE_CLOSE',
+code: 'ABORT_ERR',
 });
 
 assert.rejects(writer.closed,{
-code: 'ERR_STREAM_PREMATURE_CLOSE',
+code: 'ABORT_ERR',
 });
 
 duplex.destroy();
@@ -165,7 +165,7 @@ const {
 
 reader.closed.then(common.mustCall());
 assert.rejects(writer.closed,{
-code: 'ERR_STREAM_PREMATURE_CLOSE',
+code: 'ABORT_ERR',
 });
 
 duplex.end();

test/parallel/test-whatwg-webstreams-adapters-to-writablestream.js

@@ -92,7 +92,7 @@ class TestWritable extends Writable {
 constwritableStream=newWritableStreamFromStreamWritable(writable);
 
 assert.rejects(writableStream.close(),{
-code: 'ERR_STREAM_PREMATURE_CLOSE'
+code: 'ABORT_ERR'
 });
 
 writable.end();