packages/bun-types/tests/streams.test-d.ts


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

new ReadableStream({
  start(controller) {
    controller.enqueue("hello");
    controller.enqueue("world");
    controller.close();
  },
});

new ReadableStream({
  type: "direct",
  pull(controller) {
    controller.write("hello");
    controller.write("world");
    controller.close();
  },
  cancel() {
    // called if stream.cancel() is called
  },
});