BFE.devAI解答 - JavaScript 代码题
74. 实现 Observable Transformation Operators

题目分析：

本题需要实现 Observable 的一个 operator map()，将 Observable 原始事件流中的值进行转换，生成新的事件流，类似于 Array 的 map() 方法。

根据样例和题目描述，我们需要实现一个接受一个函数参数的高阶函数 map()，这个函数会返回一个新的函数，接受一个 Observable 对象，并返回一个新的 Observable 对象。对新的 Observable 对象订阅，会对原始的 Observable 对象订阅并在上游数据流过来时，对数据进行转换，再推送给下游。

解题步骤：

1. 实现一个高阶函数 map()，接受一个函数参数 project，用于将原始事件流中的数据进行转换。
2. 在 map() 中返回一个函数，接受一个 Observable 对象 observable，并返回一个新的 Observable 对象 newObservable。
3. 在 newObservable 内部订阅 observable，并监听事件 next，在每一个上游推送下来的数据上执行 project 函数进行数据转换，再通过 newObservable 的观察者接口将处理后的数据流进行推送。

参考代码如下：

function map(project) {
  // 返回一个高阶函数，接受一个 Observable 对象项，并返回一个 Observable 对象
  return function(observable) {
    return {
      subscribe(observer) {
        // 订阅原始的 Observable 对象
        const subscription = observable.subscribe({
          next(val) {
            try {
              // 对上游的数据进行转换
              observer.next(project(val));
            } catch (e) {
              observer.error(e);
            }
          },
          error(err) {
            observer.error(err);
          },
          complete() {
            observer.complete();
          }
        });
        // 返回订阅器，用于取消订阅
        return {
          unsubscribe() {
            subscription.unsubscribe();
          }
        }
      }
    }
  };
}

代码中使用了闭包的方式，将 project 函数保存在 map() 内部，作为 next 事件中的转换函数使用。

然后返回一个接受 Observable 对象的函数，内部订阅上游数据流并通过 observer 接口推送下游，最终返回订阅器用于取消订阅。

最后在 Observable 上调用 pipe() 方法，传入 map() 函数即可：

const source = Observable.from([1,2,3]);
source.pipe(map(x => x * x)).subscribe(console.log);
// 1
// 4
// 9