pub async fn shutdown(self) {
        let handles = self.executor_handles.into_items();
        let join_handles: Vec<_> = handles
            .into_iter()
            .map(|handle| handle.shutdown())
            .collect();

        futures::future::join_all(join_handles).await;
    }
/// Shutdown the pool
///
/// Waits for all workers to be empty before stopping.
Shutdown the pool
Waits for all workers to be empty before stopping.
Shutdown the pool Waits for all workers to be empty before stopping .
pub async fn shutdown(self) {
        let handles = self.executor_handles.into_items();
        let join_handles: Vec<_> = handles
            .into_iter()
            .map(|handle| handle.shutdown())
            .collect();
        futures::future::join_all(join_handles).await;
    }
pub async fn shutdown ( self ) { let handles = self . executor_handles . into_items ( ) ; let join_handles : Vec < _ > = handles . into_iter ( ) . map ( | handle | handle . shutdown ( ) ) . collect ( ) ; futures :: future :: join_all ( join_handles ) . await ; }
Shutdown the pool
Waits for all workers to be empty before stopping.
Shutdown the pool Waits for all workers to be empty before stopping .
self
self