RXJS Observable Transform Array To Multiple Values

Question

I'm making an Angular 2 HTTP get request and in return I get Observable<Message[]> I want to transform this observable into multiple emit. So let's say the server returned Message array with length 3. I would like to get 3 notification in my subscribe call (on for each value in the array) instead of getting one call with the array.

e.g : ['Hello','Hey','Howdy'] - > 'Hello', 'Hey','Howdy'

I found an operator that does transform the array (Observable.for), but this operator takes as an argument an array and not an Observable.

Answer 1

You can use the concatAll operator to flatten the array (mergeAll will work as well).

Observable.of(['Hello','Hey','Howdy'])
  .concatAll()
  .subscribe(console.log)

See demo: https://jsbin.com/gaxajex/3/edit?js,console

Answer 2

Try this:

Observable.from(yourRequest())
    .flatMap(msgList => Observable.from(msgList))
    .subscribe(msg => console.log(msg));

yourRequest() in this case should return array.

If yourRequest() returns Observable then:

yourRequest().flatMap(msgList => Observable.from(msgList))
    .subscribe()