Struct SessionServerConnector 

pub struct SessionServerConnector<C, LF, DF> { /* private fields */ }

Accepts connections from a Listener L and serves them with a dispatch, speaking codec C, under a logical scheme.

Two factories keep it transport- and protocol-agnostic:

• listener_factory runs at build time and returns DbResult<L>, so the bind happens there and any error surfaces synchronously from build.
• dispatch_factory turns the live &AimDb into an Arc<dyn Dispatch> (e.g. an AimxDispatch), so the spine never names a concrete protocol.

Implementations

impl<C, LF, DF> SessionServerConnector<C, LF, DF>

pub fn new( listener_factory: LF, codec: C, dispatch_factory: DF, config: SessionConfig, ) -> Self

Build a server connector. listener_factory binds the listener at build time; dispatch_factory produces the per-server dispatch from the live db. The scheme defaults to "remote".

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

Override the scheme this connector registers.

Trait Implementations

impl<L, C, LF, DF> ConnectorBuilder for SessionServerConnector<C, LF, DF>

where L: Listener + 'static, C: EnvelopeCodec + Clone + 'static, LF: Fn() -> DbResult<L> + Send + Sync + 'static, DF: Fn(&AimDb) -> Arc<dyn Dispatch> + Send + Sync + '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.