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
  f2556559_1880_00e4_1e44_dd692d512f5c["__init__()"]
  c43da4ed_d8f0_59cc_df49_f7213014b828["_SendStream"]
  f2556559_1880_00e4_1e44_dd692d512f5c -->|defined in| c43da4ed_d8f0_59cc_df49_f7213014b828
  style f2556559_1880_00e4_1e44_dd692d512f5c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/tracers/memory_stream.py lines 20–36

    def __init__(
        self, reader_loop: AbstractEventLoop, queue: Queue, done: object
    ) -> None:
        """Create a writer for the queue and done object.

        Args:
            reader_loop: The event loop to use for the writer.

                This loop will be used to schedule the writes to the queue.
            queue: The queue to write to.

                This is an asyncio queue.
            done: Special sentinel object to indicate that the writer is done.
        """
        self._reader_loop = reader_loop
        self._queue = queue
        self._done = done