Struct OpenStreamReceiver 

pub struct OpenStreamReceiver { /* private fields */ }

Transport-facing CEP-41 receiver wrapping a per-peer registry.

Implementations

impl OpenStreamReceiver

pub fn new() -> Self

Create a receiver with the default policy.

pub fn with_policy(policy: OpenStreamRegistryPolicy) -> Self

Create a receiver with an explicit registry policy.

pub fn is_open_stream_frame(notification: &JsonRpcNotification) -> bool

Returns true when notification carries a CEP-41 frame in params.cvm.

pub async fn process_frame( &mut self, notification: &JsonRpcNotification, ) -> Result<FrameOutcome, OpenStreamError>

Feed one inbound notifications/progress frame to the registry, stamping liveness with the real clock.

pub fn get_session(&self, progress_token: &str) -> Option<OpenStreamSession>

Look up an active reader session by token.

pub fn active_stream_count(&self) -> usize

Number of active streams.

pub fn registry(&self) -> &OpenStreamRegistry

Borrow the underlying registry (e.g. to create an outbound reader session or drive the keepalive sweep).

pub fn registry_mut(&mut self) -> &mut OpenStreamRegistry

Mutably borrow the underlying registry.

pub fn clear(&mut self)

Dispose all sessions and clear the registry.

Trait Implementations

impl Default for OpenStreamReceiver

fn default() -> Self

Returns the “default value” for a type.