nodejs
diff --git a/Collapse file
‎lib/internal/streams/destroy.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/destroy.js
+2-2Lines changed: 2 additions & 2 deletions b/Collapse file
‎lib/internal/streams/destroy.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/destroy.js
+2-2Lines changed: 2 additions & 2 deletions
diff --git a/Collapse file
‎lib/internal/streams/utils.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/utils.js
+14-8Lines changed: 14 additions & 8 deletions b/Collapse file
‎lib/internal/streams/utils.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/utils.js
+14-8Lines changed: 14 additions & 8 deletions
diff --git a/Collapse file
‎lib/stream.js‎
Copy file name to clipboardExpand all lines: lib/stream.js
+4Lines changed: 4 additions & 0 deletions b/Collapse file
‎lib/stream.js‎
Copy file name to clipboardExpand all lines: lib/stream.js
+4Lines changed: 4 additions & 0 deletions
@@ -11,7 +11,7 @@ const {
   Symbol,
 } = primordials;
 const {
-  kDestroyed,
+  kIsDestroyed,
   isDestroyed,
   isFinished,
   isServerRequest,
@@ -327,7 +327,7 @@ function destroyer(stream, err) {
   }
 
   if (!stream.destroyed) {
-    stream[kDestroyed] = true;
+    stream[kIsDestroyed] = true;
   }
 }
 
 
@@ -1,16 +1,20 @@
 'use strict';
 
 const {
-  Symbol,
   SymbolAsyncIterator,
   SymbolIterator,
   SymbolFor,
 } = primordials;
 
-const kDestroyed = Symbol('kDestroyed');
-const kIsErrored = Symbol('kIsErrored');
-const kIsReadable = Symbol('kIsReadable');
-const kIsDisturbed = Symbol('kIsDisturbed');
+// We need to use SymbolFor to make these globally available
+// for interopt with readable-stream, i.e. readable-stream
+// and node core needs to be able to read/write private state
+// from each other for proper interoperability.
+const kIsDestroyed = SymbolFor('nodejs.stream.destroyed');
+const kIsErrored = SymbolFor('nodejs.stream.errored');
+const kIsReadable = SymbolFor('nodejs.stream.readable');
+const kIsWritable = SymbolFor('nodejs.stream.writable');
+const kIsDisturbed = SymbolFor('nodejs.stream.disturbed');
 
 const kIsClosedPromise = SymbolFor('nodejs.webstream.isClosedPromise');
 const kControllerErrorFunction = SymbolFor('nodejs.webstream.controllerErrorFunction');
@@ -104,7 +108,7 @@ function isDestroyed(stream) {
   const wState = stream._writableState;
   const rState = stream._readableState;
   const state = wState || rState;
-  return !!(stream.destroyed || stream[kDestroyed] || state?.destroyed);
+  return !!(stream.destroyed || stream[kIsDestroyed] || state?.destroyed);
 }
 
 // Have been end():d.
@@ -162,6 +166,7 @@ function isReadable(stream) {
 }
 
 function isWritable(stream) {
+  if (stream && stream[kIsWritable] != null) return stream[kIsWritable];
   if (typeof stream?.writable !== 'boolean') return null;
   if (isDestroyed(stream)) return false;
   return isWritableNodeStream(stream) &&
@@ -298,7 +303,8 @@ function isErrored(stream) {
 }
 
 module.exports = {
-  kDestroyed,
+  isDestroyed,
+  kIsDestroyed,
   isDisturbed,
   kIsDisturbed,
   isErrored,
@@ -307,8 +313,8 @@ module.exports = {
   kIsReadable,
   kIsClosedPromise,
   kControllerErrorFunction,
+  kIsWritable,
   isClosed,
-  isDestroyed,
   isDuplexNodeStream,
   isFinished,
   isIterable,
 
@@ -51,9 +51,13 @@ const promises = require('stream/promises');
 const utils = require('internal/streams/utils');
 
 const Stream = module.exports = require('internal/streams/legacy').Stream;
+
+Stream.isDestroyed = utils.isDestroyed;
 Stream.isDisturbed = utils.isDisturbed;
 Stream.isErrored = utils.isErrored;
 Stream.isReadable = utils.isReadable;
+Stream.isWritable = utils.isWritable;
+
 Stream.Readable = require('internal/streams/readable');
 for (const key of ObjectKeys(streamReturningOperators)) {
   const op = streamReturningOperators[key];
Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@ const {`
`11`	`11`	`Symbol,`
`12`	`12`	`} = primordials;`
`13`	`13`	`const {`
`14`		`- kDestroyed,`
	`14`	`+ kIsDestroyed,`
`15`	`15`	`isDestroyed,`
`16`	`16`	`isFinished,`
`17`	`17`	`isServerRequest,`
`@@ -327,7 +327,7 @@ function destroyer(stream, err) {`
`327`	`327`	`}`
`328`	`328`
`329`	`329`	`if (!stream.destroyed) {`
`330`		`- stream[kDestroyed] = true;`
	`330`	`+ stream[kIsDestroyed] = true;`
`331`	`331`	`}`
`332`	`332`	`}`
`333`	`333`