Skip to main content

run_loop_stream_with_context

tirea_agent_loop::runtime::loop_runner

Function run_loop_stream_with_context 

Source 
pub fn run_loop_stream_with_context(
    agent: Arc<dyn Agent>,
    tools: HashMap<String, Arc<dyn Tool>>,
    run_ctx: RunContext,
    execution_ctx: RunExecutionContext,
    cancellation_token: Option<RunCancellationToken>,
    state_committer: Option<Arc<dyn StateCommitter>>,
    decision_rx: Option<UnboundedReceiver<ToolCallDecision>>,
) -> Pin<Box<dyn Stream<Item = AgentEvent> + Send>>