Method process_stream

crates/opencode-agent/src/executor.rs:309–348

(
        &mut self,
        mut stream: opencode_provider::StreamResult,
    )

    }

    async fn process_stream(
        &mut self,
        mut stream: opencode_provider::StreamResult,
    ) -> Result<(String, Vec<ToolCall>), AgentError> {
        let mut content = String::new();
        let mut tool_calls: Vec<ToolCall> = Vec::new();

        while let Some(event) = stream.next().await {
            match event {
                Ok(StreamEvent::TextDelta(text)) => {
                    content.push_str(&text);
                }
                Ok(StreamEvent::ToolCallStart { id, name }) => {
                    tool_calls.push(ToolCall {
                        id,
                        name,
                        arguments: serde_json::Value::Null,
                    });
                }
                Ok(StreamEvent::ToolCallDelta { id, input }) => {
                    if let Some(tc) = tool_calls.iter_mut().find(|t| t.id == id) {
                        if tc.arguments.is_null() {
                            tc.arguments =
                                serde_json::from_str(&input).unwrap_or(serde_json::Value::Null);
                        }
                    }
                }
                Ok(StreamEvent::Done) => break,
                Ok(StreamEvent::Error(e)) => {
                    return Err(AgentError::ProviderError(e));
                }
                Err(e) => {
                    return Err(AgentError::ProviderError(e.to_string()));
                }
                _ => {}
            }
        }

        Ok((content, tool_calls))
    }

    async fn execute_tool(&self, tool_call: &ToolCall) -> Result<String, ToolError> {
        if self.disabled_tools.contains(&tool_call.name) {