langchain_core.utils.aiter.tee_peer

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

An individual iterator of a tee()

Parameters

• iterator (AsyncIterator[T]) –

• buffer (Deque[T]) –

• peers (List[Deque[T]]) –

• lock (AsyncContextManager[Any]) –

Return type

AsyncGenerator[T, None]