[RxJS] Updating Data with Scan

2484 단어
You often need to update the data flowing through the stream with custom logic based on what you need to output. This lesson covers how to use  scan  for collecting and updating the outputs as your stream progresses.
EVerytime we click start button now it will start from 0: 
const Observable = Rx.Observable;

const startButton = document.querySelector('#start');
const stopButton = document.querySelector('#stop');

const start$ = Observable.fromEvent(startButton, 'click');
const interval$ = Observable.interval(1000);
const stop$ = Observable.fromEvent(stopButton, 'click');

const intervalThatStop$ = interval$.takeUntil(stop$);


start$.switchMapTo(intervalThatStop$)
  .subscribe( (x) => {
  console.log(x);
})

 
What we want is it should remeber the current state, so that, next time when we start again, it can use our current state: 
const Observable = Rx.Observable;

const startButton = document.querySelector('#start');
const stopButton = document.querySelector('#stop');

const start$ = Observable.fromEvent(startButton, 'click');
const interval$ = Observable.interval(1000);
const stop$ = Observable.fromEvent(stopButton, 'click');

const intervalThatStops$ = interval$
    .takeUntil(stop$);

start$
    .switchMapTo(intervalThatStops$)
    .scan( (acc) => {
        return Object.assign(acc, {count: acc.count + 1})
    }, {
       count: 0
    })
    .subscribe((x)=> console.log(x));

solr 프로필
이진 검색을 사용하여 그룹에 임의의 값이 있는지 확인합니다

좋은 웹페이지 즐겨찾기

개발자 우수 사이트 수집

개발자가 알아야 할 필수 사이트 100선 추천 우리는 당신을 위해 100개의 자주 사용하는 개발자 학습 사이트를 정리했습니다
best100-homepage