init() — langchain Function Reference

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

Function python Observability Tracers

Entity Profile

Observability→ Tracers→ __init__() — langchain Function Reference

Dependency Diagram

graph TD
  c6142728_bc4b_30fe_d689_8bc25b858e2c["__init__()"]
  37a7aa96_375d_950b_9f76_b361f654e1f7["_MemoryStream"]
  c6142728_bc4b_30fe_d689_8bc25b858e2c -->|defined in| 37a7aa96_375d_950b_9f76_b361f654e1f7
  style c6142728_bc4b_30fe_d689_8bc25b858e2c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/tracers/memory_stream.py lines 119–130

    def __init__(self, loop: AbstractEventLoop) -> None:
        """Create a channel for the given loop.

        Args:
            loop: The event loop to use for the channel.

                The reader is assumed to be running in the same loop as the one passed
                to this constructor. This will NOT be validated at run time.
        """
        self._loop = loop
        self._queue: asyncio.Queue = asyncio.Queue(maxsize=0)
        self._done = object()