Thread the per-step [`AgentEvent`] sender into every combinator call so existing subagent/AHP/trace listeners observe child-run lifecycle events.
(mut self, step_events: broadcast::Sender<AgentEvent>)
| 136 | /// Thread the per-step [`AgentEvent`] sender into every combinator call so |
| 137 | /// existing subagent/AHP/trace listeners observe child-run lifecycle events. |
| 138 | pub fn with_step_events(mut self, step_events: broadcast::Sender<AgentEvent>) -> Self { |
| 139 | self.step_events = Some(step_events); |
| 140 | self |
| 141 | } |
| 142 | |
| 143 | /// Set the stable root id used to derive per-phase checkpoint keys. Supply a |
| 144 | /// deterministic id (e.g. session-derived) for resume to work across runs; |
no outgoing calls
no test coverage detected