operators/map.js

  1. import { Observable } from '../Observable';
  2. import { passThroughNext } from './passThroughNext';
  4. /**
  5.  * Will map each value to a new value using the callback
  6.  * 
  7.  * @memberof operators
  8.  *
  9.  * @param {Observable} source$
  10.  * @param {Function} mapCallback
  11.  * @returns {Observable}
  12.  */
  13. export const map = function (source$, mapCallback) {
  14.   return passThroughNext(source$, function ({ next }, value) {
  15.     next(mapCallback(value));
  16.   });
  17. };
  19. Observable.map = map;
  20. Observable.prototype.map = function (mapCallback) {
  21.   return map(this, mapCallback);
  22. };