Struct H2Driver 

pub struct H2Driver<T> { /* private fields */ }

Owns the per-connection TCP transport and drives the HTTP/2 demux loop.

See the module docs for the high-level driver shape and how its impl is split across the recv and send child modules.

Implementations

impl<T> H2Driver<T>

where T: AsyncRead + AsyncWrite + Unpin + Send,

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

The shared H2Connection this acceptor was created from.

pub fn next(&mut self) -> Next<'_, T>

Drive the connection until the next request stream opens, the connection ends, or a fatal protocol or I/O error occurs.

Returns Ok(Some(conn)) for each new request stream — the runtime adapter is expected to spawn a handler task that consumes the Conn. Malformed requests (RFC 9113 §8.1.2) are handled internally with a stream-level RST_STREAM and never surfaced. Returns Ok(None) when the connection has been shut down cleanly (peer GOAWAY, our own swansong shutdown, peer EOF at a frame boundary).

Errors

The returned future resolves to an H2Error for any connection-level protocol violation detected while decoding peer frames or for an unrecoverable transport I/O error. A final GOAWAY is sent before a protocol error is returned (best-effort; I/O errors skip it).

Trait Implementations

impl<T: Debug> Debug for H2Driver<T>

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

Formats the value using the given formatter.

impl<T> Stream for H2Driver<T>

where T: AsyncRead + AsyncWrite + Unpin + Send,

type Item = Result<Conn<H2Transport>, H2Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.