RxJS는 Reactive Extensions For JavaScript 라이브러리이다.

ReactiveX 는 Observer 패턴, Iterator 패턴, 함수형 프로그래밍을 조합하여 제공한다.

동기와 비동기 처리를 하나의 스트림으로 관리하고 처리가 가능하다.

• 비동기 프로그래밍: 이 문서를 볼 정도면 설명이 필요 없을 것 같다.
• 함수형 프로그래밍: 순수함수, 고차함수, 일급 함수
• 데이터스트림: file stream, event stream, http stream 의 친구로 data 식 표현
• 이터레이터: iterator pattern(ES6)

Array, Set, Map 과 같이 리스트 데이터들은 기본적으로 Iterable이며 Iterator를 가지고 있으며, 이는 곧 Protocol을 만족한다는 의미, spread/rest 연산도 iterator문법을 따름

• 옵져버: 디자인패턴 책의 옵져버패턴 단원 참조, 자바스크립트에선 이미 이벤트리스너가 옵져버 패턴이다.
• 옵져버블: 특정 객체를 관찰하는 옵저버에게 여러 이벤트나 값을 전파하는 역할
• 풀: 데이터를 받을지 결정
• 푸쉬: 데이터를 보낼지 결정
• 싱글: 하나의 값이나 이벤트를 다룸
• 멀티플: 여러 개의 값이나 이벤트를 다룸

import { Observable } from 'rxjs';

const observable$ = new Observable(subscriber => {
  subscriber.next(1);
  subscriber.next(2);
  subscriber.next(3);
  setTimeout(() => {
    subscriber.next(4);
    subscriber.complete();
  }, 1000);
});

console.log('just before subscribe');
observable$.subscribe({
  next(x) { console.log('got value ' + x); },
  error(err) { console.error('something wrong occurred: ' + err); },
  complete() { console.log('done'); }
});
console.log('just after subscribe');

---------------------------
just before subscribe
got value 1
got value 2
got value 3
just after subscribe
got value 4
done