Experimental port of the Interactive operators from Reactive4Java to be used with RxJava