Flattening and Transforming Observable Arrays with RxJs