From eeb6b64af8bd17f0c56e9392a11fbbc678734aeb Mon Sep 17 00:00:00 2001 From: Akosh Farkash Date: Tue, 30 Jul 2024 14:06:07 +0100 Subject: [PATCH] BFT-496: Remove the subscription method --- node/actors/executor/src/lib.rs | 2 +- node/actors/network/src/lib.rs | 5 ----- 2 files changed, 1 insertion(+), 6 deletions(-) diff --git a/node/actors/executor/src/lib.rs b/node/actors/executor/src/lib.rs index 844198ad7..64106f6a1 100644 --- a/node/actors/executor/src/lib.rs +++ b/node/actors/executor/src/lib.rs @@ -152,7 +152,7 @@ impl Executor { self.batch_store.clone(), attester, net.batch_vote_publisher(), - net.attestation_status_receiver(), + self.attestation_status.subscribe(), ); s.spawn(async { runner.run(ctx).await?; diff --git a/node/actors/network/src/lib.rs b/node/actors/network/src/lib.rs index d4104093f..3ea0422e3 100644 --- a/node/actors/network/src/lib.rs +++ b/node/actors/network/src/lib.rs @@ -82,11 +82,6 @@ impl Network { BatchVotesPublisher(self.gossip.batch_votes.clone()) } - /// Subscribe to attestation status change notifications. - pub fn attestation_status_receiver(&self) -> AttestationStatusReceiver { - self.gossip.attestation_status.subscribe() - } - /// Handles a dispatcher message. async fn handle_message( &self,