BFE.devでのAI解答例 - JavaScript コーディング問題
70. Observable.from()を作る

function from(input) {  return new Observable(observer => {    if (Array.isArray(input) || typeof input[Symbol.iterator] === 'function') {      for (const item of input) {        observer.next(item);      }      observer.complete();      return;    }        if (typeof input.then === 'function') {      input.then(        result => {          observer.next(result);          observer.complete();        },        error => observer.error(error)      );      return;    }        if (typeof input[Symbol.observable] === 'function') {      const source$ = input[Symbol.observable]();      source$.subscribe({        next: value => observer.next(value),        error: error => observer.error(error),        complete: () => observer.complete()      });      return;    }        throw new TypeError('Unsupported observable');  });}

解説:

• from関数は、与えられた引数が配列、iterable、Promise、Observable-likeのどれかであるかどうかを判別し、それぞれに対応するObservableを生成する
• 引数が配列またはiterableである場合、for...ofループを使用してすべての要素を順番に配信し、最後にcompleteイベントを発行する
• 引数がPromiseである場合、thenメソッドを呼び出して解決された値を配信し、またはエラーが発生した場合はエラーを送信する
• 引数がObservable-likeである場合、Symbol.observableメソッドを呼び出して実際のObservableを取得し、そのObservableをフラットに購読する
• どの条件にも当てはまらない場合、エラーをスローしてサポートされていない型であることを示す