Struct H2WsConnection 

pub struct H2WsConnection { /* private fields */ }

An HTTP/2 connection that can open WebSocket streams via extended CONNECT.

Internally this wraps hyper’s HTTP/2 client connection and keeps the SendRequest handle alive. The HTTP/2 connection driver is spawned on a background task.

Implementations

impl H2WsConnection

pub async fn connect_tcp(addr: &str) -> Result<Self, H2WsError>

Establish a new HTTP/2 client connection over plain TCP (h2c).

This helper is TCP-specific. If you need TLS, you can add a method like connect_tls that wraps a TLS stream and passes it into Self::from_io.

pub async fn from_io<I>(io: I) -> Result<Self, H2WsError>

where I: AsyncRead + AsyncWrite + Unpin + Send + 'static,

Create an H2WsConnection from an arbitrary I/O stream.

The io type must implement AsyncRead + AsyncWrite + Unpin + Send + 'static. This allows integrating with custom transports (TLS, Unix sockets, etc).

pub async fn connect_websocket( &mut self, path: &str, host: &str, subprotocol: Option<&str>, ) -> Result<H2WebSocketStream, H2WsError>

Open a WebSocket over this HTTP/2 connection using RFC 8441 extended CONNECT.

• path: HTTP request path, e.g. "/echo".
• host: value for the Host header, e.g. "localhost".
• subprotocol: optional WebSocket subprotocol, e.g. "echo" or "graphql-ws".

This method:

1. Sends a CONNECT request with :protocol = "websocket".
2. Checks that the status code is 2xx.
3. Calls hyper::upgrade::on to obtain the upgraded I/O stream.
4. Wraps the upgraded stream in tokio_tungstenite::WebSocketStream.

Trait Implementations

impl Debug for H2WsConnection

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

Formats the value using the given formatter.