Struct Reader 

pub struct Reader<'bs, BS: BlobService + 'bs> {
    segments: Segments,
    pos: u64,
    blob_service: BS,
    rd: Box<dyn AsyncBufRead + Send + Unpin + 'bs>,
}

Fields

segments: Segments

pos: u64

blob_service: BS

rd: Box<dyn AsyncBufRead + Send + Unpin + 'bs>

Implementations

impl<'bs, BS: BlobService + 'bs> Reader<'bs, BS>

pub(crate) fn project<'pin>( self: Pin<&'pin mut Self>, ) -> __ReaderProjection<'pin, 'bs, BS>

pub(crate) fn project_ref<'pin>( self: Pin<&'pin Self>, ) -> __ReaderProjectionRef<'pin, 'bs, BS>

impl<'bs, BS: BlobService + Clone + 'bs> Reader<'bs, BS>

pub async fn new( root_node: &Node, blob_service: BS, directory_service: impl DirectoryService, ) -> Result<Self, RenderError>

Creates a new seekable NAR renderer for the given castore root node.

This function pre-fetches the directory closure using get_recursive() and assembles the NAR structure, except the file contents which are stored as ‘holes’ with references to a blob of a specific BLAKE3 digest and known size. The AsyncRead implementation will then switch between serving the precomputed literal segments, and the appropriate blob for the file contents.

pub fn nar_size(&self) -> u64

Trait Implementations

impl<'bs, BS: BlobService> AsyncBufRead for Reader<'bs, BS>

fn poll_fill_buf( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8]>>

Attempts to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty.

fn consume(self: Pin<&mut Self>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to poll_read.

impl<'bs, BS: BlobService> AsyncRead for Reader<'bs, BS>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl<'bs, BS: BlobService + Clone + 'bs> AsyncSeek for Reader<'bs, BS>

fn start_seek(self: Pin<&mut Self>, pos: SeekFrom) -> Result<()>

Attempts to seek to an offset, in bytes, in a stream.

fn poll_complete( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<u64>>

Waits for a seek operation to complete.

impl<'pin, 'bs, BS: BlobService + 'bs> Unpin for Reader<'bs, BS>

where PinnedFieldsOf<__Reader<'pin, 'bs, BS>>: Unpin,