tee_peer

langchain_core.utils.iter.tee_peer(iterator: Iterator[T], buffer: deque[T], peers: list[deque[T]], lock: AbstractContextManager[Any]) → Generator[T, None, None]

一个tee()的单独迭代器。

此函数是一个生成器，它从共享迭代器iterator中生成项目。它会缓冲项目，直到最不先进的迭代器也生成了它们。缓冲区与所有其他对等方共享。

Parameters:

• iterator (Iterator[T]) – 共享的迭代器。

• buffer (deque[T]) – 此对等方的缓冲区。

• peers (list[deque[T]]) – 所有对等节点的缓冲区。

• lock (AbstractContextManager[Any]) – 用于同步访问共享缓冲区的锁。

Yields:

共享迭代器中的下一个项目。

Return type:

Generator[T, None, None]