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,
        body_shared: Arc<H2BodyShared>,
        headers_tx: Sender<Result<(u16, Vec<(String, String)>)>>,
        trailers_tx: Option<Sender<Result<Vec<(String, String)>>>>,
    },
    OpenWebSocketTunnel {
        uri: Uri,
        headers: Vec<(String, String)>,
        response_tx: Sender<Result<H2Tunnel>>,
    },
    SendTunnelData {
        stream_id: u32,
        outbound: H2TunnelOutbound,
    },
}

Command sent from handle to driver

Variants

SendRequest

Send a request and get response via oneshot Driver allocates stream_id

Fields

method: Method

uri: Uri

headers: Headers

body: Option<Bytes>

response_tx: Sender<Result<StreamResponse>>

SendStreamingRequest

Send a request with a streaming body

Fields

method: Method

uri: Uri

headers: Headers

body: RequestBody

body_shared: Arc<H2BodyShared>

headers_tx: Sender<Result<(u16, Vec<(String, String)>)>>

trailers_tx: Option<Sender<Result<Vec<(String, String)>>>>

Side-channel sender for HTTP/2 response trailers. Some only when the caller requested trailers (request carried te: trailers); None keeps the warm streaming path allocation-free.

OpenWebSocketTunnel

Open an RFC 8441 WebSocket tunnel on a pooled HTTP/2 stream.

Fields

uri: Uri

headers: Vec<(String, String)>

response_tx: Sender<Result<H2Tunnel>>

SendTunnelData

Queue outbound DATA for an open RFC 8441 tunnel.

Fields

stream_id: u32

outbound: H2TunnelOutbound

Trait Implementations

impl Debug for DriverCommand

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

Formats the value using the given formatter.