_astream() — langchain Function Reference

Architecture documentation for the _astream() function in azure.py from the langchain codebase.

Function python LangChainCore LanguageModelBase

Entity Profile

LangChainCore→ LanguageModelBase→ _astream() — langchain Function Reference

Dependency Diagram

graph TD
  1c7bcc9c_dbf9_c448_17ef_0c22ccedf3b7["_astream()"]
  4b940a4c_8618_3ca0_9fa5_c378f5b8f6ac["AzureChatOpenAI"]
  1c7bcc9c_dbf9_c448_17ef_0c22ccedf3b7 -->|defined in| 4b940a4c_8618_3ca0_9fa5_c378f5b8f6ac
  style 1c7bcc9c_dbf9_c448_17ef_0c22ccedf3b7 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/partners/openai/langchain_openai/chat_models/azure.py lines 822–831

    async def _astream(
        self, *args: Any, **kwargs: Any
    ) -> AsyncIterator[ChatGenerationChunk]:
        """Route to Chat Completions or Responses API."""
        if self._use_responses_api({**kwargs, **self.model_kwargs}):
            async for chunk in super()._astream_responses(*args, **kwargs):
                yield chunk
        else:
            async for chunk in super()._astream(*args, **kwargs):
                yield chunk