Struct SessionState 

struct SessionState {
    thread_id: Option<String>,
    turn_id: Option<String>,
    phase: SessionPhase,
    items: HashMap<String, ItemSnapshot>,
    raw_unknown_events: VecDeque<Value>,
    last_terminated_turn_id: Option<String>,
    turn_starting: bool,
    pending_requests: HashMap<RpcId, PendingServerRequest>,
}

Fields

thread_id: Option<String>

turn_id: Option<String>

phase: SessionPhase

items: HashMap<String, ItemSnapshot>

raw_unknown_events: VecDeque<Value>

last_terminated_turn_id: Option<String>

The most recently turn/completed-notified turn id. start_turn checks this after its own turn/start response resolves — the response and the completion notification arrive on independent channels (the request/response oneshot vs. run_reader’s notification stream), so a turn/completed for the SAME turn can be applied before start_turn’s continuation resumes. Without this check, start_turn’s unconditional post-await write would resurrect an already-terminal turn as Running, permanently stuck (muxreview P1, PR #3210). One id is enough, not a growing set: only one turn is ever active at a time, so at most one termination can be “pending recognition” by a not-yet-resumed start_turn call.

turn_starting: bool

Reserved atomically under the same lock as the turn_id.is_some() check, before the turn/start request is even sent. Without this, two concurrent start_turn calls both observe turn_id == None and both release the lock before either gets a response/notification back — nothing was reserved under the lock, so both send turn/start (ReAgent P1, PR #3210). Cleared once the response (or an error) resolves.

pending_requests: HashMap<RpcId, PendingServerRequest>

Trait Implementations

impl Default for SessionState

fn default() -> SessionState

Returns the “default value” for a type.