diff --git a/src/main.rs b/src/main.rs index 237954a..01a9b28 100644 --- a/src/main.rs +++ b/src/main.rs @@ -399,11 +399,10 @@ async fn main() -> Result<(), MainError> { }); } - let run_shards = JoinSet::from_iter( - shards - .into_iter() - .map(|shard| handle_events(command_router.clone(), state.clone(), shard)), - ); + let run_shards = shards + .into_iter() + .map(|shard| handle_events(command_router.clone(), state.clone(), shard)); + let run_shards = JoinSet::from_iter(run_shards); let run_shards = run_shards.join_all(); tokio::pin!(run_shards);