diff --git a/crates/librqbit/src/torrent_state/live/mod.rs b/crates/librqbit/src/torrent_state/live/mod.rs index 3024e7a..0b252b7 100644 --- a/crates/librqbit/src/torrent_state/live/mod.rs +++ b/crates/librqbit/src/torrent_state/live/mod.rs @@ -1513,7 +1513,9 @@ impl PeerHandler { let _ = tx.send(WriterRequest::Disconnect(Err(e))); } }; - disk_work_queue_tx.blocking_send(Box::new(work))?; + self.state.spawn(error_span!("disk_work"), async move { + Ok(disk_work_queue_tx.send(Box::new(work)).await?) + }); } else { self.state .meta