clone shutdown tx

crates/torii/core/src/sql_test.rs

@@ -140,7 +140,7 @@ async fn test_load_from_remote(sequencer: &RunnerCtx) {
     let world_reader = WorldContractReader::new(strat.world_address, Arc::clone(&provider));
 
     let (shutdown_tx, _) = broadcast::channel(1);
-    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
     tokio::spawn(async move {
         executor.run().await.unwrap();
     });
@@ -302,7 +302,7 @@ async fn test_load_from_remote_del(sequencer: &RunnerCtx) {
     let world_reader = WorldContractReader::new(strat.world_address, Arc::clone(&provider));
 
     let (shutdown_tx, _) = broadcast::channel(1);
-    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
     tokio::spawn(async move {
         executor.run().await.unwrap();
     });
@@ -393,7 +393,7 @@ async fn test_update_with_set_record(sequencer: &RunnerCtx) {
     let world_reader = WorldContractReader::new(strat.world_address, Arc::clone(&provider));
 
     let (shutdown_tx, _) = broadcast::channel(1);
-    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
     tokio::spawn(async move {
         executor.run().await.unwrap();
     });

crates/torii/graphql/src/tests/metadata_test.rs

@@ -51,7 +51,7 @@ mod tests {
     #[sqlx::test(migrations = "../migrations")]
     async fn test_metadata(pool: SqlitePool) {
         let (shutdown_tx, _) = broadcast::channel(1);
-        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
         tokio::spawn(async move {
             executor.run().await.unwrap();
         });

crates/torii/graphql/src/tests/mod.rs

@@ -352,7 +352,7 @@ pub async fn spinup_types_test() -> Result<SqlitePool> {
     let world = WorldContractReader::new(strat.world_address, Arc::clone(&provider));
 
     let (shutdown_tx, _) = broadcast::channel(1);
-    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
     tokio::spawn(async move {
         executor.run().await.unwrap();
     });

crates/torii/graphql/src/tests/subscription_test.rs

@@ -23,7 +23,7 @@ mod tests {
     #[serial]
     async fn test_entity_subscription(pool: SqlitePool) {
         let (shutdown_tx, _) = broadcast::channel(1);
-        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
         tokio::spawn(async move {
             executor.run().await.unwrap();
         });
@@ -163,7 +163,7 @@ mod tests {
     #[serial]
     async fn test_entity_subscription_with_id(pool: SqlitePool) {
         let (shutdown_tx, _) = broadcast::channel(1);
-        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
         tokio::spawn(async move {
             executor.run().await.unwrap();
         });
@@ -283,7 +283,7 @@ mod tests {
     #[serial]
     async fn test_model_subscription(pool: SqlitePool) {
         let (shutdown_tx, _) = broadcast::channel(1);
-        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
         tokio::spawn(async move {
             executor.run().await.unwrap();
         });
@@ -353,7 +353,7 @@ mod tests {
     #[serial]
     async fn test_model_subscription_with_id(pool: SqlitePool) {
         let (shutdown_tx, _) = broadcast::channel(1);
-        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
         tokio::spawn(async move {
             executor.run().await.unwrap();
         });
@@ -424,7 +424,7 @@ mod tests {
     #[serial]
     async fn test_event_emitted(pool: SqlitePool) {
         let (shutdown_tx, _) = broadcast::channel(1);
-        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
         tokio::spawn(async move {
             executor.run().await.unwrap();
         });

crates/torii/grpc/src/server/tests/entities_test.rs

@@ -94,7 +94,7 @@ async fn test_entities_queries(sequencer: &RunnerCtx) {
     TransactionWaiter::new(tx.transaction_hash, &provider).await.unwrap();
 
     let (shutdown_tx, _) = broadcast::channel(1);
-    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+    let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
     tokio::spawn(async move {
         executor.run().await.unwrap();
     });

crates/torii/libp2p/src/tests.rs

@@ -562,7 +562,7 @@ mod test {
         let account = sequencer.account_data(0);
 
         let (shutdown_tx, _) = broadcast::channel(1);
-        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx).await.unwrap();
+        let (mut executor, sender) = Executor::new(pool.clone(), shutdown_tx.clone()).await.unwrap();
         tokio::spawn(async move {
             executor.run().await.unwrap();
         });