Struct ConnTask

pub struct ConnTask<T, B>
where
    B: Body,
    T: Read + Write + Unpin,
{
    drop_rx: Receiver<Infallible>,
    cancel_tx: Option<Sender<Infallible>>,
    conn: ConnMapErr<T, B>,
}

Fields

drop_rx: Receiver<Infallible>

cancel_tx: Option<Sender<Infallible>>

conn: ConnMapErr<T, B>

Implementations

impl<T, B> ConnTask<T, B>

where B: Body, T: Read + Write + Unpin,

fn new( conn: ConnMapErr<T, B>, drop_rx: Receiver<Infallible>, cancel_tx: Sender<Infallible>, ) -> Self

Trait Implementations

impl<T, B> Future for ConnTask<T, B>

where B: Body, T: Read + Write + Unpin,

type Output = ()

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.

impl<'__pin, T, B> Unpin for ConnTask<T, B>

where PinnedFieldsOf<__Origin<'__pin, T, B>>: Unpin, B: Body, T: Read + Write + Unpin,