Trait ActivityManager 

pub trait ActivityManager: Send + Sync {
    // Required methods
    fn snapshot(&self, stream_id: &str) -> Value;
    fn on_activity_op(&self, stream_id: &str, activity_type: &str, op: &Op);
}

Manager for activity state updates.

Implementations keep per-stream activity state and may emit external events.

Required Methods

fn snapshot(&self, stream_id: &str) -> Value

Get the current activity snapshot for a stream.

fn on_activity_op(&self, stream_id: &str, activity_type: &str, op: &Op)

Handle an activity operation for a stream.

Implementors

impl ActivityManager for NoOpActivityManager