Welcome to JS Bin

JS Bin

Save
Blog
Help
Load cached copy from
  • Run with JS
  • Save
  • Share
  • …
 
<!DOCTYPE html>
<html>
<head>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.6/rx.all.js"></script>
  <meta charset="utf-8">
  <meta name="viewport" content="width=device-width">
  <title>JS Bin</title>
</head>
<body>
 <button id="btn-stop">Stop</button>
<div id="out"></div>
</body>
</html>
 
var btn = document.getElementById('btn-stop');
​
var mouseClick = Rx.Observable.fromEvent(btn, 'click');
​
var source = Rx.Observable.create(observer => {
  var timer = 0;
  setInterval(() => {
    observer.onNext(++timer);
  }, 1000)
});
​
var sub = source
  .subscribe(x => {
    console.log(x);
  });
​
var domSub = source
  .throttle(5000)
  .map(x => {
    return 'The timer ticking... ' + x;  
  })
  .takeUntil(mouseClick)
  .forEach(x => {
 document.getElementById('out').innerHTML = x;
});
Output

You can jump to the latest bin by adding /latest to your URL

Dismiss x