Struct AiClientHandle 

pub struct AiClientHandle {
    pub queue_len: Arc<AtomicUsize>,
    /* private fields */
}

Clone-able handle onto a running (or idle) AI supervisor task.

Fields are pub(crate) so a later task’s commands.rs tests can build a handle directly from a channel + ArcSwap without going through spawn.

Fields

queue_len: Arc<AtomicUsize>

AUX‑4: shared with the supervisor loop; read by the headerline renderer.

Implementations

impl AiClientHandle

pub fn queue_len(&self) -> usize

AUX‑4: expose the live queue length for the headerline.

pub fn start(&self, provider: ProviderConfig)

Ask the supervisor to start provider. Non-blocking; the result surfaces later via AiClientHandle::snapshot and the provider’s AiLogger ring.

pub fn prompt(&self, text: String)

Ask the supervisor to send text as a prompt on the active session. Non-blocking; if no session is open the supervisor drops the prompt and logs a Warn-level “prompt dropped: no active session” record to the subsystem-wide AiLogger ring instead of sending it.

pub fn interrupt(&self)

AU‑3: interrupt the active turn without ending the session. Non-blocking; the supervisor forwards an ACP session/cancel. If no session is open it’s a no-op. Distinct from AiClientHandle::stop, which tears the session (and provider child) down.

pub fn set_auto_accept(&self, on: bool)

AU‑5: set trust mode. Non-blocking; the supervisor applies the flag and republishes AiState.

pub fn toggle_auto_accept(&self) -> bool

AU‑5: flip trust mode, returning the value it was flipped to (from the current snapshot). Non-blocking; the supervisor applies + republishes.

pub fn stop(&self)

Ask the supervisor to stop the active session. Non-blocking.

pub fn snapshot(&self) -> AiState

Read the current state snapshot. Never blocks.

impl AiClientHandle

pub fn spawn( runtime: &Handle, logger: AiLogger, conv_store: ConversationStore, diff_bus: Option<ProgrammaticDiffBus>, ) -> AiClientHandle

Spawn the supervisor task on runtime and return a handle onto it.

The supervisor owns the provider child + Connection + active SessionId for as long as the task runs (until every clone of the returned handle is dropped, which closes the command channel). All protocol I/O happens on the supervisor task, never on the caller’s thread.

Trait Implementations

impl Clone for AiClientHandle

fn clone(&self) -> AiClientHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.