({ event })
| 74 | streamFor(event.messageId); |
| 75 | }, |
| 76 | onTextMessageContentEvent({ event }) { |
| 77 | if (aborted) return; |
| 78 | const next = (buffers.get(event.messageId) ?? "") + (event.delta ?? ""); |
| 79 | buffers.set(event.messageId, next); |
| 80 | // Mid-stream the buffer is usually unbalanced markdown (an open `**`, |
| 81 | // code fence, etc.); balance it for display so the edited message never |
| 82 | // renders broken. The finalized message uses the raw text (below). |
| 83 | streamFor(event.messageId).append(autoCloseOpenMarkdown(next)); |
| 84 | }, |
| 85 | async onTextMessageEndEvent({ event }) { |
| 86 | if (aborted) return; |
| 87 | const text = buffers.get(event.messageId) ?? ""; |
nothing calls this directly
no test coverage detected
searching dependent graphs…