(events: TableEventEntry[])
| 66 | } |
| 67 | |
| 68 | const sendEvents = (events: TableEventEntry[]) => { |
| 69 | for (const entry of events) { |
| 70 | if (closed) return |
| 71 | enqueue(`data: ${JSON.stringify(entry)}\n\n`) |
| 72 | lastEventId = entry.eventId |
| 73 | } |
| 74 | } |
| 75 | |
| 76 | const sendPrunedAndClose = (earliestEventId: number | undefined) => { |
| 77 | enqueue( |