Using transducers with RxJS