some changes

1 files changed, 8 insertions, 7 deletions

diff --git a/mumd/src/main.rs b/mumd/src/main.rs
index 93bb0d0..24c2567 100644
--- a/mumd/src/main.rs
+++ b/mumd/src/main.rs
@@ -76,9 +76,10 @@ async fn main() {
     let (command_response_sender, command_response_receiver) = mpsc::unbounded_channel::<Result<Option<CommandResponse>, ()>>();
     let (connection_info_sender, connection_info_receiver) = watch::channel::<Option<ConnectionInfo>>(None);
 
+    command_sender.send(Command::ChannelList).unwrap();
     command_sender.send(Command::ServerConnect{host: server_host, port: server_port, username: username.clone(), accept_invalid_cert});
-
     command_sender.send(Command::ChannelJoin{channel_id: 1}).unwrap();
+    command_sender.send(Command::ChannelList).unwrap();
     let state = State::new(packet_sender, command_sender.clone(), connection_info_sender, username);
     let state = Arc::new(Mutex::new(state));
 
@@ -100,16 +101,16 @@ async fn main() {
             command_receiver,
             command_response_sender,
         ),
-        send_commands(
-            command_sender,
+        receive_command_responses(
             command_response_receiver,
         ),
     );
 }
 
-async fn send_commands(
-    command_sender: mpsc::UnboundedSender<Command>,
-    command_response_receiver: mpsc::UnboundedReceiver<Result<Option<CommandResponse>, ()>>,
+async fn receive_command_responses(
+    mut command_response_receiver: mpsc::UnboundedReceiver<Result<Option<CommandResponse>, ()>>,
 ) {
-
+    while let Some(command_response) = command_response_receiver.recv().await {
+        debug!("{:#?}", command_response);
+    }
 }