diff options
| author | Yuval Adam <_@yuv.al> | 2018-07-17 23:59:41 +0300 |
|---|---|---|
| committer | Yuval Adam <_@yuv.al> | 2018-07-17 23:59:41 +0300 |
| commit | 8556e2f494847d62b613dfc4fee98e530f49e9ab (patch) | |
| tree | c7769ae8a2098a0cabefeb3feae5272a6f0bbdb8 /src/serve.rs | |
| parent | 2f935cd641c72e834d62c704acba41111b78cd10 (diff) | |
Implement play/pause and cleanup
Diffstat (limited to 'src/serve.rs')
| -rw-r--r-- | src/serve.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/serve.rs b/src/serve.rs index 9ff51a2..18b9642 100644 --- a/src/serve.rs +++ b/src/serve.rs @@ -6,26 +6,26 @@ extern crate tokio_io; use self::futures::{future, Future}; use self::hyper::{Body, Method, Request, Response, Server, StatusCode}; use self::hyper::service::service_fn; +use tokio::runtime::Runtime; use std::io; static NOTFOUND: &[u8] = b"Not Found"; -pub fn run() { +pub fn run(rt: &mut Runtime) { let addr = "0.0.0.0:51497".parse().unwrap(); - let server = Server::bind(&addr) - .serve(|| service_fn(response_examples)) + .serve(|| service_fn(routes)) .map_err(|e| eprintln!("server error: {}", e)); - println!("Listening on http://{}", addr); + rt.spawn(server); - hyper::rt::run(server); + println!("Listening on http://{}", addr); } type ResponseFuture = Box<Future<Item=Response<Body>, Error=io::Error> + Send>; -pub fn response_examples(req: Request<Body>) -> ResponseFuture { +fn routes(req: Request<Body>) -> ResponseFuture { match (req.method(), req.uri().path()) { (&Method::GET, "/0") => { simple_file_send("/home/yuval/Videos/0") |