test_astreaming() — langchain Function Reference

Architecture documentation for the test_astreaming() function in test_chat_models.py from the langchain codebase.

Function python LangChainCore LanguageModelBase

Entity Profile

LangChainCore→ LanguageModelBase→ test_astreaming() — langchain Function Reference

Dependency Diagram

graph TD
  735c0981_36ef_872f_4261_f90a257b3694["test_astreaming()"]
  f27640dd_3870_5548_d153_f9504ae1021f["test_chat_models.py"]
  735c0981_36ef_872f_4261_f90a257b3694 -->|defined in| f27640dd_3870_5548_d153_f9504ae1021f
  style 735c0981_36ef_872f_4261_f90a257b3694 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/partners/anthropic/tests/integration_tests/test_chat_models.py lines 439–452

async def test_astreaming() -> None:
    """Test streaming tokens from Anthropic."""
    callback_handler = FakeCallbackHandler()
    callback_manager = CallbackManager([callback_handler])

    llm = ChatAnthropic(  # type: ignore[call-arg, call-arg]
        model_name=MODEL_NAME,
        streaming=True,
        callbacks=callback_manager,
    )

    response = await llm.agenerate([[HumanMessage(content="I'm Pickle Rick")]])
    assert callback_handler.llm_streams > 0
    assert isinstance(response, LLMResult)