/*

  when all observables complete, give the last

  emitted value from each as an array

*/

const example = Rx.Observable.forkJoin(

  //emit 'Hello' immediately

  Rx.Observable.of('Hello'),

  //emit 'World' after 1 second

  Rx.Observable.of('World').delay(1000),

  // throw error

  Rx.Observable

    .throw('This will error')

​

)

.catch(error => Rx.Observable.of(error))

//output: 'This will Error'

const subscribe = example.subscribe(val => console.log(val));