SmoothieAq

distinct_until_changed, not so nice signature?

1

It has signature def distinct_until_changed( source: AsyncObservable[_TSource], ) -> AsyncObservable[_TSource] but I would have expected def distinct_until_changed() -> Callable[[AsyncObservable[_TSource]], AsyncObservable[_TSource]] Seems like a lot of signatures here and there could...

AsyncRx.distinct_until_changed, wrong signature

2

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