(
&self,
params: AgentRunParams<'_>,
on_token: Channel<String>,
)
| 334 | } |
| 335 | |
| 336 | pub async fn run( |
| 337 | &self, |
| 338 | params: AgentRunParams<'_>, |
| 339 | on_token: Channel<String>, |
| 340 | ) -> AppResult<String> { |
| 341 | let token_sink = ChannelTokenSink { channel: on_token }; |
| 342 | let ctx = InternalRunContext::new( |
| 343 | params.session_id, |
| 344 | params.agent_type, |
| 345 | params.task, |
| 346 | params.project_path, |
| 347 | params.provider_id, |
| 348 | params.model_id, |
| 349 | None, |
| 350 | params.flux_enabled, |
| 351 | ); |
| 352 | |
| 353 | self.run_internal(&ctx, &token_sink).await |
| 354 | } |
| 355 | |
| 356 | async fn run_subagent_internal(&self, params: SubagentParams) -> AppResult<String> { |
| 357 | let token_sink = NoopTokenSink; |
no test coverage detected