@@ -603,8 +603,7 @@ pub async fn process_events_async<
603
603
CM : ' static + Deref < Target = ChannelManager < CW , T , ES , NS , SP , F , R , L > > + Send + Sync ,
604
604
PGS : ' static + Deref < Target = P2PGossipSync < G , UL , L > > + Send + Sync ,
605
605
RGS : ' static + Deref < Target = RapidGossipSync < G , L > > + Send ,
606
- APM : APeerManager + Send + Sync ,
607
- PM : ' static + Deref < Target = APM > + Send + Sync ,
606
+ PM : ' static + Deref + Send + Sync ,
608
607
S : ' static + Deref < Target = SC > + Send + Sync ,
609
608
SC : for < ' b > WriteableScore < ' b > ,
610
609
SleepFuture : core:: future:: Future < Output = bool > + core:: marker:: Unpin ,
@@ -627,6 +626,7 @@ where
627
626
L :: Target : ' static + Logger ,
628
627
P :: Target : ' static + Persist < <SP :: Target as SignerProvider >:: EcdsaSigner > ,
629
628
PS :: Target : ' static + Persister < ' a , CW , T , ES , NS , SP , F , R , L , SC > ,
629
+ PM :: Target : APeerManager + Send + Sync ,
630
630
{
631
631
let mut should_break = false ;
632
632
let async_event_handler = |event| {
@@ -742,8 +742,7 @@ impl BackgroundProcessor {
742
742
CM : ' static + Deref < Target = ChannelManager < CW , T , ES , NS , SP , F , R , L > > + Send + Sync ,
743
743
PGS : ' static + Deref < Target = P2PGossipSync < G , UL , L > > + Send + Sync ,
744
744
RGS : ' static + Deref < Target = RapidGossipSync < G , L > > + Send ,
745
- APM : APeerManager + Send + Sync ,
746
- PM : ' static + Deref < Target = APM > + Send + Sync ,
745
+ PM : ' static + Deref + Send + Sync ,
747
746
S : ' static + Deref < Target = SC > + Send + Sync ,
748
747
SC : for < ' b > WriteableScore < ' b > ,
749
748
> (
@@ -763,6 +762,7 @@ impl BackgroundProcessor {
763
762
L :: Target : ' static + Logger ,
764
763
P :: Target : ' static + Persist < <SP :: Target as SignerProvider >:: EcdsaSigner > ,
765
764
PS :: Target : ' static + Persister < ' a , CW , T , ES , NS , SP , F , R , L , SC > ,
765
+ PM :: Target : APeerManager + Send + Sync ,
766
766
{
767
767
let stop_thread = Arc :: new ( AtomicBool :: new ( false ) ) ;
768
768
let stop_thread_clone = stop_thread. clone ( ) ;
0 commit comments