Struct H2Transport 

pub struct H2Transport { /* private fields */ }

A single HTTP/2 stream’s transport handle.

Carries a backref to the shared H2Connection, the stream id, and the per-stream Arc<StreamState> used by the read side. Normal HTTP/2 operation reads through ReceivedBody and writes through the connection’s send queue; the AsyncRead / AsyncWrite impls here are only reached by code that borrows the transport directly (typically an upgrade handler after extended CONNECT).

Implementations

impl H2Transport

pub fn stream_id(&self) -> u32

The stream identifier this transport is bound to.

pub fn connection(&self) -> &Arc<H2Connection>

The shared H2Connection backing this stream.

Trait Implementations

impl AsyncRead for H2Transport

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

Attempt to read from the AsyncRead into buf.

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

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl AsyncWrite for H2Transport

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<()>>

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

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

Attempt to close the object.

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

Attempt to write bytes from bufs into the object using vectored IO operations.

impl Debug for H2Transport

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

Formats the value using the given formatter.

impl Drop for H2Transport

fn drop(&mut self)

Application-side release / cancel signal, depending on stream state:

• Wire-closed cleanly (send.completed && recv.eof): the application is done with a stream that already finished on the wire. The client-role lifecycle keeps such streams in the map after wire-close (see H2Driver::try_close_if_both_done) so the application’s transport handle remains valid for trailer / late-read access. Dropping the transport is the signal that the application is done, and we forward it to the connection so the driver removes the entry from both maps.

• Wire-incomplete (handler panic, conn task abandoned, client awaiting a response that never came): emit RST_STREAM(Cancel) so the peer learns we’re abandoning the stream. Without this the leak persists until the entire connection tears down. Symmetric for both roles.

• Already gone from the shared map: driver beat us to cleanup; no-op.

• Upgrade path graceful close in flight (outbound_close_requested): user has already asked for graceful close via Self::poll_close; the driver is draining the outbound queue + emitting DATA(END_STREAM). Don’t RST in that window.