pub struct MessageReader<R> { /* private fields */ }Expand description
A stateful reader of Messages from a stream.
Implementations§
Source§impl<R: VortexRead> MessageReader<R>
impl<R: VortexRead> MessageReader<R>
pub async fn try_new(read: R) -> VortexResult<Self>
pub async fn read_dtype(&mut self) -> VortexResult<DType>
pub async fn maybe_read_chunk( &mut self, ctx: Arc<Context>, dtype: DType, ) -> VortexResult<Option<ArrayData>>
pub fn array_stream( &mut self, ctx: Arc<Context>, dtype: DType, ) -> impl ArrayStream + '_
pub fn into_array_stream( self, ctx: Arc<Context>, dtype: DType, ) -> impl ArrayStream
pub async fn maybe_read_page(&mut self) -> VortexResult<Option<Buffer>>
pub fn into_inner(self) -> R
Auto Trait Implementations§
impl<R> !Freeze for MessageReader<R>
impl<R> RefUnwindSafe for MessageReader<R>where
R: RefUnwindSafe,
impl<R> Send for MessageReader<R>where
R: Send,
impl<R> Sync for MessageReader<R>where
R: Sync,
impl<R> Unpin for MessageReader<R>where
R: Unpin,
impl<R> UnwindSafe for MessageReader<R>where
R: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more