Struct TaskRunner 

pub struct TaskRunner { /* private fields */ }

Coalescing + late-drop spine for background tasks (issue #231).

See the module docs for the full contract. The short version: the App calls Self::request before spawning a worker, branches on the returned generation, and reports the worker’s result back via Self::complete so a superseded late result is dropped.

Implementations

impl TaskRunner

pub fn new() -> Self

Construct an empty runner — no generations claimed, nothing in flight. The App constructor calls this once.

pub fn request(&mut self, kind: TaskKind) -> Option<u64>

Claim a run of kind. Returns Some(generation) for a cold slot — the caller owns the off-thread spawn and must tag the worker’s result with that generation — or None when a run of the same kind is already in flight (coalesced; no second worker).

pub fn invalidate(&mut self, kind: TaskKind)

Drop any in-flight run of kind and bump the generation so a late result is discarded, freeing the slot for a fresh run.

pub fn invalidate_matching<F: Fn(TaskKind) -> bool>(&mut self, pred: F)

Self::invalidate every in-flight kind matching pred (issue #255). The GitHub fetch needs this because, on navigation, the App clears the per-key cache for all GitHub fetches but no longer holds the (stale) issue/PR numbers to invalidate them by key — a |k| k.is_github() predicate drops every running GitHub worker’s slot so a fresh fetch starts at a new generation and the stale worker’s late result is discarded by Self::complete. Only running kinds are touched: an idle kind has no in-flight worker to drop.

pub fn complete(&mut self, kind: TaskKind, generation: u64) -> bool

Decide whether a result tagged generation for kind is still authoritative. Returns true (apply it) only when the generation matches the current one and a run was in flight, clearing the slot; returns false for a late result whose generation was bumped by an intervening invalidate / request (the #138 guard).

pub fn is_loading(&self, kind: TaskKind) -> bool

true while a run of kind is in flight.

pub fn is_any_loading(&self) -> bool

true while any task is in flight — drives the statusbar spinner alongside the GitHub fetch’s own loading signal.

pub fn has_mutating_task_in_flight(&self) -> bool

true while a mutating worker is still in flight. Quit handling uses this to keep sync / bootstrap / delete-worktree from being abandoned mid-operation.

pub fn mutating_loading_label(&self) -> Option<&'static str>

Loader label for a mutating in-flight task, if any.

pub fn loading_label(&self) -> Option<&'static str>

The loader label for an in-flight task, if any. None when nothing is loading.

Trait Implementations

impl Debug for TaskRunner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TaskRunner

fn default() -> TaskRunner

Returns the “default value” for a type.