rework command response mechanism

1 files changed, 7 insertions, 2 deletions

diff --git a/mumd/src/command.rs b/mumd/src/command.rs
index f02ad19..5255afa 100644
--- a/mumd/src/command.rs
+++ b/mumd/src/command.rs
@@ -29,7 +29,9 @@ pub async fn handle(
                     event, 
                     Box::new(move |e| {
                         let response = generator(e);
-                        response_sender.send(response).unwrap();
+                        for response in response {
+                            response_sender.send(response).unwrap();
+                        }
                     }),
                 );
             }
@@ -42,7 +44,10 @@ pub async fn handle(
                 )
             }
             ExecutionContext::Now(generator) => {
-                response_sender.send(generator()).unwrap();
+                for response in generator() {
+                    response_sender.send(response).unwrap(); 
+                }
+                drop(response_sender);
             }
             ExecutionContext::Ping(generator, converter) => {
                 let ret = generator();