Struct ExternalDurableStream 

pub struct ExternalDurableStream<T> { /* private fields */ }

A single-reader, one-batch-buffered external source. &mut self serializes reads. A delivered batch is drained before its opaque checkpoint is promoted. Dropping a pending next cancels that attempt without advancing the checkpoint. Live readers are reconstructed by replay, not serialized as native stream handles.

Implementations

impl<T: DeserializeOwned> ExternalDurableStream<T>

pub fn json(url: impl Into<String>, options: ReadOptions) -> Self

impl ExternalDurableStream<u8>

pub fn bytes(url: impl Into<String>, options: ReadOptions) -> Self

Bytes are a sequence, not the original append chunk boundaries.

impl<T> ExternalDurableStream<T>

pub fn checkpoint(&self) -> &Checkpoint

Last fully drained checkpoint. A partially consumed batch retains its original offset.

pub fn close(&mut self)

Stop pulling and discard buffered items. To cancel an active pull, drop its future first.

pub async fn next(&mut self) -> Result<Option<T>, Error>

pub async fn collect(self) -> Result<Vec<T>, Error>