From 76bfd1a9a1b345bcdbed8776d6e7508cec3a2205 Mon Sep 17 00:00:00 2001 From: Brooks Prumo Date: Mon, 19 Dec 2022 17:27:21 -0500 Subject: [PATCH] Actually fixes non-binding `let` on a future (quic-client) (#29326) --- client/src/quic_client.rs | 5 +++-- quic-client/src/quic_client.rs | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/client/src/quic_client.rs b/client/src/quic_client.rs index 7c57fa3b33..1ce44feb8b 100644 --- a/client/src/quic_client.rs +++ b/client/src/quic_client.rs @@ -29,7 +29,7 @@ impl TpuConnection for QuicTpuConnection { let _lock = ASYNC_TASK_SEMAPHORE.acquire(); let inner = self.inner.clone(); - _ = RUNTIME + let _handle = RUNTIME .spawn(async move { send_wire_transaction_async(inner, wire_transaction).await }); Ok(()) } @@ -37,7 +37,8 @@ impl TpuConnection for QuicTpuConnection { fn send_wire_transaction_batch_async(&self, buffers: Vec>) -> TransportResult<()> { let _lock = ASYNC_TASK_SEMAPHORE.acquire(); let inner = self.inner.clone(); - _ = RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await }); + let _handle = + RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await }); Ok(()) } } diff --git a/quic-client/src/quic_client.rs b/quic-client/src/quic_client.rs index 271429326a..0cc5c9e353 100644 --- a/quic-client/src/quic_client.rs +++ b/quic-client/src/quic_client.rs @@ -174,7 +174,7 @@ impl TpuConnection for QuicTpuConnection { let _lock = ASYNC_TASK_SEMAPHORE.acquire(); let inner = self.inner.clone(); - _ = RUNTIME + let _handle = RUNTIME .spawn(async move { send_wire_transaction_async(inner, wire_transaction).await }); Ok(()) } @@ -182,7 +182,8 @@ impl TpuConnection for QuicTpuConnection { fn send_wire_transaction_batch_async(&self, buffers: Vec>) -> TransportResult<()> { let _lock = ASYNC_TASK_SEMAPHORE.acquire(); let inner = self.inner.clone(); - _ = RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await }); + let _handle = + RUNTIME.spawn(async move { send_wire_transaction_batch_async(inner, buffers).await }); Ok(()) } }