Struct ProtocolCoreHandle 

pub struct ProtocolCoreHandle { /* private fields */ }

Implementations

impl ProtocolCoreHandle

pub fn spawn( core: ProtocolCore, executor: Arc<dyn EffectExecutor>, cancellation: CancellationToken, runtime: &RuntimeHandle, ) -> Self

pub fn claim_body(&self, session: &SessionId, token: &str) -> Option<WireBody>

pub fn claim_body_stream( &self, session: &SessionId, token: &str, ) -> Option<BodyStream>

pub fn register_body( &self, session: &SessionId, body: WireBody, ) -> Result<BodyId, CoreError>

pub async fn submit(&self, input: CoreInput) -> Result<(), WsError>

pub async fn submit_batch(&self, inputs: Vec<CoreInput>) -> Result<(), WsError>

pub async fn install<F>( &self, input: CoreInput, publish: F, ) -> Result<(), WsError>

where F: FnOnce() + Send + 'static,

pub async fn attach<H: SessionHandler>( &self, session: SessionId, transport: Pipe, expected_peer: Option<String>, handler: H, ) -> Result<Arc<Wire>, WsError>

pub async fn attach_with_ceiling<H: SessionHandler>( &self, session: SessionId, transport: Pipe, expected_peer: Option<String>, handler: H, ws_collect_ceiling: usize, ) -> Result<Arc<Wire>, WsError>

pub fn shutdown(&self)

Trait Implementations

impl Clone for ProtocolCoreHandle

fn clone(&self) -> ProtocolCoreHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.