blockworks-foundation
/
solana-with-rpc-optimizations
mirror of https://github.com/blockworks-foundation/solana-with-rpc-optimizations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixes non-binding `let` on a future (quic-client) (#29300)

This commit is contained in:
Brooks Prumo 2022-12-17 03:01:22 -05:00 committed by GitHub
parent 0281973671
commit d1722b7a7a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
client/src/quic_client.rs
View File

@ -29,7 +29,7 @@ impl TpuConnection for QuicTpuConnection {
let _lock = ASYNC_TASK_SEMAPHORE.acquire();
let inner = self.inner.clone();
let _ = RUNTIME
_ = RUNTIME
.spawn(async move { send_wire_transaction_async(inner, wire_transaction).await });
Ok(())
}
@ -37,8 +37,7 @@ impl TpuConnection for QuicTpuConnection {
fn send_wire_transaction_batch_async(&self, buffers: Vec<Vec<u8>>) -> TransportResult<()> {
let _lock = ASYNC_TASK_SEMAPHORE.acquire();
let inner = self.inner.clone();
let _ =
RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await });
_ = RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await });
Ok(())
}
}

5
quic-client/src/quic_client.rs
View File

@ -174,7 +174,7 @@ impl TpuConnection for QuicTpuConnection {
let _lock = ASYNC_TASK_SEMAPHORE.acquire();
let inner = self.inner.clone();
let _ = RUNTIME
_ = RUNTIME
.spawn(async move { send_wire_transaction_async(inner, wire_transaction).await });
Ok(())
}
@ -182,8 +182,7 @@ impl TpuConnection for QuicTpuConnection {
fn send_wire_transaction_batch_async(&self, buffers: Vec<Vec<u8>>) -> TransportResult<()> {
let _lock = ASYNC_TASK_SEMAPHORE.acquire();
let inner = self.inner.clone();
let _ =
RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await });
_ = RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await });
Ok(())
}
}