Struct GenericJoiner 

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

Generic async joiner parameterized by chunk mode.

Implementations

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

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

pub async fn new(getter: G, input: M::RootRef) -> Result<Self>

Create an async joiner from a root reference.

pub fn with_concurrency(self, concurrency: usize) -> Self

Set concurrency level for prefetching.

pub const fn size(&self) -> u64

Total file size.

pub const fn position(&self) -> u64

Current read position.

pub const fn root(&self) -> &ChunkAddress

Root address.

pub async fn read_range(&self, offset: u64, len: usize) -> Result<Vec<u8>>

Read a range of bytes with concurrent fetching using the cached frontier.

pub async fn read_all(&self) -> Result<Vec<u8>>

Read entire file into memory.

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

Update read position (synchronous — just updates internal state).

pub fn into_stream(self) -> impl Stream<Item = Result<Bytes>>

Convert into a stream of leaf chunk bodies.

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

Convert into an AsyncRead reader.

Trait Implementations

impl<G, M, const BODY_SIZE: usize> Debug for GenericJoiner<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.