We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c5ab64b commit 0b7fc79Copy full SHA for 0b7fc79
src/io_uring.rs
@@ -248,8 +248,7 @@ pub async fn io_loop(
248
));
249
250
// Thread for monitoring transfer
251
- let mut monitor =
252
- tokio_uring::spawn(transfer_monitor(stats_interval, file_bytes, stream_bytes));
+ let mut monitor = tokio::spawn(transfer_monitor(stats_interval, file_bytes, stream_bytes));
253
254
// Stop as soon as one of them errors
255
let res = tokio::try_join!(&mut from_file, &mut from_stream, &mut monitor);
0 commit comments