diff --git a/src/irc_endpoint.rs b/src/irc_endpoint.rs index d73ac85..ee16fc6 100644 --- a/src/irc_endpoint.rs +++ b/src/irc_endpoint.rs @@ -25,11 +25,12 @@ impl Endpoint for IrcEndpoint { true } - async fn listen(self: Arc, event_sink_sender: oneshot::Sender>>, + async fn listen(self: Arc, event_state_handler_sender: oneshot::Sender>>, event_handler: mpsc::Sender) { //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 {