Enum DriverCommand 

pub enum DriverCommand {
    SendRequest {
        method: Method,
        uri: Uri,
        headers: Headers,
        body: Option<Bytes>,
        response_tx: Sender<Result<StreamResponse>>,
    },
    SendStreamingRequest {
        method: Method,
        uri: Uri,
        headers: Headers,
        body: RequestBody,
        headers_tx: Sender<Result<(u16, Headers)>>,
        body_shared: Arc<H3BodyShared>,
    },
    OpenWebSocketTunnel {
        uri: Uri,
        headers: Vec<(String, String)>,
        response_tx: Sender<Result<H3Tunnel>>,
    },
}

Command sent from handle to driver.

Tunnel-data DATA frames do not flow through this control channel; they take a dedicated mpsc owned by the driver so a freshly issued streaming-request or tunnel-open is never queued behind a burst of in-flight RFC 9220 tunnel writes.

Variants

SendRequest

Send a request and get response via oneshot.

Fields

method: Method

uri: Uri

headers: Headers

body: Option<Bytes>

response_tx: Sender<Result<StreamResponse>>

SendStreamingRequest

Send a request and return headers as soon as they arrive, with DATA routed incrementally through the body channel.

Fields

method: Method

uri: Uri

headers: Headers

body: RequestBody

headers_tx: Sender<Result<(u16, Headers)>>

body_shared: Arc<H3BodyShared>

OpenWebSocketTunnel

Open an RFC 9220 WebSocket-over-HTTP/3 tunnel.

Fields

uri: Uri

headers: Vec<(String, String)>

response_tx: Sender<Result<H3Tunnel>>

Trait Implementations

impl Debug for DriverCommand

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

Formats the value using the given formatter.