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

fix-server-stream

Browse Source
This commit is contained in:
Untone 2023-10-16 23:40:13 +03:00
parent 64fcd55305
commit 99cb832538
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main.rs
View File

@ -110,11 +110,6 @@ async fn connect_handler(
.unwrap() .unwrap()
.insert(format!("{}", listener_id.clone()), handle); .insert(format!("{}", listener_id.clone()), handle);
let server_event = rx.recv().await.map_err(|e| {
eprintln!("Failed to receive server event: {}", e);
ServerError("Internal Server Error")
})?;
let server_event_stream = futures::stream::unfold(rx, |mut rx| async { let server_event_stream = futures::stream::unfold(rx, |mut rx| async {
let result = rx.recv().await; let result = rx.recv().await;
match result { match result {