Struct TxAsync 

pub struct TxAsync(/* private fields */);

Implementations

impl TxAsync

pub fn new(tx: Tx) -> Self

pub fn inner(&mut self) -> &mut Tx

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

Write a buffer asynchronously.

This implementation is not side effect free, and a started future might have already written part of the passed buffer.

pub async fn write_all(&mut self, buf: &[u8]) -> Result<(), TxOverrunError>

Write an entire buffer into this writer.

This function calls write() in a loop until exactly buf.len() bytes have been written, waiting if needed.

This function is not side-effect-free on cancel (AKA “cancel-safe”), i.e. if you cancel (drop) a returned future that hasn’t completed yet, some bytes might have already been written.

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

pub fn release(self) -> Tx

Trait Implementations

impl ErrorType for TxAsync

type Error = TxOverrunError

Error type of all the IO operations on this type.

impl Write for TxAsync

async fn write(&mut self, buf: &[u8]) -> Result<usize, Self::Error>

Write a buffer asynchronously.

This implementation is not side effect free, and a started future might have already written part of the passed buffer.

async fn flush(&mut self) -> Result<(), Self::Error>

Flush this output stream, ensuring that all intermediately buffered contents reach their destination.

async fn write_all(&mut self, buf: &[u8]) -> Result<(), Self::Error>

Write an entire buffer into this writer.