RxJS Dynamic Interval

dynamic-interval.ts

import { Observable } from 'rxjs'

interface TimeFn {
  (): number
}

export function dynamicInterval(timeFn: () => number)) {
  return new Observable(function subscribe(subscriber) {
    let count = 0
    let id = setTimeout(handleTimeout, timeFn())

    // Probably not needed
    let go = true

    // How to do teardown logic?
    return function unsubscribe() {
      go = false
      clearTimeout(id)
    }

    function handleTimeout() {
      subscriber.next(count)
      count++

      if (go) {
        id = setTimeout(handleTimeout, timeFn())
      }
    }
  })
}

dynamicInterval(() => Math.random() * 10)

Use async scheduler instead of setTimeout.