nodejs
diff --git a/‎doc/api/stream.md‎
Lines changed: 28 additions & 0 deletions b/‎doc/api/stream.md‎
Lines changed: 28 additions & 0 deletions
diff --git a/‎lib/internal/streams/destroy.js‎
Lines changed: 1 addition & 0 deletions b/‎lib/internal/streams/destroy.js‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎lib/internal/streams/duplex.js‎
Lines changed: 9 additions & 0 deletions b/‎lib/internal/streams/duplex.js‎
Lines changed: 9 additions & 0 deletions
@@ -1966,6 +1966,34 @@ added: REPLACEME
 
 Returns whether the stream has been read from or cancelled.
 
+### `stream.Duplex.from(src)`
+<!-- YAML
+added: REPLACEME
+-->
+
+* `src` {Stream|Blob|ArrayBuffer|string|Iterable|AsyncIterable|
+  AsyncGeneratorFunction|AsyncFunction|Promise|Object}
+
+A utility method for creating duplex streams.
+
+* `Stream` converts writable stream into writable `Duplex` and readable stream
+  to `Duplex`.
+* `Blob` converts into readable `Duplex`.
+* `string` converts into readable `Duplex`.
+* `ArrayBuffer` converts into readable `Duplex`.
+* `AsyncIterable` converts into a readable `Duplex`. Cannot yield
+  `null`.
+* `AsyncGeneratorFunction` converts into a readable/writable transform
+  `Duplex`. Must take a source `AsyncIterable` as first parameter. Cannot yield
+  `null`.
+* `AsyncFunction` converts into a writable `Duplex`. Must return
+  either `null` or `undefined`
+* `Object ({ writable, readable })` converts `readable` and
+  `writable` into `Stream` and then combines them into `Duplex` where the
+  `Duplex` will write to the `writable` and read from the `readable`.
+* `Promise` converts into readable `Duplex`. Value `null` is ignored.
+* Returns: {stream.Duplex}
+
 ### `stream.addAbortSignal(signal, stream)`
 <!-- YAML
 added: v15.4.0
 
@@ -307,6 +307,7 @@ function isRequest(stream) {
 
 // Normalize destroy for legacy.
 function destroyer(stream, err) {
+  if (!stream) return;
   if (isRequest(stream)) return stream.abort();
   if (isRequest(stream.req)) return stream.req.abort();
   if (typeof stream.destroy === 'function') return stream.destroy(err);
 
@@ -108,3 +108,12 @@ ObjectDefineProperties(Duplex.prototype, {
     }
   }
 });
+
+let duplexify;
+
+Duplex.from = function(body) {
+  if (!duplexify) {
+    duplexify = require('internal/streams/duplexify');
+  }
+  return duplexify(body, 'body');
+};
Original file line number	Diff line number	Diff line change
@@ -108,3 +108,12 @@ ObjectDefineProperties(Duplex.prototype, {
108	108	}
109	109	}
110	110	});
	111	+
	112	+ let duplexify;
	113	+
	114	+ Duplex.from = function(body) {
	115	+ if (!duplexify) {
	116	+ duplexify = require('internal/streams/duplexify');
	117	+ }
	118	+ return duplexify(body, 'body');
	119	+ };