@@ -402,7 +402,7 @@ where
402
402
/// [`io::ErrorKind::NotFound`] variant correctly. For more information, please see the
403
403
/// documentation for [`MonitorUpdatingPersister`].
404
404
pub fn read_all_channel_monitors_with_updates < B : Deref , F : Deref + Clone > (
405
- & self , broadcaster : & B , fee_estimator : F ,
405
+ & self , broadcaster : B , fee_estimator : F ,
406
406
) -> io:: Result < Vec < ( BlockHash , ChannelMonitor < <SP :: Target as SignerProvider >:: Signer > ) > >
407
407
where
408
408
ES :: Target : EntropySource + Sized ,
@@ -417,7 +417,7 @@ where
417
417
let mut res = Vec :: with_capacity ( monitor_list. len ( ) ) ;
418
418
for monitor_key in monitor_list {
419
419
res. push ( self . read_channel_monitor_with_updates (
420
- broadcaster,
420
+ & broadcaster,
421
421
& fee_estimator,
422
422
monitor_key,
423
423
) ?)
@@ -434,7 +434,7 @@ where
434
434
/// Loading a large number of monitors will be faster if done in parallel. You can use this
435
435
/// function to accomplish this. Take care to limit the number of parallel readers.
436
436
pub fn read_channel_monitor_with_updates < B : Deref , F : Deref + Clone > (
437
- & self , broadcaster : & B , fee_estimator : & F , monitor_key : String ,
437
+ & self , broadcaster : B , fee_estimator : F , monitor_key : String ,
438
438
) -> io:: Result < ( BlockHash , ChannelMonitor < <SP :: Target as SignerProvider >:: Signer > ) >
439
439
where
440
440
ES :: Target : EntropySource + Sized ,
@@ -460,8 +460,7 @@ where
460
460
Err ( err) => return Err ( err) ,
461
461
} ;
462
462
463
- monitor
464
- . update_monitor ( & update, broadcaster, fee_estimator. clone ( ) , & self . logger )
463
+ monitor. update_monitor ( & update, & broadcaster, fee_estimator. clone ( ) , & self . logger )
465
464
. map_err ( |e| {
466
465
log_error ! (
467
466
self . logger,
@@ -711,8 +710,8 @@ where
711
710
& self , funding_txo : OutPoint , update : Option < & ChannelMonitorUpdate > ,
712
711
monitor : & ChannelMonitor < ChannelSigner > , monitor_update_call_id : MonitorUpdateId ,
713
712
) -> chain:: ChannelMonitorUpdateStatus {
714
- // IMPORTANT: monitor_update_call_id: [` MonitorUpdateId`] is not to be confused with
715
- // [` ChannelMonitorUpdate`] 's update_id.
713
+ // IMPORTANT: monitor_update_call_id: MonitorUpdateId is not to be confused with
714
+ // ChannelMonitorUpdate's update_id.
716
715
if let Some ( update) = update {
717
716
if update. update_id != CLOSED_CHANNEL_UPDATE_ID
718
717
&& update. update_id % self . maximum_pending_updates != 0
0 commit comments