Struct StreamedTurn 

pub struct StreamedTurn {
    pub message_id: Option<String>,
    pub choice: Vec<AssistantContent>,
    pub executable_tool_names: BTreeSet<String>,
    pub allowed_tool_names: BTreeSet<String>,
    pub internal_call_ids: Vec<(String, String)>,
    pub finish_reason: Option<FinishReason>,
}

Available on crate feature agent only.

The assembled streamed turn, fed to AgentRun::streamed_turn.

Fields

message_id: Option<String>

Provider-assigned assistant message ID, when available.

choice: Vec<AssistantContent>

The assistant content to record in history: canonical (reasoning → text → tool calls) when the turn produced reasoning or tool calls, otherwise the provider’s aggregated choice as-is.

executable_tool_names: BTreeSet<String>

Executable Rig tools advertised to the provider for this turn.

allowed_tool_names: BTreeSet<String>

Tools allowed by the active tool choice for this turn.

internal_call_ids: Vec<(String, String)>

(tool_call_id, internal_call_id) pairs for this turn’s tool calls, in emission order. Carried into the run state so a resumed process keeps the IDs consumers already saw in tool-call deltas.

finish_reason: Option<FinishReason>

Why the provider stopped generating this turn, when it reported a reason — the streamed analogue of ModelTurn::finish_reason, so a driver that feeds turns through streamed_turn records the same terminal reason the blocking surface does (rig#2322).

Trait Implementations

impl Clone for StreamedTurn

fn clone(&self) -> StreamedTurn

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamedTurn

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamedTurn

fn deserialize<__D>( __deserializer: __D, ) -> Result<StreamedTurn, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamedTurn

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.