Noratrieb/icefun
1
0
Fork 0
mirror of https://github.com/Noratrieb/icefun.git synced 2026-01-14 12:55:02 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

loop

Browse source
This commit is contained in:
nora 2023-03-07 16:35:00 +01:00
parent 270f547952
commit 3646dc4c88
1 changed files with 10 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

25
hyper/src/server/server.rs
View file

@ -61,11 +61,11 @@ where
} }
} }
} }
#[cfg_attr(docsrs, doc(cfg(any(feature = "http1", feature = "http2"))))]
impl<I, E> Builder<I, E> { impl<I, E> Builder<I, E> {
#[doc(hidden)] #[doc(hidden)]
#[cfg(feature = "http1")] #[cfg(feature = "http1")]
pub fn http1_pipeline_flush(mut self, val: bool) -> Self { pub fn http1_pipeline_flush(self, val: bool) -> Self {
loop {} loop {}
} }
@ -94,36 +94,25 @@ where
} }
} }
pub(crate) mod new_svc { pub(crate) mod new_svc {
use super::{Connecting, Watcher}; use super::Watcher;
use crate::body::{Body, HttpBody}; use crate::body::{Body, HttpBody};
use crate::common::exec::ConnStreamExec; use crate::common::exec::ConnStreamExec;
use crate::common::{task, Future, Pin, Poll, Unpin}; use crate::common::{task, Future, Pin, Poll, Unpin};
use crate::service::HttpService; use crate::service::HttpService;
use pin_project_lite::pin_project;
use std::error::Error as StdError; use std::error::Error as StdError;
use tokio::io::{AsyncRead, AsyncWrite}; use tokio::io::{AsyncRead, AsyncWrite};
pin_project! {
#[allow(missing_debug_implementations)]
pub struct NewSvcTask<I, N, S, E, W: Watcher<I, S, E>> { pub struct NewSvcTask<I, N, S, E, W: Watcher<I, S, E>> {
#[pin]
state: State<I, S, E, W>, state: State<I, S, E, W>,
a: N,
a: (N)
} }
}
pin_project! {
#[project = StateProj]
pub(super) enum State<I, S, E, W: Watcher<I, S, E>> { pub(super) enum State<I, S, E, W: Watcher<I, S, E>> {
Connecting { a: (I, S, W, E) },
Connecting { a: (I, S, W, E), }, Connected { future: W::Future },
}
Connected { #[pin] future : W::Future, },
}
}
impl<I, N, S: HttpService<Body>, E, W: Watcher<I, S, E>> NewSvcTask<I, N, S, E, W> { impl<I, N, S: HttpService<Body>, E, W: Watcher<I, S, E>> NewSvcTask<I, N, S, E, W> {
pub(super) fn new(watcher: W) -> Self { pub(super) fn new(watcher: W) -> Self {
loop {} loop {}