Trait laminarmq_io::io_types::StreamRead

pub trait StreamRead<B: ByteLender>: SizedEntity + FallibleEntity {
    // Required method
    fn read_stream_at<'a>(
        &'a mut self,
        position: Self::Position,
        size: Self::Size,
    ) -> impl Stream<FallibleByteLender<B, Self::Error>> + 'a
       where B: 'a;
}

Required Methods

fn read_stream_at<'a>( &'a mut self, position: Self::Position, size: Self::Size, ) -> impl Stream<FallibleByteLender<B, Self::Error>> + 'a

where B: 'a,

Object Safety

This trait is not object safe.

Implementors

impl<BM> StreamRead<AwsS3ByteLender> for AwsS3BackedFile<BM>

where BM: BlockMap,

impl<R, B> StreamRead<B> for AsyncReadStreamRead<R>

where R: AsyncRead<B>, B: ByteLender,

impl<R, RBL> StreamRead<BufByteLender<RBL>> for BufAppender<R, R::Position, R::Size>

where R: StreamRead<RBL>, R::Error: 'static, RBL: ByteLender + 'static,

impl<R, RBL> StreamRead<BufByteLender<RBL>> for BufReader<R, R::Position, R::Size>

where R: StreamRead<RBL>, R::Error: 'static, RBL: ByteLender + 'static,