Struct SearchRegistry 

pub struct SearchRegistry {
    tokens: HashMap<String, CancellationToken>,
}

In-memory registry of in-flight prefix searches.

Each search is identified by a request_id string. Registering a search creates a CancellationToken; cancelling it sets the token’s flag. The background task polls is_cancelled() between pages and emits a final empty page before exiting.

OCP: the registry is mode-agnostic — future long-running commands can reuse the same pattern by holding their own token kind.

Fields

tokens: HashMap<String, CancellationToken>

Implementations

impl SearchRegistry

pub fn register(&mut self, request_id: impl Into<String>) -> CancellationToken

Register a new search and return a CancellationToken to pass to the background task.

If a search with the same request_id already exists, it is overwritten (the old token is dropped, freeing any lingering Arc).

pub fn cancel(&mut self, request_id: &str) -> bool

Cancel the search identified by request_id.

Returns true when the token was found and cancelled; false when no matching search exists (already completed or never started).

pub fn is_cancelled(&self, request_id: &str) -> bool

Returns true when the search has been cancelled (or never started).

pub fn remove(&mut self, request_id: &str)

Remove a completed (or cancelled) search from the registry.

Call this after the background task emits its final page to free the token from the HashMap. Idempotent — safe to call on missing ids.

Trait Implementations

impl Default for SearchRegistry

fn default() -> SearchRegistry

Returns the “default value” for a type.