(threadId)
| 238 | const controllersByThread = new Map() |
| 239 | |
| 240 | const getThreadControllers = (threadId) => { |
| 241 | if (!controllersByThread.has(threadId)) { |
| 242 | controllersByThread.set(threadId, new Map()) |
| 243 | } |
| 244 | return controllersByThread.get(threadId) |
| 245 | } |
| 246 | |
| 247 | const emitDelta = (threadId, messageId, forceFlush = false) => { |
| 248 | const threadState = getThreadState(threadId) |