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,