Searched refs:notified_tx (Results 1 – 1 of 1) sorted by relevance
111 let (notified_tx, mut notified_rx) = mpsc::unbounded_channel(); in accept_many()117 let notified_tx = notified_tx.clone(); in accept_many() localVariable132 notified_tx.send(()).unwrap(); in accept_many()