Struct vortex_serde::MessageReader
source · pub struct MessageReader<R> { /* private fields */ }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<Array>>
sourcepub async fn array_stream_from_messages(
&mut self,
ctx: Arc<Context>,
) -> VortexResult<impl ArrayStream + '_>
pub async fn array_stream_from_messages( &mut self, ctx: Arc<Context>, ) -> VortexResult<impl ArrayStream + '_>
Construct an ArrayStream pulling the DType from the stream.
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>>
Auto Trait Implementations§
impl<R> Freeze for MessageReader<R>where
R: Freeze,
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