diff --git a/src/crank.rs b/src/crank.rs index c80b1a2..7a702e1 100644 --- a/src/crank.rs +++ b/src/crank.rs @@ -106,8 +106,11 @@ pub fn start( keeper_instruction: Some(KeeperInstruction::ConsumeEvents), }; - let ok = tpu_manager.send_transaction(&tx, tx_send_record).await; - trace!("send tx={:?} ok={ok}", tx.signatures[0]); + let tpu_manager = tpu_manager.clone(); + tokio::spawn(async move { + let ok = tpu_manager.send_transaction(&tx, tx_send_record).await; + trace!("send tx={:?} ok={ok}", tx.signatures[0]); + }); } } });