'use strict';

function main() {
  return Rx.Observable.timer(0, 1000) //
  .map(function (i) {
    return 'Seconds elapsed ' + i;
  });
}

function DONEffect(text$) {
  text$.subscribe(function (text) {
    var container = document.querySelector('#app');
    container.textContent = text;
  });
}

function consoleLogEffect(msg$) {
  msg$.subscribe(function (msg) {
    return console.log(msg);
  });
}

var sink = main();
DONEffect(sink);
consoleLogEffect(sink);