rename

src/main.rs

@@ -115,12 +115,6 @@ impl Transaction {
     }
 }
 
-#[derive(Serialize, Deserialize)]
-struct Item {
-    id: i32,
-    name: String,
-}
-
 #[derive(Serialize)]
 struct AccountResponse {
     amount: String,
@@ -215,16 +209,16 @@ async fn get_info(info: web::Path<AnyId>, ctx: web::Data<Ledger>) -> impl Respon
         })
 }
 
-struct ReceiverStream {
+struct SubscriberStream {
     receiver: Receiver<verax::Transaction>,
-    interval: Interval,
+    ping_interval: Interval,
 }
 
-impl Stream for ReceiverStream {
+impl Stream for SubscriberStream {
     type Item = Result<Bytes, actix_web::Error>;
 
     fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
-        match Pin::new(&mut self.interval).poll_tick(cx) {
+        match Pin::new(&mut self.ping_interval).poll_tick(cx) {
             Poll::Ready(_) => {
                 // Send a heartbeat message
                 let heartbeat_bytes = Bytes::copy_from_slice(b"{\"ping\": \"\"}\n");
@@ -255,14 +249,12 @@ async fn subscribe_by_tag(tag: web::Path<Tag>, ctx: web::Data<Ledger>) -> impl R
         })
         .await;
 
-    let body = ReceiverStream {
-        receiver,
-        interval: time::interval(Duration::from_secs(30)),
-    };
-
     HttpResponse::Ok()
         .content_type("application/json")
-        .streaming(body)
+        .streaming(SubscriberStream {
+            receiver,
+            ping_interval: time::interval(Duration::from_secs(30)),
+        })
 }
 
 #[post("/deposit")]