Struct WindowedReader 

pub struct WindowedReader<G, M: JoinMode, const BODY_SIZE: usize = DEFAULT_BODY_SIZE>
where
    G: ChunkGet<BODY_SIZE>,
{ /* private fields */ }

Seek-and-play reader: forward in-order delivery over a window that slides with the read cursor, bounded to window in-flight plus buffered leaves.

Retains the joiner’s reusable state (getter, pre-expanded frontier, tree params) so each stream rebuilds a fresh window-bounded walk from [position, size) without re-expanding the frontier. seek only repositions; it never re-fetches intermediates.

Implementations

impl<G, M, const BODY_SIZE: usize> WindowedReader<G, M, BODY_SIZE>

where G: ChunkGet<BODY_SIZE> + 'static, M: JoinMode + MaybeSend + Sync,

pub fn stream(&mut self) -> impl Stream<Item = Result<Bytes>> + '_

In-order leaf bodies from the current position to EOF. Each item is one contiguous run; reassembly is pure concatenation. Peak memory is window leaf bodies: the window slides with the emit cursor, so only leaves within window spans ahead of it are ever fetched or held.

pub fn seek(&mut self, pos: SeekFrom) -> Result<u64>

Reposition: drop the window and restart the walk from pos. Cheap; reuses the frontier, no intermediate re-fetch.

pub const fn position(&self) -> u64

Current read position.

pub const fn size(&self) -> u64

Total file size.

impl<G, M, const BODY_SIZE: usize> WindowedReader<G, M, BODY_SIZE>

where G: ChunkGet<BODY_SIZE> + 'static, M: JoinMode + Send + Sync + 'static,

pub fn into_reader(self) -> WindowedJoinerReader<G, M, BODY_SIZE>

Wrap as a tokio AsyncRead + AsyncSeek reader. Native-only.

Trait Implementations

impl<G, M, const BODY_SIZE: usize> Debug for WindowedReader<G, M, BODY_SIZE>

where G: ChunkGet<BODY_SIZE>, M: JoinMode,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.