From 5b56ae4b694cf94ef8516dbb01ae2c21b936f8fa Mon Sep 17 00:00:00 2001 From: Geoffrey Allott Date: Fri, 5 Feb 2021 17:05:48 +0000 Subject: [PATCH] send initial interest to prevent updates being missed --- src/main.rs | 8 ++++++++ 1 file changed, 8 insertions(+) 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); -- 2.34.1