pub(crate) fn wakers(&self) -> Vec<Arc<Waker>> {
        match self {
            Self::Multi { storage, workers } => {
                let mut wakers = vec![storage.waker()];
                for waker in workers.iter().map(|v| v.waker()) {
                    wakers.push(waker);
                }
                wakers
            }
            Self::Single { worker } => {
                vec![worker.waker()]
            }
        }
    }
/// Returns the wakers for all workers. Used when setting-up the queues to
/// signal to all threads.
Returns the wakers for all workers. Used when setting-up the queues to
signal to all threads.
Returns the wakers for all workers . Used when setting - up the queues to signal to all threads .
pub(crate) fn wakers(&self) -> Vec<Arc<Waker>> {
        match self {
            Self::Multi { storage, workers } => {
                let mut wakers = vec![storage.waker()];
                for waker in workers.iter().map(|v| v.waker()) {
                    wakers.push(waker);
                }
                wakers
            }
            Self::Single { worker } => {
                vec![worker.waker()]
            }
        }
    }
pub ( crate ) fn wakers ( & self ) -> Vec < Arc < Waker > > { match self { Self :: Multi { storage , workers } => { let mut wakers = vec ! [ storage waker ( ) ] ; for waker in workers . iter ( ) . map ( | v | v . waker ( ) ) { wakers . push ( waker ) ; } wakers } Self :: Single { worker } => { vec ! [ worker waker ( ) ] } } }
Returns the wakers for all workers.
Returns the wakers for all workers .
&self
&self