|
@@ -99,9 +99,9 @@ impl Worker for Broadcaster {
|
|
|
for to_rebuild in &subscriptions_to_reindex {
|
|
|
if let Some(list_of_senders) = listeners.get_mut(to_rebuild) {
|
|
|
*list_of_senders = list_of_senders
|
|
|
- .into_iter()
|
|
|
+ .iter()
|
|
|
.filter(|x| senders.contains_key(*x))
|
|
|
- .map(|x| *x)
|
|
|
+ .copied()
|
|
|
.collect::<Vec<_>>();
|
|
|
}
|
|
|
}
|
|
@@ -282,7 +282,7 @@ where
|
|
|
async fn persist(&self, mut transaction: Transaction) -> Result<Transaction, Error> {
|
|
|
transaction.persist(&self.config).await?;
|
|
|
|
|
|
- let _ = self.brodcaster.send(transaction.clone());
|
|
|
+ self.brodcaster.send(transaction.clone());
|
|
|
Ok(transaction)
|
|
|
}
|
|
|
|