AsyncRx.distinct_until_changed, wrong signature

[SmoothieAq]

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]

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]

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