1.4.5 Rx 스트림의 컴포넌트

RxJS 스트림은 몇 가지 기본 컴포넌트로 이루어졌으며 각 컴포넌트는 전체 스트림과 관련된 특정 작업과 수명이 있습니다. 앞의 예제에서 이를 언급했는데, 지금부터 본격적으로 살펴보겠습니다.

• 생산자

• 소비자

• 데이터 파이프라인

• 시간

 

생산자

생산자(Producer)는 데이터의 소스입니다. 스트림에는 항상 데이터 생산자가 있어야 하며, RxJS에서 수행할 모든 로직의 시작점이 됩니다. 실제로 생산자는 독립적으로 이벤트를 생성하는 무언가(단일 값, 배열, 마우스 클릭, 파일로부터 읽어온 바이트 스트림에 이르기까지)에서 생성됩니다. 이러한 생산자를 옵저버 패턴에서는 서브젝트(Subject)라고 정의하고, RxJS에는 관찰될 수 있는 무언가라는 의미로 옵저버블(Observable)이라 부릅니다

옵저버블은 알림을 푸시하는 역할만 해서 이 동작을 실행 후 잊기(fire-and-forget)라 부릅니다. 즉, 생산자는 이벤트 방출에만 관여하고 이벤트 처리에는 관여하지 않습니다.