chore: Spawn tokio tasks for each received trading message

Spawning a new tokio task when processing a message prevents us from potentially blocking trading requests as the trading module might still be busy processing the last request.
get10101 · Sep 14, 2023 · f21358c · f21358c
1 parent 2be5881
commit f21358c
Show file tree

Hide file tree

Showing 2 changed files with 194 additions and 193 deletions.
diff --git a/coordinator/src/bin/coordinator.rs b/coordinator/src/bin/coordinator.rs
@@ -193,7 +193,7 @@ async fn main() -> Result<()> {
     });
 
     let (tx_price_feed, _rx) = broadcast::channel(100);
-    let (_handle, trading_sender) = trading::Trading::start(pool.clone(), tx_price_feed.clone());
+    let (_handle, trading_sender) = trading::start(pool.clone(), tx_price_feed.clone());
 
     tokio::spawn({
         let node = node.clone();