From 193c1494f439781fa1317d25caa5e06353f1efe3 Mon Sep 17 00:00:00 2001 From: Fuwn Date: Sun, 27 Mar 2022 04:00:32 +0000 Subject: refactor(run): generic errors --- src/lib.rs | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) (limited to 'src') diff --git a/src/lib.rs b/src/lib.rs index 4f939c3..f2a93c0 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -250,18 +250,18 @@ impl Router { async fn handle( &self, stream: &mut tokio_openssl::SslStream, - ) -> std::io::Result<()> { + ) -> Result<(), Box> { let mut buffer = [0u8; 1024]; - let mut url = Url::parse("gemini://fuwn.me/").unwrap(); + let mut url = Url::parse("gemini://fuwn.me/")?; let mut response_status = 0; let mut footer = String::new(); let mut header = String::new(); let content; while let Ok(size) = stream.read(&mut buffer).await { - let content = String::from_utf8(buffer[0..size].to_vec()).unwrap(); + let content = String::from_utf8(buffer[0..size].to_vec())?; - url = url::Url::parse(&content.replace("\r\n", "")).unwrap(); + url = url::Url::parse(&content.replace("\r\n", ""))?; if content.contains("\r\n") { break; @@ -348,7 +348,9 @@ impl Router { } }); - stream.shutdown().await + stream.shutdown().await?; + + Ok(()) } fn create_acceptor(&mut self) { -- cgit v1.2.3