diff --git a/tap-agent/src/agent/sender_account.rs b/tap-agent/src/agent/sender_account.rs index de1fb91e..675aae38 100644 --- a/tap-agent/src/agent/sender_account.rs +++ b/tap-agent/src/agent/sender_account.rs @@ -656,7 +656,7 @@ impl Actor for SenderAccount { stream::iter(allocation_ids) // Create a sender allocation for each allocation .map(|allocation_id| state.create_sender_allocation(myself.clone(), allocation_id)) - .buffered(10) // Limit concurrency to 10 allocations at a time + .buffer_unordered(10) // Limit concurrency to 10 allocations at a time .collect::>>() .await .into_iter() diff --git a/tap-agent/src/agent/sender_accounts_manager.rs b/tap-agent/src/agent/sender_accounts_manager.rs index 69ee233d..af6c38e2 100644 --- a/tap-agent/src/agent/sender_accounts_manager.rs +++ b/tap-agent/src/agent/sender_accounts_manager.rs @@ -169,7 +169,7 @@ impl Actor for SenderAccountsManager { .map(|(sender_id, allocation_ids)| { state.create_or_deny_sender(myself.get_cell(), sender_id, allocation_ids) }) - .buffered(10) // Limit concurrency to 10 senders at a time + .buffer_unordered(10) // Limit concurrency to 10 senders at a time .collect::>() .await;