Format remaining files

1 files changed, 21 insertions, 16 deletions

diff --git a/components/channel/lib.rs b/components/channel/lib.rs
index 87950fbe22a..df1c49a64c8 100644
--- a/components/channel/lib.rs
+++ b/components/channel/lib.rs
@@ -18,43 +18,42 @@ use serde::{Deserialize, Serialize};
 use std::sync::Arc;
 use std::sync::atomic::{AtomicBool, Ordering};
 
-
 pub fn route_ipc_receiver_to_new_servo_receiver<T>(ipc_receiver: IpcReceiver<T>) -> Receiver<T>
 where
-    T: for<'de> Deserialize<'de> + Serialize + Send + 'static
+    T: for<'de> Deserialize<'de> + Serialize + Send + 'static,
 {
     let (servo_sender, servo_receiver) = channel();
     ROUTER.add_route(
         ipc_receiver.to_opaque(),
-        Box::new(move |message| {
-            drop(servo_sender.send(message.to::<T>().unwrap()))
-        }),
+        Box::new(move |message| drop(servo_sender.send(message.to::<T>().unwrap()))),
     );
     servo_receiver
 }
 
-pub fn route_ipc_receiver_to_new_servo_sender<T>(ipc_receiver: IpcReceiver<T>, servo_sender: Sender<T>)
-where
-    T: for<'de> Deserialize<'de> + Serialize + Send + 'static
+pub fn route_ipc_receiver_to_new_servo_sender<T>(
+    ipc_receiver: IpcReceiver<T>,
+    servo_sender: Sender<T>,
+) where
+    T: for<'de> Deserialize<'de> + Serialize + Send + 'static,
 {
     ROUTER.add_route(
         ipc_receiver.to_opaque(),
-        Box::new(move |message| {
-            drop(servo_sender.send(message.to::<T>().unwrap()))
-        }),
+        Box::new(move |message| drop(servo_sender.send(message.to::<T>().unwrap()))),
     )
 }
 
 pub fn channel<T>() -> (Sender<T>, Receiver<T>) {
     let (base_sender, base_receiver) = crossbeam_channel::unbounded::<T>();
     let is_disconnected = Arc::new(AtomicBool::new(false));
-    (Sender::new(base_sender, is_disconnected.clone()),
-     Receiver::new(base_receiver, is_disconnected))
+    (
+        Sender::new(base_sender, is_disconnected.clone()),
+        Receiver::new(base_receiver, is_disconnected),
+    )
 }
 
 #[derive(Debug, PartialEq)]
 pub enum ChannelError {
-    ChannelClosedError
+    ChannelClosedError,
 }
 
 pub struct Receiver<T> {
@@ -78,7 +77,10 @@ impl<T> Clone for Receiver<T> {
 }
 
 impl<T> Receiver<T> {
-    pub fn new(receiver: crossbeam_channel::Receiver<T>, is_disconnected: Arc<AtomicBool>) -> Receiver<T> {
+    pub fn new(
+        receiver: crossbeam_channel::Receiver<T>,
+        is_disconnected: Arc<AtomicBool>,
+    ) -> Receiver<T> {
         Receiver {
             receiver,
             is_disconnected,
@@ -134,7 +136,10 @@ impl<T> Clone for Sender<T> {
 }
 
 impl<T> Sender<T> {
-    pub fn new(sender: crossbeam_channel::Sender<T>, is_disconnected: Arc<AtomicBool>) -> Sender<T> {
+    pub fn new(
+        sender: crossbeam_channel::Sender<T>,
+        is_disconnected: Arc<AtomicBool>,
+    ) -> Sender<T> {
         Sender {
             sender,
             is_disconnected,