zhenyanghua · April 21, 2016 19:03
diff --git a/app.js b/app.js
 const Observable = Rx.Observable;

 const toggleButton = document.querySelector('#toggle');

 const toggleClick$ = Observable.fromEvent(toggleButton, 'click');
 const interval$ = Observable.interval(1000);

 const toggle$ = toggleClick$
  .startWith(false)
  .scan((acc, curr)=> !acc); //toggles true/false
  
 toggle$
  //project the true/false each interval "tick"
  .combineLatest(interval$, bool => bool)
  //only push when true
  .filter(bool=> bool)
  .startWith(0)
  .scan(acc => acc + 1)
  .subscribe(console.log.bind(console));
  






diff --git a/index.html b/index.html
 <!DOCTYPE html>
 <html>
 <head>
  <meta charset="utf-8">
  <meta name="viewport" content="width=device-width">
  <script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>

  <title>JS Bin</title>
 </head>
 <body>

  <button id="toggle">Toggle</button>

  
    <script src="./app.js"></script>
 </body>
 </html>
diff --git a/styles.css b/styles.css
 /* todo: add styles */
	const Observable = Rx.Observable;

	const toggleButton = document.querySelector('#toggle');

	const toggleClick$ = Observable.fromEvent(toggleButton, 'click');
	const interval$ = Observable.interval(1000);

	const toggle$ = toggleClick$
	.startWith(false)
	.scan((acc, curr)=> !acc); //toggles true/false

	toggle$
	//project the true/false each interval "tick"
	.combineLatest(interval$, bool => bool)
	//only push when true
	.filter(bool=> bool)
	.startWith(0)
	.scan(acc => acc + 1)
	.subscribe(console.log.bind(console));
	<!DOCTYPE html>
	<html>
	<head>
	<meta charset="utf-8">
	<meta name="viewport" content="width=device-width">
	<script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>

	<title>JS Bin</title>
	</head>
	<body>

	<button id="toggle">Toggle</button>


	<script src="./app.js"></script>
	</body>
	</html>