Struct FormatStream

pub struct FormatStream<T, R>
where
    T: FileItem + Send,
    R: AsyncRead + AsyncSeek + Unpin + Send,
{ /* private fields */ }

Generic iterator for file formats.

Supports files and in-memory buffers and can iterate lazily in both directions.

Implementations

impl<T: FileItem + Send> FormatStream<T, File>

pub async fn new_file( read_stream: File, identity: &'static [u8], data_length_prefix: bool, header_offset: Option<u64>, reverse: bool, ) -> Result<Self, Error>

Create a new file iterator.

impl<T, R> FormatStream<T, R>

where T: FileItem + Send, R: AsyncRead + AsyncSeek + Unpin + Send,

pub fn set_offset(&mut self, offset: u64)

Set the byte offset that constrains iteration.

Useful when creating streams of log events.

Trait Implementations

impl<T: FileItem + Send> FormatStreamIterator<T> for FormatStream<T, File>

fn next<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<T>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Next entry in the iterator.