Demystifying RxJS, Part I: of()

03-demystifying-rxjs-of.ts

function of<T>(...values: T[]): Observable<T> {
  return new Observable(obs => {
    for (const value of values) {
      obs.next(value);
    }
    obs.complete();
  });
}

// Logs:
// of 1
// of 2
// of 3
of(1, 2, 3).subscribe(x => console.log("of", x));