Struct ZrecSource 

pub struct ZrecSource { /* private fields */ }

A ZrecReader running on the blocking pool behind a bounded channel (#332) — the async end of a replay, and the mirror of ZrecSink.

replay interleaves sleep().awaits and network puts with its reads, so a blocking BufRead in that loop stalls the runtime on every line — on a cold page cache or a network filesystem, for as long as the read takes, mid-pacing. Here the file is read ahead on a blocking thread and the loop awaits parsed items; the queue is bounded, so a replay that pauses for pacing does not read the whole capture into memory.

Implementations

impl ZrecSource

pub async fn spawn<R: BufRead + Send + 'static>(source: R) -> Result<ZrecSource>

Parse the header, then read the rest ahead on the blocking pool.

The header is awaited — a file that is not a .zrec is a refusal before anything is scheduled, exactly as it was when the reader was constructed inline.

pub fn header(&self) -> &ZrecHeader

pub async fn next(&mut self) -> Option<Result<ZrecItem, String>>

The next item, or Err naming the line and the reason — a malformed row is counted by the caller, never silently skipped. None ends the file.