From f1d1ef841d6dbfb8b2ecb5f6a14242fe5612b410 Mon Sep 17 00:00:00 2001 From: some body Date: Thu, 16 Sep 2021 16:51:16 -0500 Subject: [PATCH] RircdState::run() result channel --- src/irc_endpoint.rs | 27 ++++++++++++++++----------- 1 file changed, 16 insertions(+), 11 deletions(-) diff --git a/src/irc_endpoint.rs b/src/irc_endpoint.rs index 8a93ead..d73ac85 100644 --- a/src/irc_endpoint.rs +++ b/src/irc_endpoint.rs @@ -33,18 +33,23 @@ impl Endpoint for IrcEndpoint { loop { - let (event_response_send, event_response_recv) = oneshot::channel(); - event_handler.send( - Event { - kind: EventKind::Internal(InternalEvent::Test), - result_sender: event_response_send, - }).await; + //TODO impl + break; + //tokio::select! { + // //socket.recv().parse_ircshit(); + //}; + //let (event_response_send, event_response_recv) = oneshot::channel(); + //event_handler.send( + // Event { + // kind: EventKind::Internal(InternalEvent::Test), + // result_sender: event_response_send, + // }).await; - //TODO don't unwrap - match event_response_recv.await.unwrap() { - EventResponse::Success => {}, - _ => {}, - }; + ////TODO don't unwrap + //match event_response_recv.await.unwrap() { + // EventResponse::Success => {}, + // _ => {}, + //}; } }