From 3769cae1ced6809732d042aefddc54bc560ceeab Mon Sep 17 00:00:00 2001
From: Igor Katson <igor.katson@gmail.com>
Date: Fri, 3 May 2024 13:59:05 +0100
Subject: [PATCH] dont blow up memory

---
 crates/librqbit/src/torrent_state/live/mod.rs | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/crates/librqbit/src/torrent_state/live/mod.rs b/crates/librqbit/src/torrent_state/live/mod.rs
index 3e42bd7..629daac 100644
--- a/crates/librqbit/src/torrent_state/live/mod.rs
+++ b/crates/librqbit/src/torrent_state/live/mod.rs
@@ -262,11 +262,14 @@ impl TorrentStateLive {
         if defer_writes {
             state.spawn(
                 error_span!(parent: state.meta.span.clone(), "disk_writer"),
-                async move {
-                    while let Some(work_item) = disk_work_rx.recv().await {
-                        tokio::task::spawn_blocking(work_item.work);
+                {
+                    let spawner = state.meta.spawner;
+                    async move {
+                        while let Some(work_item) = disk_work_rx.recv().await {
+                            spawner.spawn_block_in_place(work_item.work);
+                        }
+                        Ok(())
                     }
-                    Ok(())
                 },
             );
         }