Struct async_ringbuffer::Writer
[−]
[src]
pub struct Writer(_);
Write access to a nonblocking ring buffer with fixed capacity.
If there is no space in the buffer to write to, the current task is parked and notified once space becomes available.
Trait Implementations
impl Drop for Writer[src]
impl AsyncWrite for Writer[src]
fn poll_write(&mut self, cx: &mut Context, buf: &[u8]) -> Poll<usize, Error>[src]
Write data to the RingBuffer.
This only returns Ok(Ready(0)) if either buf.len() == 0, poll_close has been called,
or if the corresponding Reader has been dropped and no more data will be read to free up
space for new data.
Errors
This never emits an error.
fn poll_flush(&mut self, _: &mut Context) -> Poll<(), Error>[src]
Errors
This never emits an error.
fn poll_close(&mut self, _: &mut Context) -> Poll<(), Error>[src]
Once closing is complete, the corresponding reader will always return Ok(Ready(0)) on
poll_read once all remaining buffered data has been read.
Errors
This never emits an error.
fn poll_vectored_write(
&mut self,
cx: &mut Context,
vec: &[&IoVec]
) -> Result<Async<usize>, Error>[src]
&mut self,
cx: &mut Context,
vec: &[&IoVec]
) -> Result<Async<usize>, Error>
Attempt to write bytes from vec into the object using vectored IO operations. Read more