fixup! Add IPC transport implementation for Unix

tomusdrw · Dec 15, 2020 · 1788be6 · 1788be6
1 parent 583d816
commit 1788be6
Showing 1 changed file with 10 additions and 13 deletions.
diff --git a/src/transports/ipc.rs b/src/transports/ipc.rs
@@ -100,19 +100,16 @@ async fn run_server(unix_stream: UnixStream, messages_rx: mpsc::UnboundedReceive
 
     loop {
         tokio::select! {
-            message = messages_rx.next() => match message {
-                Some(message) => {
-                    if pending_response_txs.insert(message.id, message.response_tx).is_some() {
-                        log::warn!("Replacing a pending request with id {:?}", message.id);
-                    }
-
-                    let bytes = helpers::to_string(&message.request).into_bytes();
-                    if let Err(err) = socket_writer.write(&bytes).await {
-                        pending_response_txs.remove(&message.id);
-                        log::error!("IPC write error: {:?}", err);
-                    }
-                },
-                None => {},
+            message = messages_rx.next() => if let Some(message) = message {
+                if pending_response_txs.insert(message.id, message.response_tx).is_some() {
+                    log::warn!("Replacing a pending request with id {:?}", message.id);
+                }
+
+                let bytes = helpers::to_string(&message.request).into_bytes();
+                if let Err(err) = socket_writer.write(&bytes).await {
+                    pending_response_txs.remove(&message.id);
+                    log::error!("IPC write error: {:?}", err);
+                }
             },
             bytes = socket_reader.next() => match bytes {
                 Some(Ok(bytes)) => {