const source$ = Rx.Observable.create(observer => {
observer.next('4111111111111111');
observer.next('5105105105105100');
observer.next('4342561111111118');
observer.next('6500000000000002');
observer.complete(); -- 옵저버블이 유한하다면 옵저버의 complete() 메서드 호출해서 완료를 알릴 수 있습니다.
}); -- 이 시점에서 옵저버블은 유휴 상태이며 어떠한 데이터도 옵저버로 방출되거나 전달되지 않습니다.
 
const subscription = source$.subscribe(console.log); -- subscribe()를 사용하면 옵저버 로직이 실행되는데, 이 경우에는 콘솔에 출력됩니다.

이 스트림의 마블 다이어그램은 그림 2-15와 같습니다. 이 예제 코드는 일련의 계좌 번호를 출력하므로 간단해 보이지만, 이보다 훨씬 더 많은 것을 할 수 있습니다. 애플리케이션의 어느 위치에서나 재사용할 수 있는 사용자 정의 동작으로 직접 옵저버블을 만들 수 있습니다.

▲ 그림 2-15 complete( ) 호출로 끝나는 일련의 동기 이벤트를 보여주는 마블 다이어그램