[javascript] RxJS를 사용하는 예시를 들어주세요.

21 Nov 2023

javascript

// RxJS에서 옵저버블 생성하기
const { from, interval } = rxjs;

// 배열을 옵저버블로 변환하기
const array = [1, 2, 3, 4, 5];
const arrayObservable = from(array);

// 1초마다 값을 방출하는 옵저버블 생성하기
const intervalObservable = interval(1000);

// 옵저버블 구독하기
const subscription = arrayObservable.subscribe(value => {
  console.log(value);
});

// 5번째 값을 방출한 후 구독 종료하기
subscription.add(intervalObservable.subscribe(value => {
  console.log(value);
  if (value === 4) {
    subscription.unsubscribe();
  }
}));

위의 예시는 RxJS의 from 함수를 사용하여 배열을 옵저버블로 변환하고, interval 함수를 사용하여 1초마다 값을 방출하는 옵저버블을 생성하는 방법을 보여줍니다. 그 후 subscribe 함수를 사용하여 옵저버블을 구독하고, 값을 처리하는 로직을 작성합니다.

위의 코드는 배열의 값들을 순서대로 출력하다가 5번째 값을 방출한 후에 구독을 종료합니다.

참고 문서: