Skip to content

Commit f01b88b

Browse files
committed
tick fixes, clippy
1 parent f61ab5e commit f01b88b

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/agent/services/lazer_exporter.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -399,11 +399,13 @@ mod lazer_exporter {
399399
let (symbols_sender, mut symbols_receiver) = mpsc::channel(1);
400400
tokio::spawn(get_lazer_symbols_task(
401401
config.history_url.clone(),
402-
config.symbol_fetch_interval_duration.clone(),
402+
config.symbol_fetch_interval_duration,
403403
symbols_sender,
404404
));
405405

406406
let mut publish_interval = tokio::time::interval(config.publish_interval_duration);
407+
// consume immediate tick
408+
publish_interval.tick().await;
407409

408410
loop {
409411
tokio::select! {
@@ -496,6 +498,8 @@ mod lazer_exporter {
496498
sender: mpsc::Sender<HashMap<pyth_sdk::Identifier, SymbolResponse>>,
497499
) {
498500
let mut symbol_fetch_interval = tokio::time::interval(fetch_interval_duration);
501+
// consume immediate tick
502+
symbol_fetch_interval.tick().await;
499503

500504
loop {
501505
tokio::select! {

0 commit comments

Comments
 (0)