Struct SendRequest 

pub struct SendRequest<B> { /* private fields */ }

Available on crate features http-backend and http and std only.

Cloneable sender for a multiplexed HTTP/3 connection.

Implementations

impl<B> SendRequest<B>

pub const fn quic_connection(&self) -> &Connection

Borrow the established transport for live QUIC statistics and path control.

pub async fn peer_settings(&self) -> Result<Settings, Error>

Wait for the peer’s complete SETTINGS, preserving entry order and unknown IDs.

Run the driver concurrently and apply the caller’s handshake deadline. Cancelling this wait leaves the connection and other waiters intact. A connection failure before SETTINGS returns an error. The snapshot is cloned only when requested; observation need not be enabled.

pub fn connection_admission(&self) -> ConnectionAdmission

Publish exact request admission for a multiplexing connection pool.

A checkout reserves local request capacity and peer QUIC stream credit. The request consumes its own ticket; abandoned checkouts return both. The policy holds a weak connection reference, avoiding an extension cycle.

pub fn datagram_drops(&self) -> DatagramDrops

Received HTTP/3 datagrams this connection discarded, by reason.

pub fn take_pushes(&self) -> Option<Pushes>

Take the opt-in push consumer once per connection, shared across sender clones.

pub fn is_closed(&self) -> bool

Whether the underlying connection is terminal.

pub fn is_draining(&self) -> bool

Whether the peer has begun graceful shutdown.

pub fn closed_or_draining(&self) -> impl Future<Output = Error> + Send + 'static

Wait until the peer stops admitting requests or the connection fails. Active streams may continue after graceful shutdown begins.

pub async fn ready(&mut self) -> Result<(), Error>

Check whether this connection still admits new work.

impl<B> SendRequest<B>

where B: Body + Unpin + Send + 'static, <B as Body>::Data: Send, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>>,

pub fn send_request( &mut self, request: Request<B>, ) -> impl Future<Output = Result<Response<Incoming>, Error>> + Send

Send a request on its own bidirectional QUIC stream.

A request carrying a Protocol is sent as Extended CONNECT (RFC 9220) once the server’s SETTINGS enable it; otherwise it fails locally before a stream is opened. A successful (2xx) response exposes the tunnel through the upgrade API.

pub fn send_request_with_priority<F>( &mut self, request: Request<B>, on_stream: F, ) -> impl Future<Output = Result<Response<Incoming>, Error>> + Send

where F: FnOnce(PriorityHandle) + Send + 'static,

Publish this request’s priority handle after opening its stream and before sending HEADERS or awaiting the response. Relays can translate downstream priority changes while the origin is still working. The callback runs once; cancellation before stream admission never calls it.

Trait Implementations

impl<B> Clone for SendRequest<B>

fn clone(&self) -> SendRequest<B>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<B> Debug for SendRequest<B>

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

Formats the value using the given formatter.