#5 more ergonomic error handling
This commit is contained in:
parent
727cc7b1a7
commit
4a29f88e3e
1 changed files with 7 additions and 5 deletions
12
src/main.rs
12
src/main.rs
|
|
@ -1,16 +1,18 @@
|
||||||
use std::io::Read;
|
use std::io::Read;
|
||||||
use std::net::{TcpListener, TcpStream};
|
use std::net::{TcpListener, TcpStream};
|
||||||
|
|
||||||
fn main() {
|
fn main() -> std::io::Result<()> {
|
||||||
let listener = TcpListener::bind("127.0.0.1:7878").unwrap();
|
let listener = TcpListener::bind("127.0.0.1:7878")?;
|
||||||
for stream in listener.incoming() {
|
for stream in listener.incoming() {
|
||||||
let stream = stream.unwrap();
|
let stream = stream?;
|
||||||
handle_connection(stream);
|
handle_connection(stream);
|
||||||
}
|
}
|
||||||
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
fn handle_connection(mut stream: TcpStream) {
|
fn handle_connection(mut stream: TcpStream) -> std::io::Result<()>{
|
||||||
let mut buffer = [0; 1024];
|
let mut buffer = [0; 1024];
|
||||||
stream.read(&mut buffer).unwrap();
|
stream.read(&mut buffer)?;
|
||||||
println!("Request: {}", String::from_utf8_lossy(&buffer[..]));
|
println!("Request: {}", String::from_utf8_lossy(&buffer[..]));
|
||||||
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue