const throwInMapObs = Rx.Observable.of(null)

  .map(() => {throw new Error('throw Error in .map');})

​

const throwObs = Rx.Observable.throw(new Error('Observable.throw'))

​

// Handle thrown error in .map

throwInMapObs.subscribe(() => {}, err => console.log('Handle `throw new Error`', err.stack))

​

try {

  // Do not handle thrown error in .map

  throwInMapObs.subscribe()

} catch (e) {

  console.log('Unhandled error in .map', e.stack)

}

​

​

​

// Handle error thrown with Observable.throw

throwObs.subscribe(() => {}, err => console.log('Handle `Observable.throw`', err.stack))

​

try {

  // Do not handle error thrown with Observable.throw

  throwObs.subscribe()

} catch (e) {

  console.log('Unhandled error from Observable.throw', e.stack)

}

​

​