Struct GraphSubscriber 

pub struct GraphSubscriber { /* private fields */ }

Async helper that pairs a SharedGraph with a broadcast receiver to yield batches of GraphDiff entries whenever the graph changes.

Example

let subscriber = GraphSubscriber::new(graph.clone());
loop {
    match subscriber.next_batch().await {
        Ok(diffs) => { /* process diffs */ }
        Err(gap) => { /* full resync needed */ }
    }
}

Implementations

impl GraphSubscriber

pub fn new(graph: SharedGraph) -> Self

Create a new subscriber starting from the graph’s current version.

pub fn from_version(graph: SharedGraph, version: u64) -> Self

Create a subscriber starting from a specific version.

Useful for resuming after a reconnect.

pub async fn next_batch(&mut self) -> Result<Vec<GraphDiff>, ChangelogGap>

Wait for the next batch of changes and return them.

Blocks (async) until at least one write occurs, then returns all diffs since the last consumed version. Returns Err(ChangelogGap) if the subscriber has fallen too far behind.

pub fn version(&self) -> u64

The last version this subscriber has consumed.