Struct LocalTransport 

pub struct LocalTransport { /* private fields */ }

Implementations

impl LocalTransport

pub async fn attach( handle: SessionHandle, meta: ClientMeta, ) -> Result<(Self, AttachSnapshot), TransportError>

Attach in-process as a Mirror (= attach_with(.., Mirror)).

pub async fn attach_with( handle: SessionHandle, meta: ClientMeta, mode: AttachMode, ) -> Result<(Self, AttachSnapshot), TransportError>

Attach in-process: sends Attach, awaits the Attached envelope (bounded 5 s), returns the transport + snapshot.

pub fn handle(&self) -> &SessionHandle

Trait Implementations

impl ClientTransport for LocalTransport

fn session_id(&self) -> &SessionId

fn meta(&self) -> &SessionMeta

fn send<'life0, 'async_trait>( &'life0 self, cmd: SessionCommand, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Host-originated send (from: None; bypasses input ownership).

fn send_from_self<'life0, 'async_trait>( &'life0 self, cmd: SessionCommand, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send stamped with this client’s id (the TUI uses this; ownership is enforced by the actor, B1).

fn next_event<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Option<Envelope>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Next envelope, or None when the session ended / socket closed.

fn view(&self) -> Arc<RuntimeView>

Sync, cheap, never stale by more than one SettingChanged: what the TUI’s getters read on day 2.

fn client_id(&self) -> ClientId

Client id assigned at Attach (needed for Detach/Resync).

fn mode(&self) -> AttachMode

The mode this transport attached with.

fn input_owner(&self) -> Option<ClientId>

Current input owner — updated from Attached / InputOwnerChanged.

fn reconnect<'life0, 'async_trait>( &'life0 mut self, _mode: AttachMode, ) -> Pin<Box<dyn Future<Output = Result<AttachSnapshot, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Socket only (Local returns Err(Unsupported)): after Reloading/EOF, reconnect with backoff and re-attach with mode (C3/A4).

fn reconnect_once<'life0, 'async_trait>( &'life0 mut self, mode: AttachMode, ) -> Pin<Box<dyn Future<Output = Result<AttachSnapshot, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

F9: single reconnect attempt (no retry loop). Socket only.

fn is_reload_pending(&self) -> bool

true if the daemon announced a reload before EOF (graceful). Always false on LocalTransport.

fn daemon_pid(&self) -> u32

The daemon pid from Welcome. Returns 0 on LocalTransport.