(비동기) RxJS With Typescript

RxJs는 Observer 패턴을 통해, 여러 사용자가 값을 구독하고, 감시하는 형태의 비동기 프로그래밍 코딩 스타일을 제공한다. filter, map, take, skip 등과 같은 유용한 체이닝 함수들을 제공한다.

설치

yarn add rxjs

typescript 설정

추가 설정이 필요 없다.

Observer의 생성 및 사용

(생성) pipe : 연산할 내용 기술
(사용) subscribe : pipe에서의 연산 내용을 사용한다.

//const source = from(fetch('/api/endpoint'));
//const source = fromEvent(document, 'click');
//const source = of(1, 2, 3, 4, 5);
//const source = interval(1000);
const source = from([1, 2, 3, 4, 5, 6, 7, 8, 9, 10]);

//비동기적으로 활용하기
//var o = ajax('/api/data');
var o = source.pipe(skip(5));
o.subscribe(val => console.log(val));

참고)
https://flyingsquirrel.medium.com/rxjs-rxjs-fruits-%EC%82%AC%EC%9D%B4%ED%8A%B8-%EB%AC%B8%EC%A0%9C-%ED%92%80%EC%96%B4%EB%B3%B4%EA%B8%B0-265c69be3ed7