tee_peer

async langchain_core.utils.aiter.tee_peer(iterator: AsyncIterator[T], buffer: deque[T], peers: list[deque[T]], lock: AbstractAsyncContextManager[Any]) → AsyncGenerator[T, None]

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

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

Parameters:

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

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

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

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

Yields:

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

Return type:

AsyncGenerator[T, None]