Struct ClientTask

pub(crate) struct ClientTask<B, E, T>
where
    B: Body,
    E: Unpin,
{
    ping: Recorder,
    conn_drop_ref: Sender<Infallible>,
    conn_eof: Receiver<Infallible>,
    executor: E,
    h2_tx: SendRequest<SendBuf<B::Data>>,
    req_rx: Receiver<Request<B>, Response<Incoming>>,
    fut_ctx: Option<FutCtx<B>>,
    marker: PhantomData<T>,
}

Fields

ping: Recorder

conn_drop_ref: Sender<Infallible>

conn_eof: Receiver<Infallible>

executor: E

h2_tx: SendRequest<SendBuf<B::Data>>

req_rx: Receiver<Request<B>, Response<Incoming>>

fut_ctx: Option<FutCtx<B>>

marker: PhantomData<T>

Implementations

impl<B, E, T> ClientTask<B, E, T>

where B: Body + 'static, E: Http2ClientConnExec<B, T> + Unpin, B::Error: Into<Box<dyn Error + Send + Sync>>, T: Read + Write + Unpin,

pub(crate) fn is_extended_connect_protocol_enabled(&self) -> bool

impl<B, E, T> ClientTask<B, E, T>

where B: Body + 'static + Unpin, B::Data: Send, E: Http2ClientConnExec<B, T> + Unpin, B::Error: Into<Box<dyn Error + Send + Sync>>, T: Read + Write + Unpin,

fn poll_pipe(&mut self, f: FutCtx<B>, cx: &mut Context<'_>)

Trait Implementations

impl<B, E, T> Future for ClientTask<B, E, T>

where B: Body + 'static + Unpin, B::Data: Send, B::Error: Into<Box<dyn Error + Send + Sync>>, E: Http2ClientConnExec<B, T> + Unpin, T: Read + Write + Unpin,

type Output = Result<Dispatched, Error>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.