langchain_core.utils.iter.tee_peer

langchain_core.utils.iter.tee_peer(iterator: Iterator[T], buffer: Deque[T], peers: List[Deque[T]], lock: ContextManager[Any]) → Generator[T, None, None]

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

此函数是一个生成器，它从共享的迭代器iterator生成项目。它在最先进的迭代器也生成项目之前，将项目缓冲。缓冲区与所有其他对等方共享。

参数

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

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

• peers (List[Deque[T]]) – 所有对等方的缓冲区。

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

生成

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

返回类型

Generator[T, None, None]