Type Alias hyper::server::conn::Http1Dispatcher
source · type Http1Dispatcher<T, B, S> = Dispatcher<Server<S, Body>, B, T, Server>;
Aliased Type§
struct Http1Dispatcher<T, B, S> {
conn: Conn<T, <B as Body>::Data, Server>,
dispatch: Server<S, Body>,
body_tx: Option<Sender>,
body_rx: Pin<Box<Option<B>, Global>>,
is_closing: bool,
}
Fields§
§conn: Conn<T, <B as Body>::Data, Server>
§dispatch: Server<S, Body>
§body_tx: Option<Sender>
§body_rx: Pin<Box<Option<B>, Global>>
§is_closing: bool
Implementations§
source§impl<D, Bs, I, T> Dispatcher<D, Bs, I, T>where
D: Dispatch<PollItem = MessageHead<T::Outgoing>, PollBody = Bs, RecvItem = MessageHead<T::Incoming>> + Unpin,
D::PollError: Into<Box<dyn StdError + Send + Sync>>,
I: AsyncRead + AsyncWrite + Unpin,
T: Http1Transaction + Unpin,
Bs: HttpBody + 'static,
Bs::Error: Into<Box<dyn StdError + Send + Sync>>,
impl<D, Bs, I, T> Dispatcher<D, Bs, I, T>where D: Dispatch<PollItem = MessageHead<T::Outgoing>, PollBody = Bs, RecvItem = MessageHead<T::Incoming>> + Unpin, D::PollError: Into<Box<dyn StdError + Send + Sync>>, I: AsyncRead + AsyncWrite + Unpin, T: Http1Transaction + Unpin, Bs: HttpBody + 'static, Bs::Error: Into<Box<dyn StdError + Send + Sync>>,
pub(crate) fn new(dispatch: D, conn: Conn<I, Bs::Data, T>) -> Self
pub(crate) fn disable_keep_alive(&mut self)
pub(crate) fn into_inner(self) -> (I, Bytes, D)
sourcepub(crate) fn poll_without_shutdown(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<()>>where
Self: Unpin,
pub(crate) fn poll_without_shutdown( &mut self, cx: &mut Context<'_> ) -> Poll<Result<()>>where Self: Unpin,
Run this dispatcher until HTTP says this connection is done,
but don’t call AsyncWrite::shutdown
on the underlying IO.
This is useful for old-style HTTP upgrades, but ignores newer-style upgrade API.