Method flush_internal

src/crates/services/services-core/src/filesystem/tree.rs:291–304

(&self, force: bool)

    }

    fn flush_internal(&self, force: bool) {
        let should_flush = force || self.elapsed_since_last_flush() >= self.flush_interval;
        if !should_flush {
            return;
        }

        let batch = self.drain_batch();
        if batch.is_empty() {
            return;
        }

        (self.on_flush)(batch);
        self.mark_flushed();
    }
}

impl FileSearchProgressSink for BatchedFileSearchProgressSink {