refactor: asyncIterator ponyfill API

.changeset/gorgeous-geckos-look.md

@@ -0,0 +1,17 @@
+---
+"@sec-ant/readable-stream": minor
+---
+
+Refactor `asyncIterator` ponyfill API
+
+**BREAKING**: The `asyncIterator` from the ponyfill API is refactored, you should now use it like this:
+
+```ts
+asyncIterator(readableStream);
+```
+
+instead of
+
+```ts
+asyncIterator.call(readableStream);
+```

.github/actions/setup-and-test/action.yml

@@ -7,7 +7,7 @@ runs:
     - name: Setup Node.js
       uses: actions/setup-node@v4
       with:
-        node-version-file: .nvmrc
+        node-version-file: .node-version
 
     - name: Install Dependencies
       shell: bash

.node-version

@@ -0,0 +1 @@
+lts/*

README.md

@@ -53,7 +53,7 @@ import {
 const readableStream = (await fetch("https://www.example.org/")).body;
 
 let total = 0;
-for await (const chunk of asyncIterator.call(readableStream)) {
+for await (const chunk of asyncIterator(readableStream)) {
   total += chunk.length;
 }
 

package.json

@@ -74,21 +74,21 @@
     "bump-biome:nightly": "npm i -DE @biomejs/biome@nightly"
   },
   "devDependencies": {
-    "@biomejs/biome": "1.8.0",
-    "@changesets/cli": "^2.27.5",
+    "@biomejs/biome": "1.8.3",
+    "@changesets/cli": "^2.27.7",
     "@commitlint/cli": "^19.3.0",
     "@commitlint/config-conventional": "^19.2.2",
-    "@vitest/browser": "^1.6.0",
-    "@vitest/coverage-istanbul": "^1.6.0",
-    "@vitest/ui": "^1.6.0",
+    "@vitest/browser": "^2.0.3",
+    "@vitest/coverage-istanbul": "^2.0.3",
+    "@vitest/ui": "^2.0.3",
     "concurrently": "^8.2.2",
-    "copy-files-from-to": "^3.9.1",
-    "lint-staged": "^15.2.5",
-    "playwright": "^1.44.1",
-    "prettier": "^3.3.1",
+    "copy-files-from-to": "^3.11.0",
+    "lint-staged": "^15.2.7",
+    "playwright": "^1.45.2",
+    "prettier": "^3.3.3",
     "simple-git-hooks": "^2.11.1",
-    "typescript": "^5.4.5",
-    "vite": "^5.2.12",
-    "vitest": "^1.6.0"
+    "typescript": "^5.5.3",
+    "vite": "^5.3.4",
+    "vitest": "^2.0.3"
   }
 }

src/core/asyncIterator.ts

@@ -147,15 +147,15 @@ export interface ReadableStreamIteratorOptions {
 
 /**
  * Get an async iterable iterator from a readable stream
- * @param this
+ * @param readableStream
  * @param readableStreamIteratorOptions
  * @returns
  */
 export function asyncIterator<R, TReturn>(
-  this: ReadableStream<R>,
+  readableStream: ReadableStream<R>,
   { preventCancel = false }: ReadableStreamIteratorOptions = {},
 ) {
-  const reader = this.getReader();
+  const reader = readableStream.getReader();
   const implement = new ReadableStreamAsyncIterableIteratorImpl<R, TReturn>(
     reader,
     preventCancel,

src/polyfill/asyncIterator.ts

@@ -4,7 +4,13 @@ import { asyncIterator } from "../core/asyncIterator.js";
 
 ReadableStream.prototype.values ??= ReadableStream.prototype[
   Symbol.asyncIterator
-] ??= asyncIterator;
+] ??= function (
+  ...args: Parameters<typeof asyncIterator> extends [infer _, ...infer T]
+    ? T
+    : never
+) {
+  return asyncIterator(this, ...args);
+};
 
 ReadableStream.prototype[Symbol.asyncIterator] ??=
   ReadableStream.prototype.values;