fix: add start stream on pipe

generators/typescript/sdk/CHANGELOG.md

@@ -5,6 +5,10 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.36.3] - 2024-07-26
+
+- Fix: Support starting the stream on `StreamWrapper.pipe(...)` for shorter syntax when dealing with `node:stream` primitives.
+
 ## [0.36.2] - 2024-07-26
 
 - Fix: This release comes with numerous improvements to streaming responses:

generators/typescript/sdk/VERSION

@@ -1 +1 @@
-0.36.2
+0.36.3

generators/typescript/utils/core-utilities/fetcher/src/fetcher/stream-wrappers/Node18UniversalStreamWrapper.ts

@@ -73,6 +73,8 @@ export class Node18UniversalStreamWrapper
             }
         });
 
+        this._startReading();
+
         return dest;
     }
 
@@ -197,4 +199,28 @@ export class Node18UniversalStreamWrapper
             }
         }
     }
+
+    private async _startReading(): Promise<void> {
+        try {
+            this._emit("readable");
+            while (true) {
+                if (this.paused) {
+                    await new Promise((resolve) => {
+                        this.resumeCallback = resolve;
+                    });
+                }
+                const { done, value } = await this.reader.read();
+                if (done) {
+                    this._emit("end");
+                    this._emit("close");
+                    break;
+                }
+                if (value) {
+                    this._emit("data", value);
+                }
+            }
+        } catch (error) {
+            this._emit("error", error);
+        }
+    }
 }

generators/typescript/utils/core-utilities/fetcher/src/fetcher/stream-wrappers/UndiciStreamWrapper.ts

@@ -67,6 +67,8 @@ export class UndiciStreamWrapper
             }
         });
 
+        this._startReading();
+
         return dest;
     }
 
@@ -184,4 +186,28 @@ export class UndiciStreamWrapper
             }
         }
     }
+
+    private async _startReading(): Promise<void> {
+        try {
+            this._emit("readable");
+            while (true) {
+                if (this.paused) {
+                    await new Promise((resolve) => {
+                        this.resumeCallback = resolve;
+                    });
+                }
+                const { done, value } = await this.reader.read();
+                if (done) {
+                    this._emit("end");
+                    this._emit("close");
+                    break;
+                }
+                if (value) {
+                    this._emit("data", value);
+                }
+            }
+        } catch (error) {
+            this._emit("error", error);
+        }
+    }
 }

scripts/browser-startup-test.sh

@@ -46,7 +46,6 @@ echo "DISABLE_ESLINT_PLUGIN=true" >> .env
 
 npm install
 output=$(timeout 25s npm run start &)
-sleep 30
 echo "$output"
 if echo "$output" | grep -q "Compiled successfully!"; then
     echo "Compiled successfully"
@@ -55,5 +54,4 @@ else
     exit 1
 fi
 cd ../../..
-pwd
 rm -rf browser-test

scripts/cloudflare-startup-test.sh

@@ -47,8 +47,7 @@ export default {
         return new Response("Hello World!");
     },
 };' > src/index.ts
-output=$(timeout 1s wrangler dev &)
-sleep 1
+output=$(timeout 5s wrangler dev &)
 echo "$output"
 if echo "$output" | grep -q "SeedApiClient import was successful"; then
     echo "Compiled successfully"