[RxJS - 2] Observable의 파라미터

import { interval, take } from 'rxjs';

const interval$ = interval(1000); // 관례적으로 Observable 객체는 $를 접미로 붙인다.

interval$.subscribe(val => console.log("Observable", val));

/*
Observable 1
Observable 2
Observable 3
Observable 4
...
*/

 

 

이전 글의 위와 같은 상황에서, subscribe의 3가지 파라미터를 알아보자.

interval$.subscribe(val => 

    console.log("Observable", val),
    err => console.log(err)
    () => console.log("finished!")
    
);

 

첫 번째는 실제 수행되어질 로직,

두 번째는 에러 핸들링,

세 번째는 첫 번째 코드가 성공적으로 실행되고 난 후에 실행된다. 즉, 에러가 났을 시에는 실행되지 않는다. 에러 시에는 더 이상 event가 emit되지 않고 stream이 종료된다.