init() — langchain Function Reference

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

Function python Observability TelemetryUtilities calls 1

Entity Profile

Observability→ TelemetryUtilities→ __init__() — langchain Function Reference

Dependency Diagram

graph TD
  376b8592_9f6f_c370_0840_ed0919838785["__init__()"]
  4f5b77f2_09bd_e403_0ad5_cd7cd96465d1["Tee"]
  376b8592_9f6f_c370_0840_ed0919838785 -->|defined in| 4f5b77f2_09bd_e403_0ad5_cd7cd96465d1
  6d309a46_222b_d7a4_4826_8e1dface311e["tee_peer()"]
  376b8592_9f6f_c370_0840_ed0919838785 -->|calls| 6d309a46_222b_d7a4_4826_8e1dface311e
  style 376b8592_9f6f_c370_0840_ed0919838785 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/utils/iter.py lines 129–154

    def __init__(
        self,
        iterable: Iterator[T],
        n: int = 2,
        *,
        lock: AbstractContextManager[Any] | None = None,
    ):
        """Create a `tee`.

        Args:
            iterable: The iterable to split.
            n: The number of iterators to create.
            lock: The lock to synchronise access to the shared buffers.

        """
        self._iterator = iter(iterable)
        self._buffers: list[deque[T]] = [deque() for _ in range(n)]
        self._children = tuple(
            tee_peer(
                iterator=self._iterator,
                buffer=buffer,
                peers=self._buffers,
                lock=lock if lock is not None else NoLock(),
            )
            for buffer in self._buffers
        )