send() — langchain Function Reference

Architecture documentation for the send() function in memory_stream.py from the langchain codebase.

Function python Observability Tracers calls 1

Entity Profile

Observability→ Tracers→ send() — langchain Function Reference

Dependency Diagram

graph TD
  4d496fb1_3366_9e01_6adc_a162f9885c9a["send()"]
  c43da4ed_d8f0_59cc_df49_f7213014b828["_SendStream"]
  4d496fb1_3366_9e01_6adc_a162f9885c9a -->|defined in| c43da4ed_d8f0_59cc_df49_f7213014b828
  798574fd_5f80_cfef_2608_5304808575ca["send_nowait()"]
  4d496fb1_3366_9e01_6adc_a162f9885c9a -->|calls| 798574fd_5f80_cfef_2608_5304808575ca
  style 4d496fb1_3366_9e01_6adc_a162f9885c9a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/tracers/memory_stream.py lines 38–46

    async def send(self, item: T) -> None:
        """Schedule the item to be written to the queue using the original loop.

        This is a coroutine that can be awaited.

        Args:
            item: The item to write to the queue.
        """
        return self.send_nowait(item)