search

dbrattli / aioreactive

Async/await reactive tools for Python 3.11+
MIT License
350 stars 24 forks source link

AsyncRx.distinct_until_changed, wrong signature #47

Open SmoothieAq opened 4 months ago

SmoothieAq commented 4 months ago

In AsyncRx

the signature def distinct_until_changed(self) -> AsyncObservable[_TSource]: should be def distinct_until_changed(self) -> AsyncRx[_TSource]:

The actual return is correct, only the signature is wrong

SmoothieAq commented 4 months ago

some of the other functions in AsyncRx has the same problem, kind of makes it hard to use AsyncRx for nice and fluent notation :-|

SmoothieAq commented 4 months ago

Would also be very nice if AsyncRx had a pipe() like for example Seq