RxJs simple example with array

by jim28791

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.1.0/rx.all.js"></script>

Babel + JSX

// An array
var numbers = [1,2,3,4,5,6]

// A stream
var numbers$ = Rx.Observable
  .interval(500)
  .take(6)
  .map(i => numbers[i]);
  
var result$ = numbers$
  .reduce((total,cuurentValue) => total*cuurentValue, 1);
  
numbers$.subscribe(n => console.log('產生',n));
// => 1
// => 2
// => 3... etc
result$.subscribe(n => console.log('最終',n));
// =. 15