Struct OperationEvents 

pub struct OperationEvents { /* private fields */ }

A cursor over one prepared invocation, independent of its writer’s liveness.

Implementations

impl OperationEvents

pub fn open(operation: &OperationHandle) -> Result<Self>

Read from this invocation’s first event, even before its writer starts.

pub fn resume(operation: &OperationHandle, cursor: &str) -> Result<Self>

Continue from an opaque cursor belonging to this invocation.

pub fn read(&mut self) -> Result<Vec<Envelope>>

Return new complete envelopes; an empty batch makes no completion claim.

pub fn cursor(&self) -> String

Persist the position after the last returned record.

Trait Implementations

impl Debug for OperationEvents

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

Formats the value using the given formatter.