RxJS for f2e