Struct MultiSessionManager 

pub struct MultiSessionManager<T: AsyncReadExt + AsyncWriteExt + Unpin + Send + 'static> { /* private fields */ }

Manager for multiple async sessions with select capabilities.

This provides the core multi-session functionality, allowing you to:

• Manage multiple sessions simultaneously
• Wait for any session to match a pattern (expect_any)
• Wait for all sessions to match patterns (expect_all)
• Send to multiple sessions in parallel
• Select on multiple sessions with different patterns per session

Implementations

impl<T: AsyncReadExt + AsyncWriteExt + Unpin + Send + 'static> MultiSessionManager<T>

pub fn new() -> Self

Create a new multi-session manager.

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

Set the default timeout for operations.

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

Set the default session configuration.

pub fn add( &mut self, session: Session<T>, label: impl Into<String>, ) -> SessionId

Add an existing session to the manager.

Returns the assigned session ID.

pub async fn remove(&mut self, id: SessionId) -> Option<Session<T>>

Remove a session from the manager.

Returns the session if it existed.

pub fn len(&self) -> usize

Get the number of sessions.

pub fn is_empty(&self) -> bool

Check if there are no sessions.

pub fn session_ids(&self) -> Vec<SessionId>

Get all session IDs.

pub async fn label(&self, id: SessionId) -> Option<String>

Get the label for a session.

pub async fn is_active(&self, id: SessionId) -> bool

Check if a session is active.

pub async fn set_active(&self, id: SessionId, active: bool)

Set a session’s active state.

pub async fn active_ids(&self) -> Vec<SessionId>

Get active session IDs.

pub async fn send(&self, id: SessionId, data: &[u8]) -> Result<()>

Send data to a specific session.

Errors

Returns an error if the session doesn’t exist or the send fails.

pub async fn send_line(&self, id: SessionId, line: &str) -> Result<()>

Send a line to a specific session.

Errors

Returns an error if the session doesn’t exist or the send fails.

pub async fn send_all(&self, data: &[u8]) -> Vec<SendResult>

Send data to all active sessions in parallel.

Returns results for each session.

pub async fn expect( &self, id: SessionId, pattern: impl Into<Pattern>, ) -> Result<Match>

Expect a pattern on a specific session.

Errors

Returns an error if the session doesn’t exist or expect fails.

pub async fn expect_any( &self, pattern: impl Into<Pattern>, ) -> Result<SelectResult>

Wait for any session to match the given pattern.

Returns as soon as any session matches. This is the primary multi-session select operation, equivalent to TCL Expect’s multi-spawn expect.

Errors

Returns an error if all sessions timeout or encounter errors.

pub async fn expect_any_of(&self, patterns: &[Pattern]) -> Result<SelectResult>

Wait for any session to match any of the given patterns.

Errors

Returns an error if all sessions timeout or encounter errors.

pub async fn expect_all( &self, pattern: impl Into<Pattern>, ) -> Result<Vec<SelectResult>>

Wait for all sessions to match patterns.

Each session must match at least one pattern. Returns results for all sessions.

Errors

Returns an error if any session fails to match.

pub async fn expect_all_of( &self, patterns: &[Pattern], ) -> Result<Vec<SelectResult>>

Wait for all sessions to match any of the given patterns.

Errors

Returns an error if any session fails.

pub async fn with_session<F, R>(&self, id: SessionId, f: F) -> Result<R>

where F: FnOnce(&mut Session<T>) -> R,

Execute a closure on a specific session.

This provides direct access to the session for operations not covered by the manager’s API.

Errors

Returns an error if the session doesn’t exist.

pub async fn with_session_async<F, Fut, R>( &self, id: SessionId, f: F, ) -> Result<R>

where F: FnOnce(&mut Session<T>) -> Fut, Fut: Future<Output = R>,

Execute an async closure on a specific session.

Errors

Returns an error if the session doesn’t exist.

Trait Implementations

impl<T: AsyncReadExt + AsyncWriteExt + Unpin + Send + 'static> Debug for MultiSessionManager<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: AsyncReadExt + AsyncWriteExt + Unpin + Send + 'static> Default for MultiSessionManager<T>

fn default() -> Self

Returns the “default value” for a type.