Struct RequestResolver

pub struct RequestResolver<C, B>
where
    C: Connection<B>,
    <C as OpenStreams<B>>::BidiStream: SendStream<B>,
    B: Buf,
{ /* private fields */ }

Available on crate feature h3 only.

Helper struct to await the request headers and return a Request object

Implementations

impl<C, B> RequestResolver<C, B>

where C: Connection<B>, B: Buf,

pub async fn resolve_request( self, ) -> Result<(Request<()>, RequestStream<<C as OpenStreams<B>>::BidiStream, B>), StreamError>

Returns a future to await the request headers and return a Request object

pub fn accept_with_frame( self, frame: Result<Option<Frame<PayloadLen>>, FrameStreamError>, ) -> Result<ResolvedRequest<C, B>, StreamError>

Accepts a http request where the first frame has already been read and decoded.

This is needed as a bidirectional stream may be read as part of incoming webtransport bi-streams. If it turns out that the stream is not a WEBTRANSPORT_STREAM the request may still want to be handled and passed to the user.

Trait Implementations

impl<C, B> CloseStream for RequestResolver<C, B>

where C: Connection<B>, B: Buf,

fn handle_connection_error_on_stream( &mut self, internal_error: InternalConnectionError, ) -> StreamError

Handles a connection error on a stream

fn handle_quic_stream_error(&self, error: StreamErrorIncoming) -> StreamError

Handles a incoming stream error from the quic layer

fn check_peer_connection_closing(&self) -> Option<StreamError>

Checks if the peer connection is closing an if it is allowed to send a request / server push

impl<C, B> ConnectionState for RequestResolver<C, B>

where C: Connection<B>, B: Buf,

fn shared_state(&self) -> &SharedState

Get the shared state

fn get_conn_error(&self) -> Option<ErrorOrigin>

Get the connection error if the connection is in error state because of another task

fn set_conn_error(&self, error: ErrorOrigin) -> ErrorOrigin

tries to set the connection error

fn set_conn_error_and_wake<T>(&self, error: T) -> ErrorOrigin

where T: Into<ErrorOrigin>,

set the connection error and wake the connection

fn settings(&self) -> Cow<'_, Settings>

Get the settings

fn set_closing(&self)

Set the connection to closing

fn is_closing(&self) -> bool

Check if the connection is closing

fn set_settings(&self, settings: Settings)

Set the settings

fn waker(&self) -> &AtomicWaker

Returns the waker for the connection