diff --git a/syncer/src/actor.rs b/syncer/src/actor.rs index 239bbcd..102d72b 100644 --- a/syncer/src/actor.rs +++ b/syncer/src/actor.rs @@ -458,7 +458,6 @@ where // If found, persist the block and send to application self.cache_block(round, commitment, block.clone()).await; application.report(Update::NotarizedBlock(block.clone())).await; - self.notify_subscribers(commitment, &block).await; } else { debug!(?round, "notarized block missing"); resolver.fetch(Request::::Notarized { round }).await; @@ -804,7 +803,6 @@ where // Cache the notarization and block self.cache_block(round, commitment, block.clone()).await; self.cache.put_notarization(round, commitment, notarization).await; - self.notify_subscribers(commitment, &block).await; }, } },