lints

gbaranski · Oct 13, 2023 · d5a1d69 · d5a1d69
1 parent 15d1cf7
commit d5a1d69
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/socket.rs b/src/socket.rs
@@ -535,9 +535,9 @@ impl Socket {
         let (sink_result_sender, sink_result_receiver) = async_channel::bounded(1usize);
         handle.spawn(async move {
             let _ = stream_future.extract().await;
-            let _ = sink_abort_sender.send(());
-            let _ = hearbeat_abort_sender.send(());
-            let _ = sink_result_sender.send(
+            let _ = sink_abort_sender.send_blocking(());
+            let _ = hearbeat_abort_sender.send_blocking(());
+            let _ = sink_result_sender.send_blocking(
                 sink_future
                     .extract()
                     .await