Struct SessionHandle 

pub struct SessionHandle { /* private fields */ }

A handle for managing HTTP transport sessions and final subscription streams.

Obtained from HttpTransport::into_router_with_handle() or HttpTransport::into_router_at_with_handle(). The handle is cheap to clone and can be shared across threads.

Example

use tower_mcp::transport::http::HttpTransport;

let transport = HttpTransport::new(router);
let (router, handle) = transport.into_router_with_handle();

// Later, in an admin endpoint:
let count = handle.session_count().await;
for info in handle.list_sessions().await {
    println!("{}: created {:?} ago", info.id, info.created_at);
}
handle.terminate_session("session-id").await;

// During graceful server shutdown (with the `stateless` feature):
handle.close_subscriptions();

Implementations

impl SessionHandle

pub async fn session_count(&self) -> usize

Returns the number of currently active sessions.

pub async fn list_sessions(&self) -> Vec<SessionInfo>

Returns metadata for all active sessions.

pub async fn terminate_session(&self, id: &str) -> bool

Terminates a session by ID, returning true if the session existed.

pub fn subscription_count(&self) -> usize

Returns the number of active final-protocol subscription streams.

pub fn close_subscriptions(&self) -> usize

Gracefully finish every active final-protocol subscription stream.

Each stream receives its terminal SubscriptionsListenResult before closing. Returns the number of streams that were drained.

Trait Implementations

impl Clone for SessionHandle

fn clone(&self) -> SessionHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.