use local eqnue

src/bridge.rs

@@ -211,8 +211,6 @@ impl LiteRpcServer for LiteBridge {
             .unwrap()
             .signatures[0];
 
-        self.tpu_client.send_wire_transaction(raw_tx.clone()).await;
-
         self.tx_sender.enqnueue_tx(sig.to_string(), raw_tx);
 
         Ok(BinaryEncoding::Base58.encode(sig))

src/workers/tx_sender.rs

@@ -52,7 +52,7 @@ impl TxSender {
 
         let mut batch_index = 0;
 
-        for (index, tx) in self.enqueued_txs.read().unwrap().iter().enumerate() {
+        for (index, tx) in enqueued_txs.iter().enumerate() {
             if index % tx_batch_size == 0 {
                 tx_batch.push(Vec::with_capacity(tx_batch_size));
                 batch_index += 1;