File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -11,15 +11,17 @@ use thegraph_core::{Address, ChainId};
1111use tokio:: sync:: watch:: Receiver ;
1212use tracing:: warn;
1313
14+ use crate :: { AllocationWatcher , DisputeManagerWatcher } ;
15+
1416/// Receiver for Map of allocation id and attestation signer
1517pub type AttestationWatcher = Receiver < HashMap < Address , AttestationSigner > > ;
1618
1719/// An always up-to-date list of attestation signers, one for each of the indexer's allocations.
1820pub fn attestation_signers (
19- indexer_allocations_rx : Receiver < HashMap < Address , Allocation > > ,
21+ indexer_allocations_rx : AllocationWatcher ,
2022 indexer_mnemonic : Mnemonic ,
2123 chain_id : ChainId ,
22- dispute_manager_rx : Receiver < Address > ,
24+ dispute_manager_rx : DisputeManagerWatcher ,
2325) -> AttestationWatcher {
2426 let attestation_signers_map: & ' static Mutex < HashMap < Address , AttestationSigner > > =
2527 Box :: leak ( Box :: new ( Mutex :: new ( HashMap :: new ( ) ) ) ) ;
You can’t perform that action at this time.
0 commit comments