diff --git a/src/channels/mod.rs b/src/channels/mod.rs
index a94b63c..5785891 100644
--- a/src/channels/mod.rs
+++ b/src/channels/mod.rs
@@ -91,7 +91,6 @@ impl SonicStream {
     fn write<SC: StreamCommand>(&self, command: &SC) -> Result<()> {
         let mut writer = BufWriter::with_capacity(self.max_buffer_size, &self.stream);
         let message = command.message();
-        dbg!(&message);
         writer
             .write_all(message.as_bytes())
             .map_err(|_| Error::new(ErrorKind::WriteToStream))?;
@@ -131,7 +130,6 @@ impl SonicStream {
         };
 
         let message = channel.read(1)?;
-        dbg!(&message);
         // TODO: need to add support for versions
         if message.starts_with("CONNECTED") {
             Ok(channel)
diff --git a/src/commands/ping.rs b/src/commands/ping.rs
index ab84f8f..5c09bbc 100644
--- a/src/commands/ping.rs
+++ b/src/commands/ping.rs
@@ -12,7 +12,6 @@ impl StreamCommand for PingCommand {
     }
 
     fn receive(&self, message: String) -> Result<Self::Response> {
-        dbg!(&message);
         if message == "PONG\r\n" {
             Ok(true)
         } else {
diff --git a/src/commands/push.rs b/src/commands/push.rs
index a6aa5bd..0b3f660 100644
--- a/src/commands/push.rs
+++ b/src/commands/push.rs
@@ -26,8 +26,6 @@ impl StreamCommand for PushCommand<'_> {
     }
 
     fn receive(&self, message: String) -> Result<Self::Response> {
-        dbg!(&message);
-
         if message == "OK\r\n" {
             Ok(true)
         } else {
diff --git a/src/commands/query.rs b/src/commands/query.rs
index 5df0340..f3ebc9d 100644
--- a/src/commands/query.rs
+++ b/src/commands/query.rs
@@ -41,8 +41,6 @@ impl StreamCommand for QueryCommand<'_> {
             static ref RE: Regex = Regex::new(RE_QUERY_RECEIVED_MESSAGE).unwrap();
         }
 
-        dbg!(&message);
-
         if let Some(caps) = RE.captures(&message) {
             if caps["pending_query_id"] != caps["event_query_id"] {
                 Err(Error::new(ErrorKind::QueryResponseError(
diff --git a/src/commands/quit.rs b/src/commands/quit.rs
index 77bb16b..adfc1d7 100644
--- a/src/commands/quit.rs
+++ b/src/commands/quit.rs
@@ -12,7 +12,6 @@ impl StreamCommand for QuitCommand {
     }
 
     fn receive(&self, message: String) -> Result<Self::Response> {
-        dbg!(&message);
         if message.starts_with("ENDED ") {
             Ok(true)
         } else {
diff --git a/src/commands/start.rs b/src/commands/start.rs
index 48ac342..907620a 100644
--- a/src/commands/start.rs
+++ b/src/commands/start.rs
@@ -38,8 +38,6 @@ impl StreamCommand for StartCommand {
             static ref RE: Regex = Regex::new(RE_START_RECEIVED_MESSAGE).unwrap();
         }
 
-        dbg!(&message);
-
         if let Some(caps) = RE.captures(&message) {
             if self.mode.to_str() != &caps["mode"] {
                 Err(Error::new(ErrorKind::SwitchMode))
diff --git a/src/commands/suggest.rs b/src/commands/suggest.rs
index 1db0aac..27cb645 100644
--- a/src/commands/suggest.rs
+++ b/src/commands/suggest.rs
@@ -37,8 +37,6 @@ impl StreamCommand for SuggestCommand<'_> {
             static ref RE: Regex = Regex::new(RE_SUGGEST_RECEIVED_MESSAGE).unwrap();
         }
 
-        dbg!(&message);
-
         match RE.captures(&message) {
             None => Err(Error::new(ErrorKind::WrongSonicResponse)),
             Some(caps) => {