diff --git a/bincode-transport/src/lib.rs b/bincode-transport/src/lib.rs
index e6582fa..c04f1e8 100644
--- a/bincode-transport/src/lib.rs
+++ b/bincode-transport/src/lib.rs
@@ -218,8 +218,16 @@ mod tests {
         let transport = Transport::<_, String, String>::from(Cursor::new(&mut *writer));
         pin_mut!(transport);
 
-        assert_matches!(transport.as_mut().poll_ready(&mut ctx()), Poll::Ready(Ok(())));
-        assert_matches!(transport .as_mut() .start_send("Test one, check check.".into()), Ok(()));
+        assert_matches!(
+            transport.as_mut().poll_ready(&mut ctx()),
+            Poll::Ready(Ok(()))
+        );
+        assert_matches!(
+            transport
+                .as_mut()
+                .start_send("Test one, check check.".into()),
+            Ok(())
+        );
         assert_matches!(transport.poll_flush(&mut ctx()), Poll::Ready(Ok(())));
         assert_eq!(
             writer,
diff --git a/json-transport/src/lib.rs b/json-transport/src/lib.rs
index 26a0086..8138d4f 100644
--- a/json-transport/src/lib.rs
+++ b/json-transport/src/lib.rs
@@ -201,12 +201,15 @@ where
 
 #[cfg(test)]
 mod tests {
+    use super::Transport;
     use assert_matches::assert_matches;
     use futures::{Sink, Stream};
     use futures_test::task::noop_waker_ref;
     use pin_utils::pin_mut;
-    use std::{io::Cursor, task::{Context, Poll}};
-    use super::Transport;
+    use std::{
+        io::Cursor,
+        task::{Context, Poll},
+    };
 
     fn ctx() -> Context<'static> {
         Context::from_waker(&noop_waker_ref())
@@ -230,8 +233,16 @@ mod tests {
         let transport = Transport::<_, String, String>::from(Cursor::new(&mut *writer));
         pin_mut!(transport);
 
-        assert_matches!(transport.as_mut().poll_ready(&mut ctx()), Poll::Ready(Ok(())));
-        assert_matches!(transport.as_mut().start_send("Test one, check check.".into()), Ok(()));
+        assert_matches!(
+            transport.as_mut().poll_ready(&mut ctx()),
+            Poll::Ready(Ok(()))
+        );
+        assert_matches!(
+            transport
+                .as_mut()
+                .start_send("Test one, check check.".into()),
+            Ok(())
+        );
         assert_matches!(transport.poll_flush(&mut ctx()), Poll::Ready(Ok(())));
         assert_eq!(writer, b"\x00\x00\x00\x18\"Test one, check check.\"");
     }
diff --git a/rpc/src/lib.rs b/rpc/src/lib.rs
index ff23207..8d1f6c6 100644
--- a/rpc/src/lib.rs
+++ b/rpc/src/lib.rs
@@ -4,12 +4,7 @@
 // license that can be found in the LICENSE file or at
 // https://opensource.org/licenses/MIT.
 
-#![feature(
-    weak_counts,
-    non_exhaustive,
-    async_await,
-    trait_alias,
-)]
+#![feature(weak_counts, non_exhaustive, async_await, trait_alias)]
 #![deny(missing_docs, missing_debug_implementations)]
 
 //! An RPC framework providing client and server.
diff --git a/rpc/src/server/filter.rs b/rpc/src/server/filter.rs
index c081eda..7dd1758 100644
--- a/rpc/src/server/filter.rs
+++ b/rpc/src/server/filter.rs
@@ -456,7 +456,10 @@ fn channel_filter_poll_closed_channels() {
     assert_eq!(filter.key_counts.len(), 1);
 
     drop(channel);
-    assert_matches!(filter.as_mut().poll_closed_channels(&mut ctx()), Poll::Ready(()));
+    assert_matches!(
+        filter.as_mut().poll_closed_channels(&mut ctx()),
+        Poll::Ready(())
+    );
     assert!(filter.key_counts.is_empty());
 }
 
diff --git a/rpc/src/server/mod.rs b/rpc/src/server/mod.rs
index e11e83d..6885c2e 100644
--- a/rpc/src/server/mod.rs
+++ b/rpc/src/server/mod.rs
@@ -349,10 +349,7 @@ where
         self.transport().poll_ready(cx)
     }
 
-    fn start_send(
-        mut self: Pin<&mut Self>,
-        response: Response<Resp>,
-    ) -> Result<(), Self::Error> {
+    fn start_send(mut self: Pin<&mut Self>, response: Response<Resp>) -> Result<(), Self::Error> {
         if self
             .as_mut()
             .in_flight_requests()
@@ -521,19 +518,21 @@ where
         let trace_id = *ctx.trace_id();
         let response = self.as_mut().f().clone()(ctx, request);
         let response = deadline_compat::Deadline::new(response, Instant::now() + timeout).then(
-            move |result| async move {
-                let response = Response {
-                    request_id,
-                    message: match result {
-                        Ok(message) => Ok(message),
-                        Err(e) => Err(make_server_error(e, trace_id, deadline)),
-                    },
-                };
-                trace!("[{}] Sending response.", trace_id);
-                response_tx
-                    .send((ctx, response))
-                    .unwrap_or_else(|_| ())
-                    .await;
+            move |result| {
+                async move {
+                    let response = Response {
+                        request_id,
+                        message: match result {
+                            Ok(message) => Ok(message),
+                            Err(e) => Err(make_server_error(e, trace_id, deadline)),
+                        },
+                    };
+                    trace!("[{}] Sending response.", trace_id);
+                    response_tx
+                        .send((ctx, response))
+                        .unwrap_or_else(|_| ())
+                        .await;
+                }
             },
         );
         let abort_registration = self.as_mut().channel().start_request(request_id);
diff --git a/rpc/src/server/testing.rs b/rpc/src/server/testing.rs
index a40002a..804e601 100644
--- a/rpc/src/server/testing.rs
+++ b/rpc/src/server/testing.rs
@@ -42,10 +42,7 @@ impl<In, Resp> Sink<Response<Resp>> for FakeChannel<In, Response<Resp>> {
         self.sink().poll_ready(cx).map_err(|e| match e {})
     }
 
-    fn start_send(
-        mut self: Pin<&mut Self>,
-        response: Response<Resp>,
-    ) -> Result<(), Self::Error> {
+    fn start_send(mut self: Pin<&mut Self>, response: Response<Resp>) -> Result<(), Self::Error> {
         self.as_mut()
             .in_flight_requests()
             .remove(&response.request_id);
diff --git a/tarpc/examples/pubsub.rs b/tarpc/examples/pubsub.rs
index 7ec0347..d1087a4 100644
--- a/tarpc/examples/pubsub.rs
+++ b/tarpc/examples/pubsub.rs
@@ -4,11 +4,7 @@
 // license that can be found in the LICENSE file or at
 // https://opensource.org/licenses/MIT.
 
-#![feature(
-    async_await,
-    existential_type,
-    proc_macro_hygiene
-)]
+#![feature(async_await, existential_type, proc_macro_hygiene)]
 
 use futures::{
     future::{self, Ready},
diff --git a/tarpc/examples/server_calling_server.rs b/tarpc/examples/server_calling_server.rs
index a8cd11e..071720d 100644
--- a/tarpc/examples/server_calling_server.rs
+++ b/tarpc/examples/server_calling_server.rs
@@ -4,11 +4,7 @@
 // license that can be found in the LICENSE file or at
 // https://opensource.org/licenses/MIT.
 
-#![feature(
-    existential_type,
-    async_await,
-    proc_macro_hygiene
-)]
+#![feature(existential_type, async_await, proc_macro_hygiene)]
 
 use crate::{add::Service as AddService, double::Service as DoubleService};
 use futures::{