Struct EventWatcher 

pub struct EventWatcher { /* private fields */ }

Long poll event consumer with caller visible cursor state.

Implementations

impl EventWatcher

pub fn builder() -> EventWatcherBuilder

Start building an event watcher.

pub fn current_cursor(&self) -> Option<&EventCursor>

Return the cursor from the last successful batch.

Callers persist this value after applying each batch, then pass it to EventWatcherBuilder::since when rebuilding a watcher.

pub fn seek(&mut self, cursor: EventCursor)

Override the next request cursor.

pub async fn next(&mut self) -> Result<EventBatch, ClientError>

Fetch the next event batch and advance this watcher’s cursor.

Trait Implementations

impl Clone for EventWatcher

fn clone(&self) -> EventWatcher

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EventWatcher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.