Add some sensibly derived Debugs

Author: benashford

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "redis-async"
-version = "0.4.3"
+version = "0.4.4"
 authors = ["Ben Ashford <[email protected]>"]
 license = "MIT/Apache-2.0"
 readme = "README.md"

src/client/paired.rs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2017-2018 Ben Ashford
+ * Copyright 2017-2019 Ben Ashford
  *
  * Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
  * http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
@@ -168,7 +168,7 @@ impl Future for PairedConnectionInner {
 type SendPayload = (resp::RespValue, oneshot::Sender<resp::RespValue>);
 
 /// A shareable and cheaply cloneable connection to which Redis commands can be sent
-#[derive(Clone)]
+#[derive(Debug, Clone)]
 pub struct PairedConnection {
     out_tx_c:
         Reconnect<SendPayload, mpsc::UnboundedSender<SendPayload>, error::Error, error::Error>,
@@ -209,7 +209,8 @@ pub fn paired_connect(
                 Box::new(con_f)
             },
         )
-    }).map(|out_tx_c| PairedConnection { out_tx_c })
+    })
+    .map(|out_tx_c| PairedConnection { out_tx_c })
     .map_err(|()| error::Error::EndOfStream)
 }
 
@@ -235,7 +236,7 @@ impl PairedConnection {
             _ => {
                 return Either::B(future::err(error::internal(
                     "Command must be a RespValue::Array",
-                )))
+                )));
             }
         }
 

src/client/pubsub.rs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2017-2018 Ben Ashford
+ * Copyright 2017-2019 Ben Ashford
  *
  * Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
  * http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
@@ -204,7 +204,7 @@ impl Future for PubsubConnectionInner {
 }
 
 /// A shareable reference to subscribe to PUBSUB topics
-#[derive(Clone)]
+#[derive(Debug, Clone)]
 pub struct PubsubConnection {
     out_tx_c:
         Reconnect<PubsubEvent, mpsc::UnboundedSender<PubsubEvent>, error::Error, error::Error>,
@@ -239,7 +239,8 @@ pub fn pubsub_connect(
                 Box::new(con_f)
             },
         )
-    }).map(|out_tx_c| PubsubConnection { out_tx_c })
+    })
+    .map(|out_tx_c| PubsubConnection { out_tx_c })
     .map_err(|()| error::Error::EndOfStream)
 }
 

src/reconnect.rs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2018 Ben Ashford
+ * Copyright 2018-2019 Ben Ashford
  *
  * Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
  * http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
@@ -9,6 +9,7 @@
  */
 
 use std::error as std_error;
+use std::fmt;
 use std::sync::{Arc, RwLock};
 use std::time::Duration;
 
@@ -34,6 +35,15 @@ pub(crate) struct Reconnect<A, T, RE, CE> {
     conn_fn: Arc<Fn() -> Box<Future<Item = T, Error = CE> + Send> + Send + Sync>,
 }
 
+impl<A, T, RE, CE> fmt::Debug for Reconnect<A, T, RE, CE>
+where
+    T: fmt::Debug,
+{
+    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
+        write!(f, "Reconnect {{ state: {:?} }}", self.state)
+    }
+}
+
 pub(crate) fn reconnect<A, T, RE, CE, W, C>(
     w: W,
     c: C,
@@ -55,6 +65,7 @@ where
     r.reconnect().map(|()| r)
 }
 
+#[derive(Debug)]
 enum ReconnectState<T> {
     NotConnected,
     Connected(T),