Struct SessionOutboardReader 

pub struct SessionOutboardReader { /* private fields */ }

Serve-side Outboard over a hash’s shared HashOutboard. Its Outboard::load awaits a not-yet-captured node, racing the registry-wide fill liveness for the no-hang guarantee: once no live fill still covers the node’s byte range, it reads the node from the local store when the reader carries a store fallback (Self::with_store_fallback), and fails when that cannot supply it. Minted via FillSession::outboard_reader.

Implementations

impl SessionOutboardReader

pub fn with_store_fallback(self, engine: CacheEngine) -> Self

Read a node no live fill will capture from engine, the local store, before failing the load. The store can hold content under such a node: a pull that faulted landed part of its range first, or an earlier fill stored it. The store’s outboard then holds the node’s pair. Without the fallback such a load fails.

pub fn parked_on(&self) -> Arc<AtomicU64>

The cell this reader writes the content end it waits on into. A frame consumer shares it with its data reader and stands it as serve demand while it has no encoded bytes left to take.

Trait Implementations

impl Debug for SessionOutboardReader

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

Formats the value using the given formatter.

impl Outboard for SessionOutboardReader

fn root(&self) -> Hash

The root hash

fn tree(&self) -> BaoTree

The tree. This contains the information about the size of the file and the block size.

async fn load(&mut self, node: TreeNode) -> Result<Option<(Hash, Hash)>>

load the hash pair for a node