Lines Matching refs:Receiver
197 pub struct Receiver<T> { struct
371 receiver: &'a mut Receiver<T>,
428 pub fn channel<T: Clone>(mut capacity: usize) -> (Sender<T>, Receiver<T>) { in channel()
458 let rx = Receiver { in channel()
471 unsafe impl<T: Send> Send for Receiver<T> {} implementation
472 unsafe impl<T: Send> Sync for Receiver<T> {} implementation
553 pub fn subscribe(&self) -> Receiver<T> { in subscribe()
645 fn new_receiver<T>(shared: Arc<Shared<T>>) -> Receiver<T> { in new_receiver()
658 Receiver { shared, next } in new_receiver()
693 impl<T> Receiver<T> { implementation
811 impl<T: Clone> Receiver<T> { impl
928 impl<T> Drop for Receiver<T> { implementation
952 fn new(receiver: &'a mut Receiver<T>) -> Recv<'a, T> { in new()
966 fn project(self: Pin<&mut Self>) -> (&mut Receiver<T>, &UnsafeCell<Waiter>) { in project()
969 is_unpin::<&mut Receiver<T>>(); in project()
1046 impl<T> fmt::Debug for Receiver<T> { implementation