fix(stream): Fix Readable.pipe() (#1606)

* fix(stream): fix some debug logs that were breaking .pipe

* fix(stream): another debug fix

* test(stream): add test for .pipe

1 files changed, 27 insertions, 1 deletions

diff --git a/test/bun.js/node-stream.test.js b/test/bun.js/node-stream.test.js
index 8024ab562..549f7c180 100644
--- a/test/bun.js/node-stream.test.js
+++ b/test/bun.js/node-stream.test.js
@@ -1,5 +1,31 @@
 import { expect, describe, it } from "bun:test";
-import { Duplex, Transform, PassThrough } from "node:stream";
+import {
+  Readable,
+  Writable,
+  Duplex,
+  Transform,
+  PassThrough,
+} from "node:stream";
+
+describe("Readable", () => {
+  it("should be able to be piped via .pipe", () => {
+    const readable = new Readable({
+      _read() {
+        this.push("Hello World!");
+        this.push(null);
+      },
+    });
+
+    const writable = new Writable({
+      _write(chunk, encoding, callback) {
+        expect(chunk.toString()).toBe("Hello World!");
+        callback();
+      },
+    });
+
+    readable.pipe(writable);
+  });
+});
 
 describe("Duplex", () => {
   it("should allow subclasses to be derived via .call() on class", () => {