discours.io/quoter
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

logs

Browse Source
This commit is contained in:
Tony Rewin 2023-10-06 15:10:17 +03:00
parent 28a5aa15a7
commit 36aad923d3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main.rs
View File

@ -47,7 +47,7 @@ async fn sse_handler(
for chat_id in &chats { for chat_id in &chats {
let channel_name = format!("chat:{}", chat_id); let channel_name = format!("chat:{}", chat_id);
pubsub.subscribe(&channel_name).await.unwrap(); pubsub.subscribe(&channel_name).await.unwrap();
println!(format!("'{}' subscribed", channel_name)); println!("'{}' subscribed", channel_name);
} }
while let Some(msg) = pubsub.on_message().next().await { while let Some(msg) = pubsub.on_message().next().await {