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:54:12 -05:00
parent f1d1ef841d
commit bf60fbc6b6
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/irc_endpoint.rs
View File

@ -25,11 +25,12 @@ impl Endpoint for IrcEndpoint {
true
}
async fn listen(self: Arc<Self>, event_sink_sender: oneshot::Sender<Result<mpsc::Sender<Event>>>,
async fn listen(self: Arc<Self>, event_state_handler_sender: oneshot::Sender<Result<mpsc::Sender<Event>>>,
event_handler: mpsc::Sender<Event>) {
//TODO find apropiate defeault or size
let (s,r) = mpsc::channel(64);
event_sink_sender.send(Ok(s));
let (event_sender,event_receiver) = mpsc::channel(64);
event_state_handler_sender.send(Ok(event_sender));
loop {