()
| 249 | |
| 250 | #[tokio::test] |
| 251 | async fn fans_out_in_input_order() { |
| 252 | let exec: Arc<dyn AgentExecutor> = Arc::new(MockExecutor::new(8)); |
| 253 | let specs = vec![spec("a", "explore"), spec("b", "review"), spec("c", "plan")]; |
| 254 | let out = execute_steps_parallel(exec, specs, None).await; |
| 255 | assert_eq!( |
| 256 | out.iter().map(|o| o.task_id.as_str()).collect::<Vec<_>>(), |
| 257 | vec!["a", "b", "c"], |
| 258 | "results preserve input order" |
| 259 | ); |
| 260 | assert!(out.iter().all(|o| o.success)); |
| 261 | assert_eq!(out[0].output, "ran: prompt-a"); |
| 262 | } |
| 263 | |
| 264 | #[tokio::test] |
| 265 | async fn respects_concurrency_hint() { |
nothing calls this directly
no test coverage detected