blackbeard420/irc-rpc
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update to use tokio spawn

Browse Source
This commit is contained in:
blackbeard420 2023-12-28 18:40:59 -05:00
parent 16b32a554c
commit 677f5aede7
Signed by: blackbeard420
GPG Key ID: 88C719E09CDDA4A5
1 changed files with 28 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
src/main.rs
View File

@ -37,13 +37,15 @@ async fn main() -> Result<(), failure::Error> {
let out = cmd.output().unwrap(); let out = cmd.output().unwrap();
let output = String::from_utf8_lossy(&out.stdout); let output = String::from_utf8_lossy(&out.stdout).to_string();
let lines = output.lines(); let s = sender.clone();
for l in lines { let t = target.to_string();
sender.send_privmsg(target, l)?;
} tokio::spawn(async move {
send_message(s, t, output).await
});
} }
if &msg[1..2] == "p" { if &msg[1..2] == "p" {
@ -57,30 +59,35 @@ async fn main() -> Result<(), failure::Error> {
let out = cmd.output().unwrap(); let out = cmd.output().unwrap();
let outerr = String::from_utf8_lossy(&out.stderr); let outerr = String::from_utf8_lossy(&out.stderr).to_string();
let output = String::from_utf8_lossy(&out.stdout); let output = String::from_utf8_lossy(&out.stdout).to_string();
let lines = outerr.lines(); let s = sender.clone();
for l in lines { let t = target.to_string();
tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
sender.send_privmsg(target, l)?; tokio::spawn(async move {
send_message(s, t, outerr).await
});
let s = sender.clone();
let t = target.to_string();
tokio::spawn(async move {
send_message(s.clone(), t, output).await
});
} }
let lines = output.lines();
for l in lines {
tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
sender.send_privmsg(target, l)?;
}
}
}
if msg.contains(client.current_nickname()) {
sender.send_privmsg(target, "Hi!")?;
} }
} }
} }
Ok(()) Ok(())
} }
async fn send_message(sender: irc::client::Sender, target: String, msg: String) -> Result<(), failure::Error> {
for l in msg.lines() {
sender.send_privmsg(target.clone(), l)?;
tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
}
Ok(())
}