New version: 3.4.1 (not published yet).

Author: uhop

.clinerules

@@ -43,6 +43,7 @@ stream-chain creates a chain of streams out of regular functions, asynchronous f
 - `npm run test:deno` — run with Deno
 - `npm run test:seq` — run sequentially (also `test:seq:bun`, `test:seq:deno`)
 - `npm run ts-check` — TypeScript type checking
+- `npm run ts-test` — TypeScript tests (also `ts-test:bun`, `ts-test:deno`)
 - `npm run lint` — Prettier check
 - `npm run lint:fix` — Prettier write
 

.cursorrules

@@ -43,6 +43,7 @@ stream-chain creates a chain of streams out of regular functions, asynchronous f
 - `npm run test:deno` — run with Deno
 - `npm run test:seq` — run sequentially (also `test:seq:bun`, `test:seq:deno`)
 - `npm run ts-check` — TypeScript type checking
+- `npm run ts-test` — TypeScript tests (also `ts-test:bun`, `ts-test:deno`)
 - `npm run lint` — Prettier check
 - `npm run lint:fix` — Prettier write
 

.github/dependabot.yml

@@ -5,7 +5,7 @@
 
 version: 2
 updates:
-  - package-ecosystem: "npm" # See documentation for possible values
-    directory: "/" # Location of package manifests
+  - package-ecosystem: 'npm' # See documentation for possible values
+    directory: '/' # Location of package manifests
     schedule:
-      interval: "weekly"
+      interval: 'weekly'

.github/workflows/tests.yml

@@ -22,16 +22,16 @@ jobs:
         node-version: [20, 22, 24, 25]
 
     steps:
-    - uses: actions/checkout@v4
-      # with:
-      #   submodules: true
-    - name: Setup Node.js ${{matrix.node-version}}
-      uses: actions/setup-node@v4
-      with:
-        node-version: ${{matrix.node-version}}
-    - name: Install the package and run tests
-      run: |
-        npm ci
-        npm run build --if-present
-        npm test
-        npm run ts-check --if-present
+      - uses: actions/checkout@v4
+        # with:
+        #   submodules: true
+      - name: Setup Node.js ${{matrix.node-version}}
+        uses: actions/setup-node@v4
+        with:
+          node-version: ${{matrix.node-version}}
+      - name: Install the package and run tests
+        run: |
+          npm ci
+          npm run build --if-present
+          npm test
+          npm run ts-check --if-present

.vscode/settings.json

@@ -1,7 +1,3 @@
 {
-  "cSpell.words": [
-    "backpressure",
-    "streamable",
-    "unbundling"
-  ]
+  "cSpell.words": ["backpressure", "streamable", "unbundling"]
 }

.windsurfrules

@@ -43,6 +43,7 @@ stream-chain creates a chain of streams out of regular functions, asynchronous f
 - `npm run test:deno` — run with Deno
 - `npm run test:seq` — run sequentially (also `test:seq:bun`, `test:seq:deno`)
 - `npm run ts-check` — TypeScript type checking
+- `npm run ts-test` — TypeScript tests (also `ts-test:bun`, `ts-test:deno`)
 - `npm run lint` — Prettier check
 - `npm run lint:fix` — Prettier write
 

AGENTS.md

@@ -24,6 +24,7 @@ npm install
 - **Test (sequential):** `npm run test:seq` (also `test:seq:bun`, `test:seq:deno`)
 - **Test (single file):** `node tests/test-<name>.mjs`
 - **TypeScript check:** `npm run ts-check`
+- **TypeScript tests:** `npm run ts-test` (also `ts-test:bun`, `ts-test:deno`)
 - **Lint:** `npm run lint` (Prettier check)
 - **Lint fix:** `npm run lint:fix` (Prettier write)
 
@@ -76,7 +77,7 @@ stream-chain/
 - **Prettier** for formatting (see `.prettierrc`): 100 char width, single quotes, no bracket spacing, no trailing commas, arrow parens "avoid".
 - 2-space indentation.
 - Semicolons are enforced by Prettier (default `semi: true`).
-- Imports use `require()` syntax in source, `import` in tests (`.mjs`).
+- Imports use `require()` syntax in source, `import` in tests (`.mjs`/`.mts`).
 - The package is `stream-chain`. Internal symbols use `Symbol.for('object-stream.*')`.
 
 ## Critical rules

ARCHITECTURE.md

@@ -63,18 +63,19 @@ wiki/                     # GitHub wiki documentation (git submodule)
 
 Functions in a chain can return special values to control flow:
 
-| Value | Symbol | Effect |
-|-------|--------|--------|
-| `none` | `object-stream.none` | Skip — no value passed downstream |
-| `null`/`undefined` | — | Same as `none` |
-| `stop` | `object-stream.stop` | Skip and terminate the generator (gen/fun only) |
-| `many(values)` | `object-stream.many` | Emit multiple values from a single input |
+| Value               | Symbol                | Effect                                                         |
+| ------------------- | --------------------- | -------------------------------------------------------------- |
+| `none`              | `object-stream.none`  | Skip — no value passed downstream                              |
+| `null`/`undefined`  | —                     | Same as `none`                                                 |
+| `stop`              | `object-stream.stop`  | Skip and terminate the generator (gen/fun only)                |
+| `many(values)`      | `object-stream.many`  | Emit multiple values from a single input                       |
 | `finalValue(value)` | `object-stream.final` | Skip remaining chain steps, emit value directly (gen/fun only) |
-| `flushable(fn)` | `object-stream.flush` | Mark function to be called at stream end with `none` |
+| `flushable(fn)`     | `object-stream.flush` | Mark function to be called at stream end with `none`           |
 
 ### gen() — async generator pipeline
 
 `gen(...fns)` takes multiple functions and returns a single async generator function that:
+
 1. Processes each input value through the function pipeline sequentially.
 2. Handles all special return values (`none`, `stop`, `many`, `finalValue`).
 3. Supports regular, async, generator, and async generator functions.
@@ -92,6 +93,7 @@ Functions in a chain can return special values to control flow:
 ### Stream detection
 
 `chain()` detects stream types to decide how to integrate them:
+
 - **Node streams**: `isReadableNodeStream`, `isWritableNodeStream`, `isDuplexNodeStream`
 - **Web streams**: `isReadableWebStream`, `isWritableWebStream`, `isDuplexWebStream`
 - Web streams are adapted to Node streams via `Readable.fromWeb()`, `Writable.fromWeb()`, `Duplex.fromWeb()`.
@@ -138,6 +140,7 @@ src/utils/* ── src/defs.js (most utilities use none, stop, many, flushable)
 - **Run with Deno**: `npm run test:deno`
 - **Run sequential**: `npm run test:seq` (also `test:seq:bun`, `test:seq:deno`)
 - **TypeScript check**: `npm run ts-check`
+- **TypeScript tests**: `npm run ts-test` (also `ts-test:bun`, `ts-test:deno`)
 - **Lint**: `npm run lint` (Prettier check)
 - **Lint fix**: `npm run lint:fix` (Prettier write)