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(()) } }