Struct DataStreamRegistry 

pub struct DataStreamRegistry { /* private fields */ }

DataStreamRegistry - Stream chunk callback manager

Responsibilities

• Receive DataStream from LatencyFirst Lane (stream-format data packets)
• Maintain stream_id → callback mapping
• Concurrently invoke user-registered data stream callbacks

Typical Use Cases

• Streaming RPC (server-side push streams)
• Real-time collaborative editing (multi-user editing sync)
• Game state streams (position updates, event streams)
• Log streams, sensor data streams, metrics streams

Implementations

impl DataStreamRegistry

pub fn new() -> Self

pub fn register(&self, stream_id: String, callback: DataStreamCallback)

Register stream callback

Arguments

• stream_id: stream identifier (must be globally unique)
• callback: data stream handler callback

pub fn unregister(&self, stream_id: &str)

Unregister stream callback

Arguments

• stream_id: stream identifier to unregister

pub async fn dispatch(&self, chunk: DataStream, sender_id: ActrId)

Dispatch data stream to callback (concurrent execution)

Arguments

• chunk: data stream
• sender_id: sender ActrId

Performance

• Direct callback invocation, no queueing overhead
• Latency: ~10μs
• Concurrent execution, doesn’t block other streams

pub fn active_streams(&self) -> usize

Get active stream count

Trait Implementations

impl Default for DataStreamRegistry

fn default() -> Self

Returns the “default value” for a type.