Basic Observable Implementation From Scratch

observableTimeout.js

class Observable {
    constructor(subscribe){
        this._subscribe = subscribe;
    }

    subscribe(observer){
        return this._subscribe(observer);
    }

    static timeout(time){
        return new Observable(function subscribe(observer){
            const handle = setInterval(function(){
              //observable calling the next method on the observer
                observer.next()
                observer.complete();
            }, time)

            return {
                unsubscribe(){
                    clearInterval(handle)
                }
            }
        })
    }

}

const obs = Observable.timeout(500)

console.log(obs)

const subscription = obs.subscribe(
  //observer object
    {
      next(v){
          console.log('next')
      }, 
      complete(){
          console.log('complete')
      }
  }
)

setTimeout(() =>{subscription.unsubscribe()}, 5000)