Observable implementation which optimizes very well in prepack

Simple Observable impl

function Observable(subscribe) {
  this._subscribe = subscribe;
}

const of = (v) => new Observable(observer => {
  return observer.next(v);
});

Observable.prototype = {
  map(f) {
    return new Observable((observer) => {
      return this.subscribe({
        next: (v) => observer.next(f(v))
      });
    });
  },
  
  filter(f) {
    return new Observable((observer) => {
      return this.subscribe({
        next: (v) => {
          if (f(v)) {
            observer.next(v);
          }
        }
      });
    });
  },
  
  flatMap(f) {
    return new Observable((observer) => {
      return this.subscribe({
        next(v) {
          const otherObs = f(v);
          otherObs.subscribe(observer);
        }
      });
    });
  },
  
  subscribe(observer) {
    return this._subscribe(observer);
  }
};

of(Math.random()).
  flatMap((v) => of(Math.random())).
  map((v) => v * Math.random()).
  subscribe({
    next: (v) => console.log(v)
  });