All instances of `old_io` and `old_path` were switched to use the new shiny `std::io`, `std::net`, and `std::path` modules. This means that `Request` and `Response` implement `Read` and `Write` now. Because of the changes to `TcpListener`, this also takes the opportunity to correct the method usage of `Server`. As with other languages/frameworks, the server is first created with a handler, and then a host/port is passed to a `listen` method. This reverses what `Server` used to do. Closes #347 BREAKING CHANGE: Check the docs. Everything was touched.
		
			
				
	
	
		
			57 lines
		
	
	
		
			1.6 KiB
		
	
	
	
		
			Rust
		
	
	
	
	
	
			
		
		
	
	
			57 lines
		
	
	
		
			1.6 KiB
		
	
	
	
		
			Rust
		
	
	
	
	
	
| #![feature(io, net)]
 | |
| extern crate hyper;
 | |
| #[macro_use] extern crate log;
 | |
| 
 | |
| use std::io::{Write, copy};
 | |
| use std::net::IpAddr;
 | |
| 
 | |
| use hyper::{Get, Post};
 | |
| use hyper::header::ContentLength;
 | |
| use hyper::server::{Server, Request, Response};
 | |
| use hyper::uri::RequestUri::AbsolutePath;
 | |
| 
 | |
| macro_rules! try_return(
 | |
|     ($e:expr) => {{
 | |
|         match $e {
 | |
|             Ok(v) => v,
 | |
|             Err(e) => { error!("Error: {}", e); return; }
 | |
|         }
 | |
|     }}
 | |
| );
 | |
| 
 | |
| fn echo(mut req: Request, mut res: Response) {
 | |
|     match req.uri {
 | |
|         AbsolutePath(ref path) => match (&req.method, &path[..]) {
 | |
|             (&Get, "/") | (&Get, "/echo") => {
 | |
|                 let out = b"Try POST /echo";
 | |
| 
 | |
|                 res.headers_mut().set(ContentLength(out.len() as u64));
 | |
|                 let mut res = try_return!(res.start());
 | |
|                 try_return!(res.write_all(out));
 | |
|                 try_return!(res.end());
 | |
|                 return;
 | |
|             },
 | |
|             (&Post, "/echo") => (), // fall through, fighting mutable borrows
 | |
|             _ => {
 | |
|                 *res.status_mut() = hyper::NotFound;
 | |
|                 try_return!(res.start().and_then(|res| res.end()));
 | |
|                 return;
 | |
|             }
 | |
|         },
 | |
|         _ => {
 | |
|             try_return!(res.start().and_then(|res| res.end()));
 | |
|             return;
 | |
|         }
 | |
|     };
 | |
| 
 | |
|     let mut res = try_return!(res.start());
 | |
|     try_return!(copy(&mut req, &mut res));
 | |
|     try_return!(res.end());
 | |
| }
 | |
| 
 | |
| fn main() {
 | |
|     let server = Server::http(echo);
 | |
|     let _guard = server.listen(IpAddr::new_v4(127, 0, 0, 1), 1337).unwrap();
 | |
|     println!("Listening on http://127.0.0.1:1337");
 | |
| }
 |