(stream)
| 414 | }; |
| 415 | |
| 416 | const closeConnection = (stream) => { |
| 417 | if (activeStream && activeStream !== stream) return; |
| 418 | if (closed) return; |
| 419 | closed = true; |
| 420 | flushBuffer(); |
| 421 | postToContentScript({ |
| 422 | type: 'stream-close', |
| 423 | connectionId: connectionId, |
| 424 | timestamp: Date.now() |
| 425 | }); |
| 426 | }; |
| 427 | |
| 428 | const processChunk = (value, stream) => { |
| 429 | if (!value) return; |
no test coverage detected