rm more debugging code

datrs · Aug 28, 2024 · 42508dd · 42508dd
1 parent ef00161
commit 42508dd
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 7 deletions.
diff --git a/src/channels.rs b/src/channels.rs
@@ -354,7 +354,6 @@ pub(crate) struct ChannelMap {
     channels: HashMap<String, ChannelHandle>,
     local_id: Vec<Option<String>>,
     remote_id: Vec<Option<String>>,
-    pub messages: (Sender<Message>, Receiver<Message>),
 }
 
 impl ChannelMap {
@@ -365,7 +364,6 @@ impl ChannelMap {
             // This makes sure that 0 may be used for stream-level extensions.
             local_id: vec![None],
             remote_id: vec![],
-            messages: async_channel::unbounded(),
         }
     }
 

diff --git a/src/protocol.rs b/src/protocol.rs
@@ -141,8 +141,7 @@ pub struct Protocol<IO: AsyncWrite + AsyncRead + Send + Unpin + 'static> {
     state: State,
     options: Options,
     handshake: Option<HandshakeResult>,
-    #[allow(private_interfaces)]
-    pub channels: ChannelMap,
+    channels: ChannelMap,
     command_rx: Receiver<Command>,
     command_tx: CommandTx,
     outbound_rx: Receiver<Vec<ChannelMessage>>,
@@ -199,9 +198,7 @@ where
             //channel_messages: async_channel::unbounded(),
         }
     }
-    pub fn receiver_for_all_channel_messages(&self) -> Receiver<Message> {
-        self.channels.messages.1.clone()
-    }
+
     /// Whether this protocol stream initiated the underlying IO connection.
     pub fn is_initiator(&self) -> bool {
         self.options.is_initiator