Struct ARCPRuntime 

pub struct ARCPRuntime { /* private fields */ }

The ARCP runtime. Cheap to clone; share across tasks.

Implementations

impl ARCPRuntime

pub fn builder() -> RuntimeBuilder

Construct via RuntimeBuilder.

pub fn event_log(&self) -> &EventLog

Borrow the runtime’s event log.

pub fn artifacts(&self) -> &ArtifactStore

Borrow the runtime’s artifact store.

pub fn subscriptions(&self) -> &SubscriptionManager

Borrow the runtime’s subscription manager.

pub fn serve_connection<T: Transport + 'static>( &self, transport: T, ) -> JoinHandle<()>

Spawn a per-connection task that drives the handshake and then dispatches subsequent envelopes. The returned JoinHandle is owned by the caller — Phase 2 doesn’t yet integrate with a connection registry.

pub async fn run_connection<T: Transport + 'static>( &self, transport: T, ) -> Result<(), ARCPError>

Drive one connection synchronously (in the caller’s task).

Errors

Returns ARCPError for transport / serialisation failures or for internal protocol errors (rare).

Trait Implementations

impl Clone for ARCPRuntime

fn clone(&self) -> ARCPRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ARCPRuntime

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

Formats the value using the given formatter.