redditwarp.iterators.stubborn_caller_async_iterator

class redditwarp.iterators.stubborn_caller_async_iterator.StubbornCallerAsyncIterator(iterable: Iterable[Callable[[], Awaitable[T]]])

Bases: AsyncIterator[T]

Call each callable in the given iterator and return its result.

If a call raises an exception it will propagate normally. Doing next(self) will re-attempt the call until it returns a result.

Has a self.current attribute to get the current callable.

current: Callable[[], Awaitable[T]] | None