File tree Expand file tree Collapse file tree 1 file changed +11
-6
lines changed Expand file tree Collapse file tree 1 file changed +11
-6
lines changed Original file line number Diff line number Diff line change @@ -964,17 +964,22 @@ async fn produce_events<N: DestinationGenerator + ?Sized, A: PaymentGenerator +
964
964
}
965
965
966
966
let wait: Duration = if current_count == 0 {
967
+ let start = node_generator. payment_start ( ) ;
968
+ if start != Duration :: from_secs ( 0 ) {
969
+ log:: debug!(
970
+ "Using a start delay. The first payment for {source} will be at {:?}." ,
971
+ start
972
+ ) ;
973
+ }
974
+ start
975
+ } else {
967
976
log:: debug!(
968
- "Using a start delay. The first payment for {source} will be at {:?} seconds ." ,
969
- node_generator. payment_start ( )
977
+ "Next payment for {source} in {:?}." ,
978
+ node_generator. next_payment_wait ( )
970
979
) ;
971
- node_generator. payment_start ( )
972
- } else {
973
980
node_generator. next_payment_wait ( )
974
981
} ;
975
982
976
- log:: debug!( "Next payment for {source} in {:?} seconds." , wait) ;
977
-
978
983
select ! {
979
984
biased;
980
985
_ = listener. clone( ) => {
You can’t perform that action at this time.
0 commit comments