Struct LimitedJoinSet 

pub struct LimitedJoinSet<T> { /* private fields */ }

Implementations

impl<T: 'static> LimitedJoinSet<T>

pub fn new(max_concurrent: usize) -> Self

pub fn spawn<F>(&mut self, task: F) -> AbortHandle

where F: Future<Output = T> + Send + 'static, T: Send,

pub fn try_join_next(&mut self) -> Option<Result<T, JoinError>>

pub async fn join_next(&mut self) -> Option<Result<T, JoinError>>

pub async fn join_all(self) -> Vec<T>

pub fn poll_join_next( &mut self, cx: &mut Context<'_>, ) -> Poll<Option<Result<T, JoinError>>>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool