({ envelope, payload, chunk, fallbackThreadId })
| 22 | } |
| 23 | |
| 24 | const resolveChunkThreadId = ({ envelope, payload, chunk, fallbackThreadId }) => { |
| 25 | return ( |
| 26 | getThreadIdFromObject(envelope) || |
| 27 | getThreadIdFromObject(payload) || |
| 28 | getThreadIdFromObject(chunk) || |
| 29 | fallbackThreadId |
| 30 | ) |
| 31 | } |
| 32 | |
| 33 | const processRunSseResponse = async (response, onEvent) => { |
| 34 | if (!response || !response.body) return |
no test coverage detected