pub struct StreamingBinaryReader { /* private fields */ }Expand description
Streaming reader implementation
Trait Implementations§
Source§impl BinaryFormatReader for StreamingBinaryReader
impl BinaryFormatReader for StreamingBinaryReader
Source§fn read_header(&self) -> Result<FileHeader, PipelineError>
fn read_header(&self) -> Result<FileHeader, PipelineError>
Reads the .adapipe file header/metadata
Source§fn read_next_chunk<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<Option<ChunkFormat>, PipelineError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn read_next_chunk<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<Option<ChunkFormat>, PipelineError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Reads the next processed chunk (compressed/encrypted data) from the
.adapipe file
Source§fn seek_to_chunk<'life0, 'async_trait>(
&'life0 mut self,
chunk_index: u32,
) -> Pin<Box<dyn Future<Output = Result<(), PipelineError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn seek_to_chunk<'life0, 'async_trait>(
&'life0 mut self,
chunk_index: u32,
) -> Pin<Box<dyn Future<Output = Result<(), PipelineError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Seeks to a specific chunk by index
Source§fn validate_integrity<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<bool, PipelineError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn validate_integrity<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<bool, PipelineError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Validates the file integrity
Auto Trait Implementations§
impl !Freeze for StreamingBinaryReader
impl !RefUnwindSafe for StreamingBinaryReader
impl Send for StreamingBinaryReader
impl Sync for StreamingBinaryReader
impl Unpin for StreamingBinaryReader
impl !UnwindSafe for StreamingBinaryReader
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> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
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