From: Geoffrey Allott <geoffrey@allott.email>
Date: Fri, 5 Feb 2021 17:05:48 +0000 (+0000)
Subject: send initial interest to prevent updates being missed
X-Git-Url: https://git.pointlesshacks.com/?a=commitdiff_plain;h=5b56ae4b694cf94ef8516dbb01ae2c21b936f8fa;p=pokerwave.git

send initial interest to prevent updates being missed
---

diff --git a/src/main.rs b/src/main.rs
index 4fe04b5..793244c 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -98,6 +98,14 @@ pub async fn handle_client_interest(mut connection: PubSub, mut new_clients: Rec
                         error!("handle_client_interest: Unsubscribe failed: {}", err);
                     }
                 }
+                let client = &mut clients[index];
+                let sender = &mut client.sender;
+                for interest in &client.interests - &client_interests {
+                    debug!("handle_client_interest: Sending initial interest for new interest {:?} to {:?}", interest, sender);
+                    if let Err(err) = sender.interest.send(interest.clone()).await {
+                        error!("handle_client_interest: Send failed: {}", err);
+                    }
+                }
             }
             Action::SendInterest{interest} => {
                 debug!("handle_client_interest: Action::SendInterest {{ interest: {:?} }}", interest);