mirror of https://github.com/fafhrd91/actix-web
remove extraneous test
This commit is contained in:
parent
a0788ca3b5
commit
95b53b699c
|
@ -127,19 +127,7 @@ where
|
||||||
_t: PhantomData,
|
_t: PhantomData,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
impl<F, I, S, B> HttpServer<F, I, S, B>
|
|
||||||
where
|
|
||||||
F: Fn() -> I + Send + Clone + 'static,
|
|
||||||
I: IntoServiceFactory<S>,
|
|
||||||
S: ServiceFactory<Config = AppConfig, Request = Request>,
|
|
||||||
S::Error: Into<Error> + 'static,
|
|
||||||
S::InitError: fmt::Debug,
|
|
||||||
S::Response: Into<Response<B>> + 'static,
|
|
||||||
<S::Service as Service>::Future: 'static,
|
|
||||||
B: MessageBody + 'static,
|
|
||||||
{
|
|
||||||
/// Set number of workers to start.
|
/// Set number of workers to start.
|
||||||
///
|
///
|
||||||
/// By default http server uses number of available logical cpu as threads
|
/// By default http server uses number of available logical cpu as threads
|
||||||
|
|
|
@ -1,45 +0,0 @@
|
||||||
use std::{any::Any, env, io, net::SocketAddr};
|
|
||||||
|
|
||||||
use actix_web::{dev::Extensions, rt::net::TcpStream, web, App, HttpServer};
|
|
||||||
|
|
||||||
#[derive(Debug, Clone)]
|
|
||||||
struct ConnectionInfo {
|
|
||||||
bind: SocketAddr,
|
|
||||||
peer: SocketAddr,
|
|
||||||
ttl: Option<u32>,
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn route_whoami(conn_info: web::ReqData<ConnectionInfo>) -> String {
|
|
||||||
format!(
|
|
||||||
"Here is some info about your connection:\n\n{:#?}",
|
|
||||||
conn_info
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn get_conn_info(connection: &dyn Any, data: &mut Extensions) {
|
|
||||||
if let Some(sock) = connection.downcast_ref::<TcpStream>() {
|
|
||||||
data.insert(ConnectionInfo {
|
|
||||||
bind: sock.local_addr().unwrap(),
|
|
||||||
peer: sock.peer_addr().unwrap(),
|
|
||||||
ttl: sock.ttl().ok(),
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
unreachable!("connection should only be plaintext since no TLS is set up");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[actix_web::main]
|
|
||||||
async fn main() -> io::Result<()> {
|
|
||||||
if env::var("RUST_LOG").is_err() {
|
|
||||||
env::set_var("RUST_LOG", "info");
|
|
||||||
}
|
|
||||||
|
|
||||||
env_logger::init();
|
|
||||||
|
|
||||||
HttpServer::new(|| App::new().default_service(web::to(route_whoami)))
|
|
||||||
.on_connect(get_conn_info)
|
|
||||||
.bind(("127.0.0.1", 8080))?
|
|
||||||
.workers(1)
|
|
||||||
.run()
|
|
||||||
.await
|
|
||||||
}
|
|
Loading…
Reference in New Issue