pub async fn process_batched_future_queue_result<I, C, E, R>( future_queue: I, batch_size: usize, stop_token: StopToken, result_callback: C, ) -> Result<(), E>where I: IntoIterator, C: Fn(R) -> Result<(), E>, <I as IntoIterator>::Item: Future<Output = R>,