Struct TaskFeed 

pub(crate) struct TaskFeed {
    pending: HashMap<String, Pending>,
    owners: HashMap<String, String>,
}

Per-stream state: one per stdout reader. Holds only shell tasks that have started and not yet ended, plus the owners of subagent Bash calls whose task_started hasn’t arrived yet, so it stays small.

Fields

pending: HashMap<String, Pending>

owners: HashMap<String, String>

Implementations

impl TaskFeed

pub(crate) fn apply( &mut self, store: &Store, broker: Option<&Broker>, block_id: &str, line: &Value, now_ms: i64, ) -> bool

Apply one parsed stdout line. Returns true when the registry changed, in which case background-task-updated has been published.

fn settle_vanished( &mut self, store: &Store, block_id: &str, still_live: Option<&[String]>, ) -> bool

End every task that left the snapshot and got no end event since: the CLI stopped tracking it without saying so (a subagent’s task, dropped when the CLI started a new session segment, per the 2026-09-30 retro). With still_live, a vanished task listed again is kept. The row ends stopped, at the time it left the snapshot.

fn note_owner(&mut self, line: &Value)

A subagent’s own stream lines carry parent_tool_use_id = the Agent call that spawned it (also that subagent’s meta.json toolUseId). Remember it for each Bash call such a line issues; the call’s task_started, which follows in the same message, claims it.

Trait Implementations

impl Debug for TaskFeed

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

Formats the value using the given formatter.

impl Default for TaskFeed

fn default() -> TaskFeed

Returns the “default value” for a type.