cargo fmt

Author: glyn

src/bin/spawn_receiver_sender_client.rs

@@ -19,9 +19,12 @@ fn main() {
 
     let (sub_tx, sub_rx) = ipc::channel().unwrap();
 
-    let tx: IpcSender<IpcReceiver<String>> = IpcSender::connect(token.to_string()).expect("connect failed");
+    let tx: IpcSender<IpcReceiver<String>> =
+        IpcSender::connect(token.to_string()).expect("connect failed");
     tx.send(sub_rx).expect("send failed");
-    sub_tx.send("test message".to_string()).expect("send failed");
+    sub_tx
+        .send("test message".to_string())
+        .expect("send failed");
 
     process::exit(0);
 }

src/bin/spawn_used_receiver_sender_client.rs

@@ -19,13 +19,18 @@ fn main() {
     let token = args.get(1).expect("missing argument");
 
     let (sub_tx, sub_rx) = ipc::channel().unwrap();
-    sub_tx.send("test message".to_string()).expect("send failed");
+    sub_tx
+        .send("test message".to_string())
+        .expect("send failed");
     let msg = sub_rx.recv().unwrap();
     assert_eq!("test message", msg);
 
-    let tx: IpcSender<IpcReceiver<String>> = IpcSender::connect(token.to_string()).expect("connect failed");
+    let tx: IpcSender<IpcReceiver<String>> =
+        IpcSender::connect(token.to_string()).expect("connect failed");
     tx.send(sub_rx).expect("send failed");
-    sub_tx.send("test message".to_string()).expect("send failed");
+    sub_tx
+        .send("test message".to_string())
+        .expect("send failed");
 
     process::exit(0);
 }

src/test.rs

@@ -177,7 +177,7 @@ fn embedded_receivers_used_before_and_after_transmission() {
     super_tx.send(person_and_receiver).unwrap();
     let received_person_and_receiver = super_rx.recv().unwrap();
     assert_eq!(received_person_and_receiver.0, person);
-    
+
     sub_tx.send(person.clone()).unwrap();
     let received_person2 = received_person_and_receiver.1.recv().unwrap();
     assert_eq!(received_person2, person);

tests/integration_test.rs

@@ -51,8 +51,8 @@ fn spawn_one_shot_server_client() {
 fn spawn_receiver_sender_client() {
     let executable_path: String = env!("CARGO_BIN_EXE_spawn_receiver_sender_client").to_string();
 
-    let (server, token) =
-        IpcOneShotServer::<IpcReceiver<String>>::new().expect("Failed to create IPC one-shot server.");
+    let (server, token) = IpcOneShotServer::<IpcReceiver<String>>::new()
+        .expect("Failed to create IPC one-shot server.");
 
     let mut command = process::Command::new(executable_path);
     let child_process = command.arg(token);
@@ -81,10 +81,11 @@ fn spawn_receiver_sender_client() {
 #[cfg(not(any(feature = "force-inprocess", target_os = "android", target_os = "ios")))]
 #[test]
 fn spawn_used_receiver_sender_client() {
-    let executable_path: String = env!("CARGO_BIN_EXE_spawn_used_receiver_sender_client").to_string();
+    let executable_path: String =
+        env!("CARGO_BIN_EXE_spawn_used_receiver_sender_client").to_string();
 
-    let (server, token) =
-        IpcOneShotServer::<IpcReceiver<String>>::new().expect("Failed to create IPC one-shot server.");
+    let (server, token) = IpcOneShotServer::<IpcReceiver<String>>::new()
+        .expect("Failed to create IPC one-shot server.");
 
     let mut command = process::Command::new(executable_path);
     let child_process = command.arg(token);