Make Stream[T]
implement AsyncIterable[T]
in addition to Iterable[T]
#8
Labels
feature
New feature or request, modifies library API
An
AsyncIterable[T]
implements__aiter__(self) -> AsyncIterator[T]
An
AsyncIterator[T]
implements__anext__(self) -> T
it allows
async for _ in aiterable
expected TODO:
.amap
/.aforeach
, we needafilter
...)__init__(self, source: AsyncIterable[T])
AsyncIteratorVisitor(Visitor[AsyncIterator[T]])
that raises if non async source or non async function is involved in the streamThe text was updated successfully, but these errors were encountered: