Upgrade ReadableStream[Symbol.asyncIterator] ponyfill (#128)

Author: ehmicky

package.json

@@ -45,7 +45,7 @@
 		"concat"
 	],
 	"dependencies": {
-		"@sec-ant/readable-stream": "^0.3.2",
+		"@sec-ant/readable-stream": "^0.4.1",
 		"is-stream": "^4.0.1"
 	},
 	"devDependencies": {

source/stream.js

@@ -1,5 +1,5 @@
 import {isReadableStream} from 'is-stream';
-import {ponyfill} from './web-stream.js';
+import {asyncIterator} from '@sec-ant/readable-stream/ponyfill';
 
 export const getAsyncIterable = stream => {
 	if (isReadableStream(stream, {checkOpen: false}) && nodeImports.on !== undefined) {
@@ -12,7 +12,7 @@ export const getAsyncIterable = stream => {
 
 	// `ReadableStream[Symbol.asyncIterator]` support is missing in multiple browsers, so we ponyfill it
 	if (toString.call(stream) === '[object ReadableStream]') {
-		return ponyfill.asyncIterator.call(stream);
+		return asyncIterator.call(stream);
 	}
 
 	throw new TypeError('The first argument must be a Readable, a ReadableStream, or an async iterable.');

source/web-stream.js

@@ -1,21 +1,13 @@
 import {Duplex, Readable} from 'node:stream';
 import {finished} from 'node:stream/promises';
 
+// @todo Use ReadableStream.from() after dropping support for Node 18
+export {fromAnyIterable as readableStreamFrom} from '@sec-ant/readable-stream/ponyfill';
+
 export const createStream = streamDefinition => typeof streamDefinition === 'function'
 	? Duplex.from(streamDefinition)
 	: Readable.from(streamDefinition);
 
-// @todo Use ReadableStream.from() after dropping support for Node 18
-export const readableStreamFrom = chunks => new ReadableStream({
-	start(controller) {
-		for (const chunk of chunks) {
-			controller.enqueue(chunk);
-		}
-
-		controller.close();
-	},
-});
-
 // Tests related to big buffers/strings can be slow. We run them serially and
 // with a higher timeout to ensure they do not randomly fail.
 export const BIG_TEST_DURATION = '2m';