use `concatMap()` + `.toObservable()`

# rx

[zak.taccardi]

use concatMap() + .toObservable()