( event: RemoteAppServerEvent, )
| 151 | } |
| 152 | |
| 153 | export function appServerEventRequiresDelivery( |
| 154 | event: RemoteAppServerEvent, |
| 155 | ): boolean { |
| 156 | if (event.type === 'disconnected') { |
| 157 | return true |
| 158 | } |
| 159 | if (event.type !== 'server_notification') { |
| 160 | return false |
| 161 | } |
| 162 | switch (event.notification.method) { |
| 163 | case 'turn/completed': |
| 164 | case 'item/completed': |
| 165 | case 'item/agentMessage/delta': |
| 166 | case 'item/plan/delta': |
| 167 | case 'item/reasoning/summaryTextDelta': |
| 168 | case 'item/reasoning/textDelta': |
| 169 | return true |
| 170 | default: |
| 171 | return false |
| 172 | } |
| 173 | } |
| 174 | |
| 175 | class AsyncEventQueue<T> { |
| 176 | private queue: T[] = [] |
no outgoing calls
no test coverage detected