Searched refs:push_ch (Results 1 – 1 of 1) sorted by relevance
101 push_ch: Option<mpsc::Sender<()>>, // writer requires mutex field308 self.push_ch = Some(push_ch_tx); in start()354 self.push_ch.take(); in stop()416 if let Some(push_ch) = &self.push_ch { in push()417 let _ = push_ch.try_send(()); in push()