fixed up the example

Signed-off-by: Erik Hollensbe <git@hollensbe.org>
This commit is contained in:
Erik Hollensbe
2022-04-27 07:42:39 -07:00
parent 1ac2b56efe
commit d56a20ce81
2 changed files with 13 additions and 31 deletions
-30
View File
@@ -1,30 +0,0 @@
use std::path::PathBuf;
use ratpack::prelude::*;
async fn hello(
req: Request<Body>,
_resp: Option<Response<Body>>,
params: Params,
_app: App<(), NoState>,
_state: NoState,
) -> HTTPResult<NoState> {
let name = params.get("name").unwrap();
let bytes = Body::from(format!("hello, {}!\n", name));
return Ok((
req,
Some(Response::builder().status(200).body(bytes).unwrap()),
NoState {},
));
}
#[tokio::main]
async fn main() -> Result<(), ServerError> {
let mut app = App::new();
app.get("/:name", compose_handler!(hello));
app.serve_unix(PathBuf::from("/tmp/server.sock")).await?;
Ok(())
}
+13 -1
View File
@@ -1,4 +1,6 @@
use ratpack::prelude::*;
#[cfg(feature = "unix")]
use std::path::PathBuf;
async fn hello(
req: Request<Body>,
@@ -22,7 +24,17 @@ async fn main() -> Result<(), ServerError> {
let mut app = App::new();
app.get("/:name", compose_handler!(hello));
app.serve("127.0.0.1:3000").await?;
#[cfg(feature = "unix")]
{
std::fs::remove_file("/tmp/server.sock").unwrap_or_default();
eprintln!("Serving over /tmp/server.sock");
app.serve_unix(PathBuf::from("/tmp/server.sock")).await?;
}
#[cfg(not(feature = "unix"))]
{
eprintln!("Serving over 127.0.0.1:3000");
app.serve("127.0.0.1:3000").await?;
}
Ok(())
}