diff --git a/src/thin_client.rs b/src/thin_client.rs
index 6e5e2e3b55..b564afdc24 100644
--- a/src/thin_client.rs
+++ b/src/thin_client.rs
@@ -222,7 +222,12 @@ mod tests {
         let requests_socket = UdpSocket::bind("0.0.0.0:0").unwrap();
         let events_socket = UdpSocket::bind("0.0.0.0:0").unwrap();
 
-        let mut client = ThinClient::new(leader.data.requests_addr, requests_socket, leader.data.events_addr, events_socket);
+        let mut client = ThinClient::new(
+            leader.data.requests_addr,
+            requests_socket,
+            leader.data.events_addr,
+            events_socket,
+        );
         let last_id = client.get_last_id().wait().unwrap();
         let _sig = client
             .transfer(500, &alice.keypair(), bob_pubkey, &last_id)
@@ -264,7 +269,12 @@ mod tests {
             .set_read_timeout(Some(Duration::new(5, 0)))
             .unwrap();
         let events_socket = UdpSocket::bind("0.0.0.0:0").unwrap();
-        let mut client = ThinClient::new(leader.data.requests_addr, requests_socket, leader.data.events_addr, events_socket);
+        let mut client = ThinClient::new(
+            leader.data.requests_addr,
+            requests_socket,
+            leader.data.events_addr,
+            events_socket,
+        );
         let last_id = client.get_last_id().wait().unwrap();
 
         let tr = Transaction::new(&alice.keypair(), bob_pubkey, 500, last_id);
diff --git a/src/tvu.rs b/src/tvu.rs
index 157f09e0c6..a75bbe59d8 100644
--- a/src/tvu.rs
+++ b/src/tvu.rs
@@ -119,7 +119,9 @@ impl Tvu {
             t_gossip,
             t_listen,
         ];
-        Tvu{thread_hdls: threads}
+        Tvu {
+            thread_hdls: threads,
+        }
     }
 }
 
@@ -154,6 +156,7 @@ pub mod tests {
     use bincode::serialize;
     use chrono::prelude::*;
     use crdt::Crdt;
+    use crdt::ReplicatedData;
     use entry::Entry;
     use event::Event;
     use hash::{hash, Hash};
@@ -162,13 +165,12 @@ pub mod tests {
     use packet::BlobRecycler;
     use signature::{KeyPair, KeyPairUtil};
     use std::collections::VecDeque;
+    use std::net::UdpSocket;
     use std::sync::atomic::{AtomicBool, Ordering};
     use std::sync::mpsc::channel;
     use std::sync::{Arc, RwLock};
     use std::time::Duration;
-    use std::net::UdpSocket;
     use streamer;
-    use crdt::ReplicatedData;
     use tvu::Tvu;
 
     /// Test that mesasge sent from leader to target1 and repliated to target2
@@ -328,7 +330,15 @@ pub mod tests {
                 requests.local_addr().unwrap(),
                 event.local_addr().unwrap(),
             );
-            TestNode {data, gossip, requests, replicate, event, respond, broadcast }
+            TestNode {
+                data,
+                gossip,
+                requests,
+                replicate,
+                event,
+                respond,
+                broadcast,
+            }
         }
     }
 }