FollowUp enqueues a message to be processed after the current agent turn finishes. Unlike Steer, follow-ups are popped one at a time and each gets a full undivided agent turn.
(ctx context.Context, msg QueuedMessage)
| 1789 | // finishes. Unlike Steer, follow-ups are popped one at a time and each gets |
| 1790 | // a full undivided agent turn. |
| 1791 | func (r *LocalRuntime) FollowUp(ctx context.Context, msg QueuedMessage) error { |
| 1792 | if !r.followUpQueue.Enqueue(ctx, msg) { |
| 1793 | return errors.New("follow-up queue full") |
| 1794 | } |
| 1795 | return nil |
| 1796 | } |
| 1797 | |
| 1798 | func (r *LocalRuntime) QueueStatus() QueueStatus { |
| 1799 | status := QueueStatus{} |