karaolidis/qrust
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor clone()s

Browse Source 
Signed-off-by: Nikolaos Karaolidis <nick@karaolidis.com>
This commit is contained in:
Nick Karaolidis
2024-01-26 13:38:32 +00:00
parent 2829bb2970
commit 973917dad2
4 changed files with 20 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/threads/data/asset_status.rs
View File

@@ -52,17 +52,13 @@ pub async fn run(
>,
) {
loop {
let app_config = app_config.clone();
let guard = guard.clone();
let websocket_sender = websocket_sender.clone();
let message = asset_status_receiver.recv().await.unwrap();
spawn(handle_asset_status_message(
app_config,
app_config.clone(),
thread_type,
guard,
websocket_sender,
guard.clone(),
websocket_sender.clone(),
message,
));
}

13
src/threads/data/backfill.rs
View File

@@ -59,19 +59,14 @@ pub async fn run(
};
loop {
let app_config = app_config.clone();
let guard = guard.clone();
let backfill_jobs = backfill_jobs.clone();
let data_url = data_url.clone();
let message = backfill_receiver.recv().await.unwrap();
spawn(handle_backfill_message(
app_config,
app_config.clone(),
thread_type,
guard,
data_url,
backfill_jobs,
guard.clone(),
data_url.clone(),
backfill_jobs.clone(),
message,
));
}

20
src/threads/data/mod.rs
View File

@@ -58,26 +58,18 @@ pub async fn run(
loop {
select! {
Some(asset_message) = asset_receiver.recv() => {
let bars_us_equity_asset_status_sender = bars_us_equity_asset_status_sender.clone();
let bars_crypto_asset_status_sender = bars_crypto_asset_status_sender.clone();
let news_asset_status_sender = news_asset_status_sender.clone();
spawn(handle_asset_message(
bars_us_equity_asset_status_sender,
bars_crypto_asset_status_sender,
news_asset_status_sender,
bars_us_equity_asset_status_sender.clone(),
bars_crypto_asset_status_sender.clone(),
news_asset_status_sender.clone(),
asset_message,
));
}
Some(_) = clock_receiver.recv() => {
let bars_us_equity_backfill_sender = bars_us_equity_backfill_sender.clone();
let bars_crypto_backfill_sender = bars_crypto_backfill_sender.clone();
let news_backfill_sender = news_backfill_sender.clone();
spawn(handle_clock_message(
bars_us_equity_backfill_sender,
bars_crypto_backfill_sender,
news_backfill_sender,
bars_us_equity_backfill_sender.clone(),
bars_crypto_backfill_sender.clone(),
news_backfill_sender.clone(),
));
}
else => {

23
src/threads/data/websocket.rs
View File

@@ -33,19 +33,14 @@ pub async fn run(
backfill_sender: mpsc::Sender<backfill::Message>,
) {
loop {
let app_config = app_config.clone();
let guard = guard.clone();
let websocket_sender = websocket_sender.clone();
let backfill_sender = backfill_sender.clone();
let message = websocket_receiver.next().await.unwrap().unwrap();
spawn(handle_websocket_message(
app_config,
app_config.clone(),
thread_type,
guard,
websocket_sender,
backfill_sender,
guard.clone(),
websocket_sender.clone(),
backfill_sender.clone(),
message,
));
}
@@ -67,15 +62,11 @@ async fn handle_websocket_message(
if let Ok(message) = message {
for message in message {
let app_config = app_config.clone();
let guard = guard.clone();
let backfill_sender = backfill_sender.clone();
spawn(handle_parsed_websocket_message(
app_config,
app_config.clone(),
thread_type,
guard,
backfill_sender,
guard.clone(),
backfill_sender.clone(),
message,
));
}