Struct H2Stream 

pub struct H2Stream<F, B, E>
where
    B: Body,
{
    reply: SendResponse<SendBuf<B::Data>>,
    state: H2StreamState<F, B>,
    date_header: bool,
    exec: E,
}

Fields

reply: SendResponse<SendBuf<B::Data>>

state: H2StreamState<F, B>

date_header: bool

exec: E

Implementations

impl<F, B, E> H2Stream<F, B, E>

where B: Body,

fn new( fut: F, connect_parts: Option<ConnectParts>, respond: SendResponse<SendBuf<B::Data>>, date_header: bool, exec: E, ) -> H2Stream<F, B, E>

impl<F, B, Ex, E> H2Stream<F, B, Ex>

where F: Future<Output = Result<Response<B>, E>>, B: Body, B::Data: 'static, B::Error: Into<Box<dyn StdError + Send + Sync>>, Ex: Http2UpgradedExec<B::Data>, E: Into<Box<dyn StdError + Send + Sync>>,

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

Trait Implementations

impl<F, B, Ex, E> Future for H2Stream<F, B, Ex>

where F: Future<Output = Result<Response<B>, E>>, B: Body, B::Data: 'static, B::Error: Into<Box<dyn StdError + Send + Sync>>, Ex: Http2UpgradedExec<B::Data>, E: Into<Box<dyn StdError + Send + Sync>>,

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, F, B, E> Unpin for H2Stream<F, B, E>

where PinnedFieldsOf<__Origin<'__pin, F, B, E>>: Unpin, B: Body,