Struct SessionSourceInitiatorBuilder 

pub struct SessionSourceInitiatorBuilder<'a, S> { /* private fields */ }

Implementations

impl<'a, S> SessionSourceInitiatorBuilder<'a, S>

pub fn parity(self, parity: Parity) -> Self

pub fn root_settings(self, settings: ConnectionSettings) -> Self

pub fn max_concurrent_requests(self, max_concurrent_requests: u32) -> Self

pub fn channel_capacity(self, channel_capacity: u32) -> Self

pub fn observer(self, observer: impl VoxObserver) -> Self

pub fn observer_handle(self, observer: VoxObserverHandle) -> Self

pub fn metadata(self, metadata: Metadata<'a>) -> Self

pub fn on_connection(self, acceptor: impl ConnectionAcceptor) -> Self

pub fn keepalive(self, keepalive: SessionKeepaliveConfig) -> Self

pub fn connect_timeout(self, timeout: Duration) -> Self

pub fn recovery_timeout(self, timeout: Duration) -> Self

pub fn resumable(self) -> Self

pub fn non_resumable(self) -> Self

Disable session resumability. Useful for IPC transports where the peer is a process: when the process exits the connection is gone for good, there’s nothing to resume against, and keeping the session alive in recovery mode just leaks per-channel state (e.g. server-side Tx<T>s never observing that the client disconnected).

pub fn operation_store(self, operation_store: Arc<dyn OperationStore>) -> Self

pub fn spawn_fn(self, f: impl FnOnce(BoxSessionFuture) + Send + 'static) -> Self

pub async fn establish<Client: FromVoxSession>( self, ) -> Result<Client, SessionError>

where S: LinkSource, S::Link: Link + MaybeSend + 'static, <S::Link as Link>::Tx: MaybeSend + MaybeSync + 'static, <S::Link as Link>::Rx: MaybeSend + 'static,