diff --git a/CodeEdit/Features/Documents/WorkspaceDocument/WorkspaceDocument+Index.swift b/CodeEdit/Features/Documents/WorkspaceDocument/WorkspaceDocument+Index.swiftindex 5a5a4620..0ffad45b 100644--- a/CodeEdit/Features/Documents/WorkspaceDocument/WorkspaceDocument+Index.swift+++ b/CodeEdit/Features/Documents/WorkspaceDocument/WorkspaceDocument+Index.swift@@ -25,6 +25,10 @@ extension WorkspaceDocument.SearchState {             )         }+        let (progressStream, continuation) = AsyncStream<Double>.makeStream()+        // Dispatch this now, we want to continue after starting to monitor+        Task { await self.monitorProgressStream(progressStream, activityId: activity.id) }+         Task.detached {             let filePaths = self.getFileURLs(at: url)             let asyncController = SearchIndexer.AsyncManager(index: indexer)@@ -33,16 +37,6 @@ extension WorkspaceDocument.SearchState {             // Batch our progress updates             var pendingProgress: Double?-            func updateProgress(_ progress: Double) async {-                await MainActor.run {-                    self.indexStatus = .indexing(progress: progress)-                    self.workspace.activityManager.update(-                        id: activity.id,-                        percentage: progress-                    )-                }-            }-             for await (file, index) in AsyncFileIterator(fileURLs: filePaths) {                 _ = await asyncController.addText(files: [file], flushWhenComplete: false)                 let progress = Double(index) / Double(filePaths.count)@@ -54,7 +48,7 @@ extension WorkspaceDocument.SearchState {                      // Only update UI every 100ms                     if index == filePaths.count - 1 || pendingProgress != nil {-                        await updateProgress(progress)+                        continuation.yield(progress)                         pendingProgress = nil                     }                 }@@ -77,6 +71,25 @@ extension WorkspaceDocument.SearchState {         }     }++    /// Monitors a progress stream from ``addProjectToIndex()`` and updates ``indexStatus`` and the workspace's activity+    /// manager accordingly.+    ///+    /// Without this, updates can come too fast for `Combine` to handle and can cause crashes.+    ///+    /// - Parameters:+    ///   - stream: The stream to monitor for progress updates, in %.+    ///   - activityId: The activity ID that's being monitored+    @MainActor private func monitorProgressStream(_ stream: AsyncStream<Double>, activityId: String) async {+        for await progressUpdate in stream.debounce(for: .milliseconds(10)) {+            self.indexStatus = .indexing(progress: progressUpdate)+            self.workspace.activityManager.update(+                id: activityId,+                percentage: progressUpdate+            )+        }+    }+     /// Retrieves an array of file URLs within the specified directory URL.     ///     /// - Parameter url: The URL of the directory to search for files.