diff --git a/src/lib.rs b/src/lib.rs index 0d58afb..dc13ae3 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -712,7 +712,7 @@ impl HttpServerStarter { let running = Arc::new(AtomicBool::new(true)); if self.threads == 0 { - start_server(self.http_server, &self.host, self.timeout, handler, running) + start_server_new_thread(self.http_server, &self.host, self.timeout, handler, running) } else if self.threads == 1 { start_server_sync(self.http_server, &self.host, self.timeout, handler, running) } else { @@ -743,7 +743,7 @@ impl HttpServerStarter { let thread = if self.threads == 0 { thread::spawn(move || { - start_server( + start_server_new_thread( self.http_server, &self.host, self.timeout, @@ -827,7 +827,7 @@ where Ok(()) } -fn start_server( +fn start_server_new_thread( server: S, host: &str, timeout: Option, @@ -1000,3 +1000,14 @@ impl Worker { Worker { thread } } } + +pub fn start_server(server: S, host: &str) { + start_server_new_thread( + server, + host, + None, + handle_connection, + Arc::new(AtomicBool::new(true)), + ) + .unwrap(); +} diff --git a/src/main.rs b/src/main.rs index b3ef31d..7ead942 100644 --- a/src/main.rs +++ b/src/main.rs @@ -46,4 +46,6 @@ fn main() { .threads(5) // threadpool size .start_forever() .expect("http server error"); + + // ezhttp::start_server(site, host); }