Correctly replace subscriptions if ID matches

This commit is contained in:
Greg Heartsfield 2021-11-24 16:22:28 -06:00
parent 1a0f66a518
commit 5bc36cc591

View File

@ -55,9 +55,11 @@ impl Proto {
info!("Dropping subscription with huge ({}) length", sub_id_len); info!("Dropping subscription with huge ({}) length", sub_id_len);
return; return;
} }
// check if an existing subscription exists. // check if an existing subscription exists, and replace if so
if self.subscriptions.contains_key(&k) { if self.subscriptions.contains_key(&k) {
info!("Client requested a subscription with an already-existing key"); self.subscriptions.remove(&k);
self.subscriptions.insert(k, s);
info!("Replaced existing subscription");
return; return;
} }