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()