Struct EventStream 

pub struct EventStream { /* private fields */ }

Event stream with broadcast capability for real-time subscribers

Implementations

impl EventStream

pub fn new() -> Self

Create a new event stream with specified channel capacity

pub fn with_capacity(capacity: usize) -> Self

Create event stream with custom channel capacity

pub fn append( &self, event_type: EventType, workflow_id: WorkflowId, data: JsonValue, ) -> Event

Append a new event and broadcast to all subscribers

pub fn append_with_parent( &self, event_type: EventType, workflow_id: WorkflowId, parent_workflow_id: Option<WorkflowId>, data: JsonValue, ) -> Event

Append event with optional parent workflow ID

pub fn subscribe(&self) -> Receiver<Event>

Subscribe to real-time event stream Returns a receiver that will get all future events

pub fn from_offset(&self, offset: EventOffset) -> Vec<Event>

Get events from a specific offset (for replay)

pub fn all(&self) -> Vec<Event>

Get all events

pub fn len(&self) -> usize

Get event count

pub fn is_empty(&self) -> bool

pub fn current_offset(&self) -> EventOffset

Get the current offset (next event will have this offset)

Trait Implementations

impl Clone for EventStream

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for EventStream

fn default() -> Self

Returns the “default value” for a type.