Struct tokio::sync::mpsc::chan::Rx

pub(crate) struct Rx<T, S: Semaphore> {
    inner: Arc<Chan<T, S>>,
}

Channel receiver.

Fields

inner: Arc<Chan<T, S>>

Implementations

impl<T, S: Semaphore> Rx<T, S>

fn new(chan: Arc<Chan<T, S>>) -> Rx<T, S>

pub(crate) fn close(&mut self)

pub(crate) fn is_closed(&self) -> bool

pub(crate) fn is_empty(&self) -> bool

pub(crate) fn len(&self) -> usize

pub(crate) fn recv(&mut self, cx: &mut Context<'_>) -> Poll<Option<T>>

Receive the next value

pub(crate) fn recv_many( &mut self, cx: &mut Context<'_>, buffer: &mut Vec<T>, limit: usize, ) -> Poll<usize>

Receives up to limit values into buffer

For limit > 0, receives up to limit values into buffer. For limit == 0, immediately returns Ready(0).

pub(crate) fn try_recv(&mut self) -> Result<T, TryRecvError>

Try to receive the next value.

pub(super) fn semaphore(&self) -> &S

pub(super) fn sender_strong_count(&self) -> usize

pub(super) fn sender_weak_count(&self) -> usize

Trait Implementations

impl<T, S: Semaphore + Debug> Debug for Rx<T, S>

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, S: Semaphore> Drop for Rx<T, S>

fn drop(&mut self)

Executes the destructor for this type.