testostestis
/
Rircd
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

RircdState::run() result channel

This commit is contained in:
some body 2021-09-16 16:51:16 -05:00
parent b38615b5dd
commit f1d1ef841d
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/irc_endpoint.rs
View File

@ -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 => {},
// _ => {},
//};
}
}