(text: string)
| 57 | let nextHeartbeatAt = Date.now() + HEARTBEAT_INTERVAL_MS |
| 58 | |
| 59 | const enqueue = (text: string) => { |
| 60 | if (closed) return |
| 61 | try { |
| 62 | controller.enqueue(encoder.encode(text)) |
| 63 | } catch { |
| 64 | closed = true |
| 65 | } |
| 66 | } |
| 67 | |
| 68 | const sendEvents = (events: TableEventEntry[]) => { |
| 69 | for (const entry of events) { |
no test coverage detected