diff options
| author | Gustav Sörnäs <gustav@sornas.net> | 2020-11-11 13:17:41 +0100 |
|---|---|---|
| committer | Gustav Sörnäs <gustav@sornas.net> | 2020-11-11 13:17:41 +0100 |
| commit | 2a3eb31fe09152729f80f9329bedfec96c8ebff4 (patch) | |
| tree | 0ff15a62d69d7f239497a63f86825a82628c89c9 /src/slack.rs | |
| parent | c01c8716de4a91e4c60f61cf0bb6eaeca5cbf619 (diff) | |
| download | kodapa-2a3eb31fe09152729f80f9329bedfec96c8ebff4.tar.gz | |
send more strings between async
Diffstat (limited to 'src/slack.rs')
| -rw-r--r-- | src/slack.rs | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/slack.rs b/src/slack.rs index 40e465c..9a30b49 100644 --- a/src/slack.rs +++ b/src/slack.rs @@ -4,12 +4,11 @@ use tokio::sync::mpsc; pub async fn handle( token: Option<String>, sender: mpsc::UnboundedSender<String>, - _receiver: mpsc::UnboundedReceiver<String>, + mut receiver: mpsc::UnboundedReceiver<String>, ) { println!("Setting up Slack"); - let token = std::env::var("SLACK_API_TOKEN") - .unwrap_or(token.unwrap()); + let token = std::env::var("SLACK_API_TOKEN").unwrap_or(token.unwrap()); let client = slack::default_client().unwrap(); let request = slack::rtm::StartRequest::default(); @@ -36,4 +35,8 @@ pub async fn handle( } else { //TODO NotAuth etc println!("{:?}", response) } + + while let Some(s) = receiver.recv().await { + println!("Slack received '{}' from discord", s); + } } |
