async langchain_core.utils.aiter.tee_peer(iterator: AsyncIterator[T], buffer: Deque[T], peers: List[Deque[T]], lock: AsyncContextManager[Any]) → AsyncGenerator[T, None]

tee() 的单个迭代器。

该函数是一个生成器，它会从共享迭代器 iterator 中产生项。它缓存项，直到最先进的迭代器也产生了这些项。该缓存与所有其他参与者共享。

参数

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

• buffer (Deque[T]) – 本参与者的缓存。

• peers (List[Deque[T]]) – 所有参与者的缓存。

• lock (AsyncContextManager[Any]) – 控制对共享缓存访问同步的锁。

产生

共享迭代器的下一个项。

返回类型

AsyncGenerator[T, None]