fixup! Add IPC transport implementation for Unix

tomusdrw · Dec 15, 2020 · e3d3469 · e3d3469
1 parent 6a28cad
commit e3d3469
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/transports/ipc.rs b/src/transports/ipc.rs
@@ -145,14 +145,12 @@ async fn run_server(unix_stream: UnixStream, messages_rx: mpsc::UnboundedReceive
                 },
                 Some(Err(err)) => {
                     log::error!("IPC read error: {:?}", err);
-                    break;
+                    return Err(err.into());
                 },
-                None => break,
+                None => return Ok(()),
             }
         };
     }
-
-    Ok(())
 }
 
 fn respond(