返回订阅期间从Observable发出的值的最新计数

import { Observable } from 'rxjs';
import { scan, startWith } from 'rxjs/operators';

// 创建一个Observable对象，发出一系列数字
const source$ = new Observable(observer => {
  let count = 0;
  const interval = setInterval(() => {
    observer.next(count++);
  }, 1000);

  // 在取消订阅时清除定时器
  return () => {
    clearInterval(interval);
  };
});

// 使用scan操作符计算最新计数
const count$ = source$.pipe(
  scan((acc, value) => acc + 1, 0),
  startWith(0)
);

// 订阅最新计数的变化
const subscription = count$.subscribe(count => {
  console.log('最新计数:', count);
});

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