Method execute_streaming

crates/opencode-agent/src/executor.rs:266–284

(
        &mut self,
        user_message: String,
    )

    }

    pub async fn execute_streaming(
        &mut self,
        user_message: String,
    ) -> Result<BoxStream<'static, Result<StreamEvent, AgentError>>, AgentError> {
        self.conversation.add_user_message(user_message);

        let provider = self.get_provider()?;
        let model_id = self.get_model_id(&provider);
        let request = ChatRequest::new(model_id, self.conversation.to_provider_messages());

        let stream = provider
            .chat_stream(request)
            .await
            .map_err(|e| AgentError::ProviderError(e.to_string()))?;

        Ok(stream
            .map(|r| r.map_err(|e| AgentError::ProviderError(e.to_string())))
            .boxed())
    }

    fn get_provider(&self) -> Result<Arc<dyn Provider>, AgentError> {
        if let Some(ref model_ref) = self.agent.model {