Struct Scheduler 

pub struct Scheduler { /* private fields */ }

The live (pre-analysis) text of every open document, with a generation counter per document.

The generation guard is the cancellation model: every edit bumps the generation, and an analysis pass only installs+publishes its result if the generation it captured is still current when it finishes. Stale results are dropped on the floor — no locks held, nothing blocks.

Implementations

impl Scheduler

pub fn new() -> Self

pub fn open(&self, uri: Url, text: String, version: i32) -> u64

Register a newly opened document. Returns its starting generation.

pub fn apply_changes( &self, uri: &Url, changes: Vec<TextDocumentContentChangeEvent>, version: i32, ) -> Option<u64>

Apply LSP content changes in order and bump the generation. Returns the new generation, or None for an unopened document.

pub fn current_if(&self, uri: &Url, generation: u64) -> Option<(String, i32)>

Snapshot the current text/version if generation is still current.

pub fn current_text(&self, uri: &Url) -> Option<(String, i32)>

The live text and version of an open document, regardless of generation — what a save should check.

pub fn is_current(&self, uri: &Url, generation: u64) -> bool

pub fn open_uris(&self) -> Vec<Url>

Every open document, for whole-server sweeps (config changes).

pub fn close(&self, uri: &Url)