(controller)
| 19 | it.concurrent('should return original stream when no response format selection', async () => { |
| 20 | const mockStream = new ReadableStream({ |
| 21 | start(controller) { |
| 22 | controller.enqueue(new TextEncoder().encode('{"content": "test"}')) |
| 23 | controller.close() |
| 24 | }, |
| 25 | }) |
| 26 | |
| 27 | const result = processor.processStream( |