(controller)
| 9 | const encoder = new TextEncoder() |
| 10 | return new ReadableStream<Uint8Array>({ |
| 11 | start(controller) { |
| 12 | for (const event of events) { |
| 13 | controller.enqueue(encoder.encode(`data: ${JSON.stringify(event)}\n\n`)) |
| 14 | } |
| 15 | controller.enqueue(encoder.encode('data: [DONE]\n\n')) |
| 16 | controller.close() |
| 17 | }, |
| 18 | }) |
| 19 | } |
| 20 |