impl Debug for MultiplexedConnection & Pipeline

redis/src/aio.rs

@@ -1,6 +1,8 @@
 //! Adds experimental async IO support to redis.
 use async_trait::async_trait;
 use std::collections::VecDeque;
+use std::fmt;
+use std::fmt::Debug;
 use std::io;
 use std::mem;
 use std::net::SocketAddr;
@@ -623,6 +625,17 @@ impl<SinkItem, I, E> Clone for Pipeline<SinkItem, I, E> {
     }
 }
 
+impl<SinkItem, I, E> Debug for Pipeline<SinkItem, I, E>
+where
+    SinkItem: Debug,
+    I: Debug,
+    E: Debug,
+{
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.debug_tuple("Pipeline").field(&self.0).finish()
+    }
+}
+
 pin_project! {
     struct PipelineSink<T, I, E> {
         #[pin]
@@ -847,6 +860,15 @@ pub struct MultiplexedConnection {
     db: i64,
 }
 
+impl Debug for MultiplexedConnection {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.debug_struct("MultiplexedConnection")
+            .field("pipeline", &self.pipeline)
+            .field("db", &self.db)
+            .finish()
+    }
+}
+
 impl MultiplexedConnection {
     /// Constructs a new `MultiplexedConnection` out of a `AsyncRead + AsyncWrite` object
     /// and a `ConnectionInfo`