| 503 | } |
| 504 | |
| 505 | function isMessageDeltaStreamEvent( |
| 506 | message: Message | StreamEvent, |
| 507 | ): message is StreamEventMessage & { event: BetaRawMessageDeltaEvent } { |
| 508 | return ( |
| 509 | message.type === 'stream_event' && |
| 510 | typeof (message as StreamEventMessage).event === 'object' && |
| 511 | (message as StreamEventMessage).event !== null && |
| 512 | 'type' in (message as StreamEventMessage).event && |
| 513 | (message as StreamEventMessage).event.type === 'message_delta' |
| 514 | ) |
| 515 | } |
| 516 | |
| 517 | export async function runForkedAgent({ |
| 518 | promptMessages, |