Struct Session 

pub struct Session<T: AsyncRead + AsyncWrite + Send + Unpin + 'static> { /* private fields */ }

Network multiplexing session

Session is the core component of network multiplexing, managing multiple independent streams over a single underlying connection. Each session can handle multiple streams simultaneously, with each stream having its own unique stream ID and lifecycle.

Implementations

impl<T: AsyncRead + AsyncWrite + Send + Unpin + 'static> Session<T>

pub fn server(conn: T, config: Config) -> Self

Create a server session.

pub fn client(conn: T, config: Config) -> Self

Create a client session.

pub async fn open(&self) -> Result<Stream, Error>

Open a new stream

This method allocates a new stream ID, creates the corresponding stream object, and sends a SYN frame to establish the connection. The returned stream can be used for data transmission.

pub async fn accept(&self) -> Result<Stream, Error>

Accept a new stream connection

This method waits for stream creation requests from the remote end, then creates the corresponding stream object. Typically used by servers to accept connection requests from clients.

pub fn close(self)

Close the session

This method gracefully closes the session, including:

• Setting the shutdown flag
• Notifying all background tasks to stop
• Closing the underlying connection

Note: After calling this method, the session can no longer be used to send data.