Struct UpgradedSendStreamTask 

pub struct UpgradedSendStreamTask<B> {
    h2_tx: SendStream<SendBuf<B>>,
    rx: Receiver<Cursor<Box<[u8]>>>,
    error_tx: Option<Sender<Error>>,
}

Fields

h2_tx: SendStream<SendBuf<B>>

rx: Receiver<Cursor<Box<[u8]>>>

error_tx: Option<Sender<Error>>

Implementations

impl<B> UpgradedSendStreamTask<B>

where B: Buf,

fn tick(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Error>>

Trait Implementations

impl<B> Future for UpgradedSendStreamTask<B>

where B: Buf,

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, B> Unpin for UpgradedSendStreamTask<B>

where PinnedFieldsOf<__Origin<'__pin, B>>: Unpin,