Lines Matching refs:Receiver
45 pub fn unbounded<T>() -> (Sender<T>, Receiver<T>) { in unbounded()
50 let r = Receiver { in unbounded()
106 pub fn bounded<T>(cap: usize) -> (Sender<T>, Receiver<T>) { in bounded()
112 let r = Receiver { in bounded()
121 let r = Receiver { in bounded()
173 pub fn after(duration: Duration) -> Receiver<Instant> { in after()
174 Receiver { in after()
221 pub fn at(when: Instant) -> Receiver<Instant> { in at()
222 Receiver { in at()
262 pub fn never<T>() -> Receiver<T> { in never()
263 Receiver { in never()
321 pub fn tick(duration: Duration) -> Receiver<Instant> { in tick()
322 Receiver { in tick()
693 pub struct Receiver<T> { struct
700 Array(counter::Receiver<flavors::array::Channel<T>>),
703 List(counter::Receiver<flavors::list::Channel<T>>),
706 Zero(counter::Receiver<flavors::zero::Channel<T>>),
718 unsafe impl<T: Send> Send for Receiver<T> {} implementation
719 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
721 impl<T> UnwindSafe for Receiver<T> {} implementation
722 impl<T> RefUnwindSafe for Receiver<T> {} implementation
724 impl<T> Receiver<T> { impl
1122 pub fn same_channel(&self, other: &Receiver<T>) -> bool { in same_channel()
1135 impl<T> Drop for Receiver<T> { implementation
1150 impl<T> Clone for Receiver<T> { implementation
1161 Receiver { flavor } in clone()
1165 impl<T> fmt::Debug for Receiver<T> { implementation
1171 impl<'a, T> IntoIterator for &'a Receiver<T> { implementation
1180 impl<T> IntoIterator for Receiver<T> { implementation
1218 receiver: &'a Receiver<T>,
1270 receiver: &'a Receiver<T>,
1316 receiver: Receiver<T>,
1397 impl<T> SelectHandle for Receiver<T> { implementation
1497 pub unsafe fn read<T>(r: &Receiver<T>, token: &mut Token) -> Result<T, ()> { in read()