Struct timely::communication::allocator::zero_copy::bytes_exchange::SendEndpoint[−][src]

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

A BytesPush wrapper which stages writes.

Implementations

impl<P> SendEndpoint<P> where
    P: BytesPush, [src]

pub fn new(queue: P) -> SendEndpoint<P>[src]

Allocates a new BytesSendEndpoint from a shared queue.

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

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]ⓘ

Notable traits for &'_ [u8]

impl<'_> Read for &'_ [u8]impl<'_> Write for &'_ mut [u8]
[src]

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

pub fn publish(&mut self)[src]

Marks all written data as valid, makes visible.

Trait Implementations

impl<P> Drop for SendEndpoint<P> where
    P: BytesPush, [src]

Auto Trait Implementations

impl<P> !RefUnwindSafe for SendEndpoint<P>

impl<P> Send for SendEndpoint<P> where
    P: Send, 

impl<P> !Sync for SendEndpoint<P>

impl<P> Unpin for SendEndpoint<P> where
    P: Unpin, 

impl<P> !UnwindSafe for SendEndpoint<P>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.