Trait laminarmq_io::io_types::AsyncAppend

pub trait AsyncAppend: SizedEntity + FallibleEntity {
    // Required method
    fn append(
        &mut self,
        bytes: Bytes,
    ) -> impl Future<Output = Result<AppendInfo<Self::Position, Self::Size>, UnwrittenError<Self::Error>>>;
}

Required Methods

fn append( &mut self, bytes: Bytes, ) -> impl Future<Output = Result<AppendInfo<Self::Position, Self::Size>, UnwrittenError<Self::Error>>>

Object Safety

This trait is not object safe.

Implementors

impl AsyncAppend for BufferedFile

impl AsyncAppend for DmaFile

impl AsyncAppend for TokioUringFile

impl<K, const FLUSH_ON_APPEND: bool> AsyncAppend for TokioFile<K, FLUSH_ON_APPEND>

impl<P> AsyncAppend for AwsS3BackedFile<P>

where P: PartMap,

impl<R> AsyncAppend for BufferedAppender<R, R::Position, R::Size>

where R: AsyncAppend + AsyncFlush,