@@ -603,8 +603,7 @@ pub async fn process_events_async<
603603 CM : ' static + Deref < Target = ChannelManager < CW , T , ES , NS , SP , F , R , L > > + Send + Sync ,
604604 PGS : ' static + Deref < Target = P2PGossipSync < G , UL , L > > + Send + Sync ,
605605 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 ,
608607 S : ' static + Deref < Target = SC > + Send + Sync ,
609608 SC : for < ' b > WriteableScore < ' b > ,
610609 SleepFuture : core:: future:: Future < Output = bool > + core:: marker:: Unpin ,
@@ -627,6 +626,7 @@ where
627626 L :: Target : ' static + Logger ,
628627 P :: Target : ' static + Persist < <SP :: Target as SignerProvider >:: Signer > ,
629628 PS :: Target : ' static + Persister < ' a , CW , T , ES , NS , SP , F , R , L , SC > ,
629+ PM :: Target : APeerManager + Send + Sync ,
630630{
631631 let mut should_break = false ;
632632 let async_event_handler = |event| {
@@ -742,8 +742,7 @@ impl BackgroundProcessor {
742742 CM : ' static + Deref < Target = ChannelManager < CW , T , ES , NS , SP , F , R , L > > + Send + Sync ,
743743 PGS : ' static + Deref < Target = P2PGossipSync < G , UL , L > > + Send + Sync ,
744744 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 ,
747746 S : ' static + Deref < Target = SC > + Send + Sync ,
748747 SC : for < ' b > WriteableScore < ' b > ,
749748 > (
@@ -763,6 +762,7 @@ impl BackgroundProcessor {
763762 L :: Target : ' static + Logger ,
764763 P :: Target : ' static + Persist < <SP :: Target as SignerProvider >:: Signer > ,
765764 PS :: Target : ' static + Persister < ' a , CW , T , ES , NS , SP , F , R , L , SC > ,
765+ PM :: Target : APeerManager + Send + Sync ,
766766 {
767767 let stop_thread = Arc :: new ( AtomicBool :: new ( false ) ) ;
768768 let stop_thread_clone = stop_thread. clone ( ) ;
0 commit comments