cycle-circular.js

import { Observable, Subject } from 'rx'
const { timer, fromEvent } = Observable

/* --- logic --- */
const main = DOM =>
  DOM.startWith(null)
    .flatMapLatest(
      () => timer(0, 100).map(
        i => `seconds elapsed ${i}`))

/* --- effects --- */
const DOM = text$ => {
  text$.subscribe(text =>
    document.querySelector('#app').textContent = text)
  return fromEvent(document, 'click')
}

/* --- binding --- */
const run = (main, driver) => {
  const proxy = new Subject()
  driver(main(proxy))
    .subscribe(proxy::proxy.onNext)
}

/* --- run --- */
run(main, DOM)