Struct SendEndpoint 

pub struct SendEndpoint<P>
where
    P: BytesPush,
{ /* private fields */ }

A BytesPush wrapper which stages writes.

Implementations

impl<P> SendEndpoint<P>

where P: BytesPush,

pub fn new(queue: P, refill: BytesRefill) -> SendEndpoint<P>

Allocates a new BytesSendEndpoint from a shared queue.

pub fn make_valid(&mut self, bytes: usize)

Makes the next bytes bytes valid.

The current implementation also sends the bytes, to ensure early visibility.

pub fn reserve(&mut self, capacity: usize) -> &mut [u8]

Acquires a prefix of self.empty() of length at least capacity.

pub fn publish(&mut self)

Marks all written data as valid, makes visible.

pub fn push_bytes(&mut self, bytes: Bytes)

Sends already-formed bytes, after anything staged so far.

Staged bytes are sent first, so that the order of messages toward the destination is the order in which they were pushed.

Trait Implementations

impl<P> Drop for SendEndpoint<P>

where P: BytesPush,

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.