1
2
3
4
5
6
7
8
9
10
11
12
13
14
| export async function* streamAsyncIterable<T>(stream: ReadableStream<T>) {
| const reader = stream.getReader()
| try {
| while (true) {
| const { done, value } = await reader.read()
| if (done) {
| return
| }
| yield value
| }
| } finally {
| reader.releaseLock()
| }
| }
|
|
