Struct BufInsertFormatted 

pub struct BufInsertFormatted { /* private fields */ }

A wrapper around InsertFormatted which buffers writes.

Implementations

impl BufInsertFormatted

pub fn buf_len(&self) -> usize

Return the number of buffered bytes.

pub fn capacity(&self) -> usize

Return the current capacity of the buffer.

Note: Size is Not Constant This may be smaller than the original capacity if part of the buffer is still being used by the connection.

This may be larger if a call to Self::write_buffered() caused the buffer to expand.

pub fn write_buffered(&mut self, data: &[u8])

Write data to the buffer without waiting for it to be flushed.

May cause the buffer to resize to fit the data.

pub async fn write(&mut self, data: &[u8]) -> Result<usize>

Write some data to the buffer, flushing first if it is already full.

Returns the number of bytes written, which may be less than data.len() if the remaining capacity was smaller.

Cancel-safe. Until this returns Ok(n), the contents of data are not yet written to the buffer.

pub async fn flush(&mut self) -> Result<()>

Flush the buffer to the server as a single chunk.

If compression is enabled, the full buffer will be compressed.

pub async fn end(&mut self) -> Result<()>

Flushes the buffer, then calls InsertFormatted::end().

Cancel-safe.

Trait Implementations

impl AsyncWrite for BufInsertFormatted

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.