You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
An AsyncIterable[T] implements __aiter__(self) -> AsyncIterator[T]
An AsyncIterator[T] implements __anext__(self) -> T
it allows async for _ in aiterable
expected TODO:
Implement first async alternatives to all operation having a potentially expensive function parameter (we already have .amap/.aforeach, we need afilter...)
Overload the constructor: __init__(self, source: AsyncIterable[T])
Implement a AsyncIteratorVisitor(Visitor[AsyncIterator[T]]) that raises if non async source or non async function is involved in the stream
The text was updated successfully, but these errors were encountered:
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: