diff --git a/src/lib.rs b/src/lib.rs
index 41f0a35..f33d975 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -204,7 +204,7 @@ impl Responder {
     /// Checks that the response matches the request for which the responder was created.
     pub fn respond(self, response: Response) -> Result<(), ()> {
         if self.check_response(&response).is_err() {
-            return Err(())
+            return Err(());
         }
         if self
             .response_sender
@@ -331,59 +331,82 @@ impl Protocol {
         match request.value {
             // Info
             Some(Request_oneof_value::info(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::Info);
+                let responder =
+                    Responder::new(self.response_sender.clone(), sender, ResponseType::Info);
                 self.application.info(r, responder);
             }
             // Init chain
             Some(Request_oneof_value::init_chain(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::InitChain);
+                let responder = Responder::new(
+                    self.response_sender.clone(),
+                    sender,
+                    ResponseType::InitChain,
+                );
                 self.application.init_chain(r, responder);
-            },
+            }
             // Set option
             Some(Request_oneof_value::set_option(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::SetOption);
+                let responder = Responder::new(
+                    self.response_sender.clone(),
+                    sender,
+                    ResponseType::SetOption,
+                );
                 self.application.set_option(r, responder);
-            },
+            }
             // Query
             Some(Request_oneof_value::query(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::Query);
+                let responder =
+                    Responder::new(self.response_sender.clone(), sender, ResponseType::Query);
                 self.application.query(r, responder);
-            },
+            }
             // Check tx
             Some(Request_oneof_value::check_tx(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::CheckTx);
+                let responder =
+                    Responder::new(self.response_sender.clone(), sender, ResponseType::CheckTx);
                 self.application.check_tx(r, responder);
-            },
+            }
             // Begin block
             Some(Request_oneof_value::begin_block(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::BeginBlock);
+                let responder = Responder::new(
+                    self.response_sender.clone(),
+                    sender,
+                    ResponseType::BeginBlock,
+                );
                 self.application.begin_block(r, responder);
-            },
+            }
             // Deliver Tx
             Some(Request_oneof_value::deliver_tx(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::DeliverTx);
+                let responder = Responder::new(
+                    self.response_sender.clone(),
+                    sender,
+                    ResponseType::DeliverTx,
+                );
                 self.application.deliver_tx(r, responder);
-            },
+            }
             // End block
             Some(Request_oneof_value::end_block(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::EndBlock);
+                let responder =
+                    Responder::new(self.response_sender.clone(), sender, ResponseType::EndBlock);
                 self.application.end_block(r, responder);
-            },
+            }
             // Commit
             Some(Request_oneof_value::commit(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::Commit);
+                let responder =
+                    Responder::new(self.response_sender.clone(), sender, ResponseType::Commit);
                 self.application.commit(r, responder);
-            },
+            }
             // Flush
             Some(Request_oneof_value::flush(_)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::Flush);
+                let responder =
+                    Responder::new(self.response_sender.clone(), sender, ResponseType::Flush);
                 let mut response = Response::new();
                 response.set_flush(ResponseFlush::new());
                 let _ = responder.respond(response);
             }
             // Echo
             Some(Request_oneof_value::echo(r)) => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::Echo);
+                let responder =
+                    Responder::new(self.response_sender.clone(), sender, ResponseType::Echo);
                 let mut response = Response::new();
                 let echo_msg = r.get_message().to_string();
                 let mut echo = ResponseEcho::new();
@@ -392,7 +415,11 @@ impl Protocol {
                 let _ = responder.respond(response);
             }
             _ => {
-                let responder = Responder::new(self.response_sender.clone(), sender, ResponseType::Exception);
+                let responder = Responder::new(
+                    self.response_sender.clone(),
+                    sender,
+                    ResponseType::Exception,
+                );
                 let mut response = Response::new();
                 let mut re = ResponseException::new();
                 re.set_error(String::from("Unrecognized request"));