Number of prefetched fragments currently ready for callers.
Stop fetching and release pending readers with cancellation.
Schedule fetching before the first next(); safe to call repeatedly.
Reader terminal status, or OK while it is healthy and still running.
Await the next fragment; null is a clean logical end of the sequence.
OptionaltimeoutMs: numberIterate to the clean reader end, yielding one terminal error when needed.
OptionaltimeoutMs: numberAwait end-of-sequence, cancellation, or a store error.
StaticcreateValidate options, create the cursor, and start its lazy fetch pump.
Fair, stackless, prefetching cursor over a ChunkStore.
A reader turns the store's waitable log operations into a simple
next()or async-iterator interface. Ordered mode stops after the final fragment, a clean store closure, or its configured read limit; arrival mode is useful when inspecting interleaved network ingestion. The bounded prefetch buffer lets consumers overlap storage latency without allocating a task or fiber per node.