()
| 6 | // Create a Readable stream that emits the SSE lines |
| 7 | const stream = new Readable({ |
| 8 | read() { |
| 9 | for (const line of sseLines) { |
| 10 | this.push(line + "\n\n"); |
| 11 | } |
| 12 | this.push(null); // End of stream |
| 13 | }, |
| 14 | }) as any; |
| 15 | |
| 16 | // Minimal Response mock |