( events: Array<OpencodeStreamEvent>, )
| 24 | } |
| 25 | |
| 26 | async function* fromArray( |
| 27 | events: Array<OpencodeStreamEvent>, |
| 28 | ): AsyncIterable<OpencodeStreamEvent> { |
| 29 | for (const event of events) yield event |
| 30 | } |
| 31 | |
| 32 | async function collect( |
| 33 | events: Array<OpencodeStreamEvent>, |