Struct StaticSource 

pub struct StaticSource { /* private fields */ }

In-memory SyncSource used by tests.

Holds a list of pre-baked PullResult batches and serves them in order; once exhausted, subsequent calls return an empty batch with has_more = false.

Implementations

impl StaticSource

pub fn new(id: impl Into<String>, batches: Vec<PullResult>) -> Self

Build a static source with the given id and batches.

pub fn from_deltas(id: impl Into<String>, deltas: Vec<Delta>) -> Self

Convenience: build a single-batch source from a flat delta list.

pub fn enqueue(&self, batch: PullResult)

Push another batch to be served on the next pull.

Trait Implementations

impl SyncSource for StaticSource

fn id(&self) -> &str

Stable id of the source (matches Provenance::source).

fn pull<'life0, 'async_trait>( &'life0 self, _cursor: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<PullResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Pull the next batch of deltas. cursor is the value the source returned from the previous call, or None for the first pull.

fn subscribe<'life0, 'async_trait>( &'life0 self, cursor: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<DeltaStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribe to a live stream of deltas starting from cursor.