Trait laminarmq_io::io_types::AsyncBufRead

pub trait AsyncBufRead: SizedEntity + FallibleEntity {
    // Required method
    fn read_at_buf(
        &mut self,
        position: Self::Position,
        buffer: BytesMut,
    ) -> impl Future<Output = Result<ReadBytes<BytesMut, Self::Size>, UnreadError<Self::Error>>>;

    // Provided method
    fn read_at_buf_sized(
        &mut self,
        position: Self::Position,
        size: Self::Size,
        buffer: BytesMut,
    ) -> impl Future<Output = Result<ReadBytes<BytesMut, Self::Size>, UnreadError<Self::Error>>> { ... }
}

Required Methods

fn read_at_buf( &mut self, position: Self::Position, buffer: BytesMut, ) -> impl Future<Output = Result<ReadBytes<BytesMut, Self::Size>, UnreadError<Self::Error>>>

Provided Methods

fn read_at_buf_sized( &mut self, position: Self::Position, size: Self::Size, buffer: BytesMut, ) -> impl Future<Output = Result<ReadBytes<BytesMut, Self::Size>, UnreadError<Self::Error>>>

Object Safety

This trait is not object safe.

Implementors

impl AsyncBufRead for TokioFile<RandomRead, true>

impl AsyncBufRead for TokioFile<Seek, true>

impl AsyncBufRead for TokioUringFile

impl<R> AsyncBufRead for BufAppender<R, R::Position, R::Size>

where R: AsyncBufRead,