Don't panic the tokio worker thread when deserialize() fails

src/bin/drone.rs

@@ -116,8 +116,14 @@ fn main() {
 
             let processor = reader
                 .for_each(move |bytes| {
-                    let req: DroneRequest =
+                    let req: DroneRequest = deserialize(&bytes).or_else(|err| {
-                        deserialize(&bytes).expect("deserialize packet in drone");
+                        use std::io;
+                        Err(io::Error::new(
+                            io::ErrorKind::Other,
+                            format!("deserialize packet in drone: {:?}", err),
+                        ))
+                    })?;
+
                     println!("Airdrop requested...");
                     // let res = drone2.lock().unwrap().check_rate_limit(client_ip);
                     let res1 = drone2.lock().unwrap().send_airdrop(req);
@@ -127,14 +133,6 @@ fn main() {
                     }
                     Ok(())
                 })
-                .and_then(|()| {
-                    println!("Socket received FIN packet and closed connection");
-                    Ok(())
-                })
-                .or_else(|err| {
-                    println!("Socket closed with error: {:?}", err);
-                    Err(err)
-                })
                 .then(|result| {
                     println!("Socket closed with result: {:?}", result);
                     Ok(())