Struct Inner 

struct Inner {
    backpressure_boundary: usize,
    is_closed: bool,
    receiver_waker: Option<Waker>,
    sender_waker: Option<Waker>,
    buf: BytesMut,
}

Fields

backpressure_boundary: usize

poll_write will return Poll::Pending if the backpressure boundary is reached

is_closed: bool

either Sender or Receiver is closed

receiver_waker: Option<Waker>

Waker used to wake the Receiver

sender_waker: Option<Waker>

Waker used to wake the Sender

buf: BytesMut

Buffer used to read and write data

Implementations

impl Inner

fn with_capacity(capacity: usize) -> Self

fn register_receiver_waker(&mut self, waker: &Waker) -> Option<Waker>

fn register_sender_waker(&mut self, waker: &Waker) -> Option<Waker>

fn take_receiver_waker(&mut self) -> Option<Waker>

fn take_sender_waker(&mut self) -> Option<Waker>

fn is_closed(&self) -> bool

fn close_receiver(&mut self) -> Option<Waker>

fn close_sender(&mut self) -> Option<Waker>

Trait Implementations

impl Debug for Inner

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

Formats the value using the given formatter.