pub struct Connection<T, B, E>where
T: Read + Write + Unpin,
B: Body + 'static,
E: Http2ClientConnExec<B, T> + Unpin,
B::Error: Into<Box<dyn Error + Send + Sync>>,{
inner: (PhantomData<T>, ClientTask<B, E, T>),
}
Expand description
A future that processes all HTTP state for the IO object.
In most cases, this should just be spawned into an executor, so that it can process incoming and outgoing messages, notice hangups, and the like.
Instances of this type are typically created via the handshake
function
Fields§
§inner: (PhantomData<T>, ClientTask<B, E, T>)
Implementations§
Source§impl<T, B, E> Connection<T, B, E>
impl<T, B, E> Connection<T, B, E>
Sourcepub fn is_extended_connect_protocol_enabled(&self) -> bool
pub fn is_extended_connect_protocol_enabled(&self) -> bool
Returns whether the extended CONNECT protocol is enabled or not.
This setting is configured by the server peer by sending the
SETTINGS_ENABLE_CONNECT_PROTOCOL
parameter in a SETTINGS
frame.
This method returns the currently acknowledged value received from the
remote.
Trait Implementations§
Source§impl<T, B, E> Debug for Connection<T, B, E>
impl<T, B, E> Debug for Connection<T, B, E>
Source§impl<T, B, E> Future for Connection<T, B, E>
impl<T, B, E> Future for Connection<T, B, E>
Auto Trait Implementations§
impl<T, B, E> Freeze for Connection<T, B, E>
impl<T, B, E> !RefUnwindSafe for Connection<T, B, E>
impl<T, B, E> Send for Connection<T, B, E>
impl<T, B, E> Sync for Connection<T, B, E>
impl<T, B, E> Unpin for Connection<T, B, E>
impl<T, B, E> !UnwindSafe for Connection<T, B, E>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_cancellation_token(
self,
cancellation_token: &CancellationToken,
) -> WithCancellationTokenFuture<'_, Self>where
Self: Sized,
fn with_cancellation_token(
self,
cancellation_token: &CancellationToken,
) -> WithCancellationTokenFuture<'_, Self>where
Self: Sized,
Similar to
CancellationToken::run_until_cancelled
,
but with the advantage that it is easier to write fluent call chains,
and biased towards waiting for CancellationToken
to complete. Read moreSource§fn with_cancellation_token_owned(
self,
cancellation_token: CancellationToken,
) -> WithCancellationTokenFutureOwned<Self>where
Self: Sized,
fn with_cancellation_token_owned(
self,
cancellation_token: CancellationToken,
) -> WithCancellationTokenFutureOwned<Self>where
Self: Sized,
Similar to
CancellationToken::run_until_cancelled_owned
,
but with the advantage that it is easier to write fluent call chains,
and biased towards waiting for CancellationToken
to complete. Read moreSource§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<F> IntoFuture for Fwhere
F: Future,
impl<F> IntoFuture for Fwhere
F: Future,
Source§type IntoFuture = F
type IntoFuture = F
Which kind of future are we turning this into?
Source§fn into_future(self) -> <F as IntoFuture>::IntoFuture
fn into_future(self) -> <F as IntoFuture>::IntoFuture
Creates a future from a value. Read more