_aiter_sse() — langchain Function Reference

Architecture documentation for the _aiter_sse() function in chat_models.py from the langchain codebase.

Function python LangChainCore LanguageModelBase calls 1 called by 1

Entity Profile

LangChainCore→ LanguageModelBase→ _aiter_sse() — langchain Function Reference

Dependency Diagram

graph TD
  09d0f5ce_3c2f_d34c_f826_0393269f0685["_aiter_sse()"]
  cfb937d2_ce7f_5338_2b62_6452043ac78a["chat_models.py"]
  09d0f5ce_3c2f_d34c_f826_0393269f0685 -->|defined in| cfb937d2_ce7f_5338_2b62_6452043ac78a
  8db35ed5_08a5_0e78_5859_838dd98768d9["acompletion_with_retry()"]
  8db35ed5_08a5_0e78_5859_838dd98768d9 -->|calls| 09d0f5ce_3c2f_d34c_f826_0393269f0685
  7e7a3965_93cb_5f0e_d0f9_9b939f2b27cc["_araise_on_error()"]
  09d0f5ce_3c2f_d34c_f826_0393269f0685 -->|calls| 7e7a3965_93cb_5f0e_d0f9_9b939f2b27cc
  style 09d0f5ce_3c2f_d34c_f826_0393269f0685 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/partners/mistralai/langchain_mistralai/chat_models.py lines 208–217

async def _aiter_sse(
    event_source_mgr: AbstractAsyncContextManager[EventSource],
) -> AsyncIterator[dict]:
    """Iterate over the server-sent events."""
    async with event_source_mgr as event_source:
        await _araise_on_error(event_source.response)
        async for event in event_source.aiter_sse():
            if event.data == "[DONE]":
                return
            yield event.json()