Expand description
The receiver side of the channel. This will receive every message broadcast.
If receive is called twice on the same receiver, only one receive will receive the broadcast message. If both must receive it, clone the receiver.
Implementations
sourceimpl<T: Clone + Unpin> Receiver<T>
impl<T: Clone + Unpin> Receiver<T>
sourcepub fn recv(&self) -> Result<T, Disconnected>
pub fn recv(&self) -> Result<T, Disconnected>
Receive a broadcast message. If there are none in the queue, it will block until another is sent or all senders disconnect.
sourcepub fn try_recv(&self) -> Result<Option<T>, Disconnected>
pub fn try_recv(&self) -> Result<Option<T>, Disconnected>
Try to receive a broadcast message. If there are none in the queue, it will return None
, or
if there are no senders it will return Disconnected
.
sourcepub fn recv_async(&self) -> RecvFut<'_, T>ⓘNotable traits for RecvFut<'a, T>impl<'a, T: Clone + Unpin> Future for RecvFut<'a, T> type Output = Result<T, Disconnected>;
pub fn recv_async(&self) -> RecvFut<'_, T>ⓘNotable traits for RecvFut<'a, T>impl<'a, T: Clone + Unpin> Future for RecvFut<'a, T> type Output = Result<T, Disconnected>;
Receive a broadcast message. If there are none in the queue, it will asynchronously wait until another is sent or all senders disconnect.
Converts this receiver into a shared receiver.
Trait Implementations
Auto Trait Implementations
impl<T> !RefUnwindSafe for Receiver<T>
impl<T> Send for Receiver<T> where
T: Send + Sync,
impl<T> Sync for Receiver<T> where
T: Send + Sync,
impl<T> Unpin for Receiver<T>
impl<T> !UnwindSafe for Receiver<T>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more