From aa710a3420ef4d834ee1df4099b25f3c83b9c31d Mon Sep 17 00:00:00 2001 From: Eskil Queseth Date: Sat, 22 May 2021 01:27:17 +0200 Subject: rework command response mechanism --- mumd/src/command.rs | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) (limited to 'mumd/src/command.rs') 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(); -- cgit v1.2.1