diff --git a/core/src/muxing.rs b/core/src/muxing.rs
index f07088bc..d96df5d6 100644
--- a/core/src/muxing.rs
+++ b/core/src/muxing.rs
@@ -268,9 +268,10 @@ impl
fmt::Debug for SubstreamRef
where
P: Deref,
P::Target: StreamMuxer,
+ ::Substream: fmt::Debug,
{
fn fmt(&self, f: &mut fmt::Formatter) -> Result<(), fmt::Error> {
- write!(f, "Substream({:?})", self)
+ write!(f, "Substream({:?})", self.substream)
}
}
diff --git a/core/src/nodes/node.rs b/core/src/nodes/node.rs
index d35ef2a6..6d418c26 100644
--- a/core/src/nodes/node.rs
+++ b/core/src/nodes/node.rs
@@ -80,7 +80,6 @@ enum StreamState {
}
/// Event that can happen on the `NodeStream`.
-#[derive(Debug)]
pub enum NodeEvent
where
TMuxer: muxing::StreamMuxer,
@@ -346,32 +345,37 @@ where
}
}
-// TODO:
-/*impl fmt::Debug for NodeEvent
-where TTrans: Transport,
- ::Error: fmt::Debug,
+impl fmt::Debug for NodeEvent
+where
+ TMuxer: muxing::StreamMuxer,
+ TMuxer::Substream: fmt::Debug,
+ TUserData: fmt::Debug,
{
- fn fmt(&self, f: &mut fmt::Formatter) -> Result<(), fmt::Error> {
+ fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
match self {
- NodeEvent::Incoming { ref listen_addr, .. } => {
- f.debug_struct("NodeEvent::Incoming")
- .field("listen_addr", listen_addr)
+ NodeEvent::InboundSubstream { substream } => {
+ f.debug_struct("NodeEvent::OutboundClosed")
+ .field("substream", substream)
.finish()
},
- NodeEvent::Closed { ref listen_addr, .. } => {
- f.debug_struct("NodeEvent::Closed")
- .field("listen_addr", listen_addr)
+ NodeEvent::OutboundSubstream { user_data, substream } => {
+ f.debug_struct("NodeEvent::OutboundSubstream")
+ .field("user_data", user_data)
+ .field("substream", substream)
.finish()
},
- NodeEvent::Error { ref listen_addr, ref error, .. } => {
- f.debug_struct("NodeEvent::Error")
- .field("listen_addr", listen_addr)
- .field("error", error)
+ NodeEvent::OutboundClosed { user_data } => {
+ f.debug_struct("NodeEvent::OutboundClosed")
+ .field("user_data", user_data)
+ .finish()
+ },
+ NodeEvent::InboundClosed => {
+ f.debug_struct("NodeEvent::InboundClosed")
.finish()
},
}
}
-}*/
+}
#[cfg(test)]
mod node_stream {
diff --git a/core/src/tests/dummy_muxer.rs b/core/src/tests/dummy_muxer.rs
index bd7832d3..63f9e781 100644
--- a/core/src/tests/dummy_muxer.rs
+++ b/core/src/tests/dummy_muxer.rs
@@ -27,9 +27,11 @@ use muxing::{StreamMuxer, Shutdown};
use futures::prelude::*;
/// Substream type
+#[derive(Debug)]
pub struct DummySubstream {}
/// OutboundSubstream type
+#[derive(Debug)]
pub struct DummyOutboundSubstream {}
/// Control the muxer state by setting the "connection" state as to set up a mock