Searched refs:unbounded_send (Results 1 – 7 of 7) sorted by relevance
66 b_tx.unbounded_send(99).unwrap(); in works_1()67 a_tx.unbounded_send(33).unwrap(); in works_1()71 b_tx.unbounded_send(99).unwrap(); in works_1()72 a_tx.unbounded_send(33).unwrap(); in works_1()76 c_tx.unbounded_send(42).unwrap(); in works_1()78 a_tx.unbounded_send(43).unwrap(); in works_1()
64 tx.unbounded_send(()).unwrap(); in mutex_contested()
32 UnboundedSender::unbounded_send(&tx, i).unwrap(); in unbounded_1_tx()54 UnboundedSender::unbounded_send(x, i).unwrap(); in unbounded_100_tx()69 UnboundedSender::unbounded_send(&tx, i).expect("send"); in unbounded_uncontended()
89 self.unbounded_send(msg) in start_send()
870 pub fn unbounded_send(&self, msg: T) -> Result<(), TrySendError<T>> { in unbounded_send() method
220 tx.unbounded_send(1).unwrap(); in stress_shared_unbounded()359 if tx.unbounded_send(i).is_err() { in stress_close_receiver_iter()
115 sender.unbounded_send(ref_count).expect("failed to send"); in single_receiver_drop_closes_channel_and_drains()