Struct Connection

pub struct Connection { /* private fields */ }

An open connection from an RPC client.

Tracks information that persists from one request to another.

The client might not have authenticated; access and permissions control is handled via the capability system. Specifically, the objects table in Inner hold capabilities that the client will use to do things, including an RpcSession.

In the Arti RPC System

A connection to Arti.

This object is available as soon as you open a connection to Arti RPC, even before you authenticate. Its ObjectId is always "connection".

Because this object is available before authentication, it provides only those methods that you need in order to perform authentication and receive an RpcSession.

Implementations

impl Connection

pub async fn run<IN, OUT>( self: Arc<Self>, input: IN, output: OUT, ) -> Result<(), ConnectionError>

where IN: AsyncRead + Send + Sync + Unpin + 'static, OUT: AsyncWrite + Send + Sync + Unpin + 'static,

Run in a loop, decoding JSON requests from input and writing JSON responses onto output.

Trait Implementations

impl Context for Connection

fn lookup_object(&self, id: &ObjectId) -> Result<Arc<dyn Object>, LookupError>

Look up an object by identity within this context.

fn register_owned(&self, object: Arc<dyn Object>) -> ObjectId

Create an owning reference to object within this context.

fn release_owned(&self, id: &ObjectId) -> Result<(), LookupError>

Drop an owning reference to the object called object within this context.

fn dispatch_table(&self) -> &Arc<RwLock<DispatchTable>>

Return a dispatch table that can be used to invoke other RPC methods.

impl Object for Connection

where Connection: Send + Sync + 'static,

fn get_cast_table(&self) -> &CastTable

Return a CastTable that can be used to downcast a dyn Object of this type into various kinds of dyn Trait references.

fn expose_outside_of_session(&self) -> bool

Return true if this object should be given an identifier that allows it to be used outside of the session that generated it.

fn delegate(&self) -> Option<Arc<dyn Object>>

Optionally, return a delegation target for this `Object``.