diff --git a/crates/librqbit/src/torrent_state/live/mod.rs b/crates/librqbit/src/torrent_state/live/mod.rs
index e465cbc..2cffbcc 100644
--- a/crates/librqbit/src/torrent_state/live/mod.rs
+++ b/crates/librqbit/src/torrent_state/live/mod.rs
@@ -176,8 +176,6 @@ pub struct TorrentStateLive {
     up_speed_estimator: SpeedEstimator,
     cancellation_token: CancellationToken,
 
-    disk_work_queue_tx: std::sync::mpsc::SyncSender<Box<dyn FnOnce() + Send + Sync>>,
-
     pub(crate) streams: Arc<TorrentStreams>,
 }
 
@@ -209,8 +207,6 @@ impl TorrentStateLive {
             pri
         };
 
-        let (disk_work_queue_tx, mut disk_work_queue_rx) = std::sync::mpsc::sync_channel(2048);
-
         let state = Arc::new(TorrentStateLive {
             meta: paused.info.clone(),
             peers: Default::default(),
@@ -233,17 +229,8 @@ impl TorrentStateLive {
             up_speed_estimator,
             cancellation_token,
             streams: paused.streams,
-            disk_work_queue_tx,
         });
 
-        if paused.info.options.defer_writes {
-            tokio::runtime::Handle::current().spawn_blocking(move || {
-                while let Ok(work_unit) = disk_work_queue_rx.recv() {
-                    work_unit();
-                }
-            });
-        }
-
         state.spawn(
             error_span!(parent: state.meta.span.clone(), "speed_estimator_updater"),
             {
@@ -1488,7 +1475,6 @@ impl PeerHandler {
             let counters = self.counters.clone();
             let piece = piece.clone_to_owned();
             let tx = self.tx.clone();
-            let disk_work_queue_tx = state.disk_work_queue_tx.clone();
 
             let work = move || {
                 if let Err(e) = write_to_disk(
@@ -1502,8 +1488,7 @@ impl PeerHandler {
                     let _ = tx.send(WriterRequest::Disconnect(Err(e)));
                 }
             };
-            tokio::runtime::Handle::current().spawn_blocking(work);
-            // disk_work_queue_tx.send(Box::new(work))?;
+            tokio::task::spawn_blocking(work);
         } else {
             self.state
                 .meta