forked/hyper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

docs(examples): Update multi_server example to use async await

Browse Source
This commit is contained in:
messense
2019-07-12 15:40:14 +08:00
committed by Sean McArthur
parent 7ff8fccced
commit 19ba891fac
1 changed files with 29 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
examples/multi_server.rs
View File

@@ -1,34 +1,47 @@
#![feature(async_await)]
#![deny(warnings)] #![deny(warnings)]
extern crate hyper; extern crate hyper;
extern crate pretty_env_logger; extern crate pretty_env_logger;
use hyper::{Body, Response, Server}; use hyper::{Body, Request, Response, Server};
use hyper::service::service_fn_ok; use hyper::service::{service_fn, make_service_fn};
use hyper::rt::{self, Future}; use futures_util::future::join;
static INDEX1: &'static [u8] = b"The 1st service!"; static INDEX1: &'static [u8] = b"The 1st service!";
static INDEX2: &'static [u8] = b"The 2nd service!"; static INDEX2: &'static [u8] = b"The 2nd service!";
fn main() { async fn index1(_: Request<Body>) -> Result<Response<Body>, hyper::Error> {
Ok(Response::new(Body::from(INDEX1)))
}
async fn index2(_: Request<Body>) -> Result<Response<Body>, hyper::Error> {
Ok(Response::new(Body::from(INDEX2)))
}
#[hyper::rt::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
pretty_env_logger::init(); pretty_env_logger::init();
let addr1 = ([127, 0, 0, 1], 1337).into(); let addr1 = ([127, 0, 0, 1], 1337).into();
let addr2 = ([127, 0, 0, 1], 1338).into(); let addr2 = ([127, 0, 0, 1], 1338).into();
rt::run(rt::lazy(move || { let srv1 = Server::bind(&addr1)
let srv1 = Server::bind(&addr1) .serve(make_service_fn(|_| {
.serve(|| service_fn_ok(|_| Response::new(Body::from(INDEX1)))) async {
.map_err(|e| eprintln!("server 1 error: {}", e)); Ok::<_, hyper::Error>(service_fn(index1))
}
}));
let srv2 = Server::bind(&addr2) let srv2 = Server::bind(&addr2)
.serve(|| service_fn_ok(|_| Response::new(Body::from(INDEX2)))) .serve(make_service_fn(|_| {
.map_err(|e| eprintln!("server 2 error: {}", e)); async {
Ok::<_, hyper::Error>(service_fn(index2))
}
}));
println!("Listening on http://{} and http://{}", addr1, addr2); println!("Listening on http://{} and http://{}", addr1, addr2);
rt::spawn(srv1); let _ret = join(srv1, srv2).await;
rt::spawn(srv2);
Ok(()) Ok(())
}));
} }