如何从可观察性(rxjs)中获取更改的元素

import { Observable } from 'rxjs';

// 创建一个可观察对象
const observable = new Observable((observer) => {
  // 模拟数据流中的元素
  const elements = [1, 2, 3, 4, 5];

  // 模拟每隔一秒发送一个元素
  const interval = setInterval(() => {
    const element = elements.shift();
    if (element) {
      // 发送元素给订阅者
      observer.next(element);
    } else {
      // 数据流结束
      observer.complete();
      clearInterval(interval);
    }
  }, 1000);
});

// 订阅可观察对象
const subscription = observable.subscribe({
  next: (element) => {
    // 处理数据流中的元素
    console.log('Element:', element);
  },
  complete: () => {
    console.log('Data stream completed.');
  },
});

// 取消订阅
setTimeout(() => {
  subscription.unsubscribe();
}, 5000);