()
| 167 | let lastMessageId = '' |
| 168 | |
| 169 | function resetState() { |
| 170 | rawAccumulated = '' |
| 171 | emittedFilteredLength = 0 |
| 172 | lastMessageId = '' |
| 173 | } |
| 174 | |
| 175 | function flushBuffer(): StreamChunk | null { |
| 176 | if (rawAccumulated.length === 0) return null |
no outgoing calls
no test coverage detected