aboutsummaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-12-28 03:43:39 -0800
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-12-28 03:43:39 -0800
commit3d60b870ee0d206d79eb4dda22dec7da55d91184 (patch)
tree3a1b3bf08cbfe2b1c044cd4e7e5cd56490c38ce5 /test
parent3ae23091c6f69dbf192b8ad89d208403661bd8c3 (diff)
downloadbun-3d60b870ee0d206d79eb4dda22dec7da55d91184.tar.gz
bun-3d60b870ee0d206d79eb4dda22dec7da55d91184.tar.zst
bun-3d60b870ee0d206d79eb4dda22dec7da55d91184.zip
Fix `ReadableStream.pipeTo`
Diffstat (limited to 'test')
-rw-r--r--test/bun.js/streams.test.js18
1 files changed, 18 insertions, 0 deletions
diff --git a/test/bun.js/streams.test.js b/test/bun.js/streams.test.js
index 577570221..ec803a9dd 100644
--- a/test/bun.js/streams.test.js
+++ b/test/bun.js/streams.test.js
@@ -48,6 +48,24 @@ describe("WritableStream", () => {
throw e;
}
});
+
+ it("pipeTo", async () => {
+ const rs = new ReadableStream({
+ start(controller) {
+ controller.enqueue("hello world");
+ controller.close();
+ },
+ });
+
+ let received;
+ const ws = new WritableStream({
+ write(chunk, controller) {
+ received = chunk;
+ },
+ });
+ await rs.pipeTo(ws);
+ expect(received).toBe("hello world");
+ });
});
describe("ReadableStream.prototype.tee", () => {