Struct SessionBound 

pub struct SessionBound<W> { /* private fields */ }

A channel writer that ends with an error when the session does.

The bug this exists to make impossible (cov-13 finding 4, 2026-10-06)

russh’s channel writer (ChannelTx, what make_writer returns) waits for SSH window on a Notify that only a window-adjust from the client fires. A session that ENDS fires nothing. So a clone or fetch streaming a pack to a client whose link died — the window shut, the session then ended by the keepalive — left the transfer parked forever: its fan worker, its admission slot, its memory-ledger charge, its store handle, all held for good. One dead client per leak, until the fan refuses everyone.

Every poll here also polls the session’s end, so the parked write wakes and fails with session_ended_error the moment the session is gone.

Implementations

impl<W> SessionBound<W>

pub fn new(inner: W, over: SessionOver) -> Self

Bind inner to the session over watches.

Trait Implementations

impl<W: AsyncWrite + Unpin> AsyncWrite for SessionBound<W>

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl<W> Debug for SessionBound<W>

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

Formats the value using the given formatter.