BFE.devAI解答 - JavaScript 代码题
70. 实现Observable.from()

实现思路：

对于不同的数据类型，我们需要进行不同的处理：对于数组、类数组对象、Set、Map，可以通过 for...of 来获取元素并发送给观察者，对于 Promise，可以在 resolve 之后将数据发送给观察者，对于 Observable 实例，可以通过订阅原来的 Observable 来将数据发送给观察者。

实现代码如下：

const { Observable } = rxjs;

function from(data) {
  return new Observable(observer => {
    if (Array.isArray(data) || typeof data[Symbol.iterator] === 'function') {
      for (let item of data) {
        observer.next(item);
      }
      observer.complete();
    } else if (typeof data === 'string') {
      for (let i = 0; i < data.length; i++) {
        observer.next(data.charAt(i));
      }
      observer.complete();
    } else if (typeof data.then === 'function') {
      data.then(res => {
        observer.next(res);
        observer.complete();
      }, err => {
        observer.error(err);
      });
    } else if (typeof data[Symbol.observable] === 'function') {
      const sub = data[Symbol.observable]().subscribe({
        next: item => observer.next(item),
        error: err => observer.error(err),
        complete: () => observer.complete()
      });
      return () => sub.unsubscribe();
    } else {
      for (let item of Object.values(data)) {
        observer.next(item);
      }
      observer.complete();
    }
  });
}