fixes-29
This commit is contained in:
parent
f892abbd6a
commit
4db2a1fec6
|
@ -10,7 +10,6 @@ use futures::StreamExt;
|
||||||
use tokio::sync::broadcast::{self, Receiver};
|
use tokio::sync::broadcast::{self, Receiver};
|
||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
use chrono::Utc;
|
use chrono::Utc;
|
||||||
use std::borrow::Borrow;
|
|
||||||
|
|
||||||
#[derive(Debug, Serialize, Deserialize)]
|
#[derive(Debug, Serialize, Deserialize)]
|
||||||
#[serde(rename_all = "snake_case")]
|
#[serde(rename_all = "snake_case")]
|
||||||
|
@ -165,7 +164,7 @@ async fn sse_handler(
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
let server_event = match rx.get_ref().recv().await {
|
let server_event = match rx.recv().await {
|
||||||
Ok(event) => event,
|
Ok(event) => event,
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
eprintln!("Failed to receive server event: {}", e);
|
eprintln!("Failed to receive server event: {}", e);
|
||||||
|
|
Loading…
Reference in New Issue
Block a user