ebonnal/streamable

Expressive iteration in Python: fluent, typed, lazy, and concurrent

streamable's Issues

`.limit`: add a `predicate: Callable[[T], bool]` parameter to stop the iteration based on an arbitrary condition

I can't get it to print anything or logger.info anything

Make `Stream[T]` implement `AsyncIterable[T]` too

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

`.group`: optimize when `by` is `None`

let's yield Iterators instead of Lists

Measure the impact of `PyPy` on performances

`.throttle`: do not base the logic on a "min period" and add `seconds_interval`

README: create a complete yet short ETL Stream example

Maybe based on an open API like PokéAPI