New implementation of Rx .NET based on RxJava Lift