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