redditwarp.iterators.call_chunk_chaining_async_iterator#

class redditwarp.iterators.call_chunk_chaining_async_iterator.CallChunkChainingAsyncIterator(chunks: Iterable[Callable[[], Awaitable[Sequence[T]]]])[source]#

Bases: Generic[T]

Evaluate call chunks and chain them together.

property current_callable: Callable[[], Awaitable[Sequence[T]]] | None#
property current_iterator: Iterator[T]#
get_chunking_iterator() → Iterator[Callable[[], Awaitable[Sequence[T]]]][source]#