(event: {
subtype: "snapshot" | "enqueued" | "dequeued" | "drained" | "updated"
taskId?: string
content?: string
queueDepth: number
queue: JsonEventQueueItem[]
})
| 188 | } |
| 189 | |
| 190 | emitQueue(event: { |
| 191 | subtype: "snapshot" | "enqueued" | "dequeued" | "drained" | "updated" |
| 192 | taskId?: string |
| 193 | content?: string |
| 194 | queueDepth: number |
| 195 | queue: JsonEventQueueItem[] |
| 196 | }): void { |
| 197 | this.emitEvent({ |
| 198 | type: "queue", |
| 199 | subtype: event.subtype, |
| 200 | taskId: event.taskId, |
| 201 | content: event.content, |
| 202 | queueDepth: event.queueDepth, |
| 203 | queue: event.queue, |
| 204 | }) |
| 205 | } |
| 206 | |
| 207 | private handleStateChange(event: AgentStateChangeEvent): void { |
| 208 | // Only treat the next say:text as a prompt echo when a new task starts. |
no test coverage detected