From c31c8e91ac2b622f6823ea56391565ca0e0997f7 Mon Sep 17 00:00:00 2001
From: Zynh0722 <Zynh0722@gmail.com>
Date: Mon, 6 Nov 2023 17:54:10 -0800
Subject: [PATCH] throttle updates

---
 Cargo.toml | 2 +-
 src/api.rs | 5 ++++-
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index 649e120..4672b43 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -18,7 +18,7 @@ tracing = "0.1"
 tracing-subscriber = { version = "0.3", features = ["env-filter"] }
 tower-http = { version = "0.4.4", features = ["full"] }
 ructe.workspace = true
-tokio-stream = { version = "0.1.14", features = ["sync"] }
+tokio-stream = { version = "0.1.14", features = ["sync", "time"] }
 futures-util = "0.3.28"
 diesel = { version = "2.1.0", features = ["chrono"] }
 diesel-async = { version = "0.4.1", features = ["mysql", "deadpool"] }
diff --git a/src/api.rs b/src/api.rs
index 84b8b2f..990df5b 100644
--- a/src/api.rs
+++ b/src/api.rs
@@ -1,3 +1,5 @@
+use std::time::Duration;
+
 use axum::{
     extract::{Path, State},
     response::{
@@ -182,7 +184,8 @@ async fn ada_subscribe(
     State(state): State<AppState>,
 ) -> Sse<impl Stream<Item = Result<Event, BroadcastStreamRecvError>>> {
     let stream = BroadcastStream::new(state.sse_handler.ada_sender.subscribe())
-        .map(|r| r.map(|s| Event::default().event("ada").data(s)));
+        .map(|r| r.map(|s| Event::default().event("ada").data(s)))
+        .throttle(Duration::from_secs(1));
 
     Sse::new(stream).keep_alive(KeepAlive::default())
 }