Deuxfleurs/aerogramme
15
0
Fork 1
Code Issues 33 Pull requests 1 Projects 11 Releases 5 Wiki Activity

Simplified types

Browse source
This commit is contained in:
Quentin 2022-06-02 17:04:50 +02:00
parent 2d1e6bfffb
commit 81e647e881
Signed by: quentin
GPG key ID: E9602264D639FF68
1 changed files with 6 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/server.rs
View file

@ -28,28 +28,24 @@ async fn handle_req(req: Request) -> Result<Response> {
Ok(Response::ok("Done")?) Ok(Response::ok("Done")?)
} }
struct Echo;
struct Echo;
impl Service<Request> for Echo { impl Service<Request> for Echo {
type Response = Response; type Response = Response;
type Error = Box<dyn Error + Send + Sync>; type Error = anyhow::Error;
type Future = Pin<Box<dyn futures::Future<Output = Result<Self::Response, Self::Error>> + Send>>; type Future = Pin<Box<dyn futures::Future<Output = Result<Self::Response>> + Send>>;
fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
Poll::Ready(Ok(())) Poll::Ready(Ok(()))
} }
fn call(&mut self, req: Request) -> Self::Future { fn call(&mut self, req: Request) -> Self::Future {
Box::pin(Echo::handle_req(req)) println!("Got request: {:#?}", req);
let fut = futures::future::ok(Response::ok("Done").unwrap());
Box::pin(fut)
} }
} }
impl Echo {
async fn handle_req(req: Request) -> Result<Response, Box<dyn Error + Send + Sync>> {
println!("Got request: {:#?}", req);
Ok(Response::ok("Done").unwrap())
}
}
impl Server { impl Server {
pub fn new(config: Config) -> Result<Arc<Self>> { pub fn new(config: Config) -> Result<Arc<Self>> {