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] [source]ΒΆ
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]