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<P> StreamRead<AwsS3ByteLender> for AwsS3BackedFile<P>

where P: PartMap,

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

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

impl<R, RBL> StreamRead<BufferedByteLender<RBL>> for BufferedAppender<R, R::Position, R::Size>

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

impl<R, RBL> StreamRead<BufferedByteLender<RBL>> for BufferedReader<R, R::Position, R::Size>

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