(controller)
| 50 | const createMockStream = () => { |
| 51 | return new ReadableStream({ |
| 52 | start(controller) { |
| 53 | controller.enqueue( |
| 54 | new TextEncoder().encode('data: {"blockId":"agent-1","chunk":"Hello"}\n\n') |
| 55 | ) |
| 56 | controller.enqueue( |
| 57 | new TextEncoder().encode('data: {"blockId":"agent-1","chunk":" world"}\n\n') |
| 58 | ) |
| 59 | controller.enqueue( |
| 60 | new TextEncoder().encode('data: {"event":"final","data":{"success":true}}\n\n') |
| 61 | ) |
| 62 | controller.close() |
| 63 | }, |
| 64 | }) |
| 65 | } |
| 66 |