NetanelBasal
11/15/2016 - 9:52 AM

obs6.js

mergeMap(anotherFunctionThatThrowsValues) {
    return new Observable(observer => {
      return this.subscribe({
        next(val) {    
          anotherFunctionThatThrowsValues(val).subscribe({
            next(val) { observer.next(val) },
            error(e) { observer.error(e) } ,
            complete() { observer.complete() } 
          });
        },
        error(e) { observer.error(e) } ,
        complete() { observer.complete() } 
      });
    });
}