Struct SessionClientConnector 

pub struct SessionClientConnector<D, C> { /* private fields */ }

Mirrors records to/from a peer reached via the dialer D, speaking codec C, under a logical scheme. A transport crate wraps it in a one-line sugar constructor (e.g. UdsClient).

Implementations

impl<D, C> SessionClientConnector<D, C>

pub fn new(dialer: D, codec: C) -> Self

Mirror records over dialer, framing messages with codec. The scheme defaults to "remote".

pub fn scheme(self, scheme: impl Into<String>) -> Self

Override the scheme this connector registers (so <scheme>://<record> links validate and route here).

pub fn with_config(self, config: ClientConfig) -> Self

Override the client engine config (reconnect policy, keepalive, etc.).

Trait Implementations

impl<D, C> ConnectorBuilder for SessionClientConnector<D, C>

where D: Dialer + Send + 'static, C: EnvelopeCodec + Clone + 'static,

fn build<'a>( &'a self, db: &'a AimDb, ) -> Pin<Box<dyn Future<Output = DbResult<Vec<Pin<Box<dyn Future<Output = ()> + Send + 'static>>>>> + Send + 'a>>

Build the connector and return its driving futures.

fn scheme(&self) -> &str

The URL scheme this connector handles

fn owns_scheme(&self) -> bool

Whether registering a second connector under this scheme is an error.