多个反应式过滤器和更新的问题奇怪的行为

// 使用RxJS的pipe操作符来确保过滤器的正确顺序
import { of } from 'rxjs';
import { filter, map } from 'rxjs/operators';

const source$ = of(1, 2, 3, 4, 5);

source$.pipe(
  filter(value => value % 2 === 0), // 过滤偶数
  map(value => value * 2) // 将过滤后的值乘以2
).subscribe(console.log); // 输出: 4, 8

// 使用debounceTime来减少更新频率
import { fromEvent } from 'rxjs';
import { debounceTime, map } from 'rxjs/operators';

const input = document.querySelector('input');
const input$ = fromEvent(input, 'input');

input$.pipe(
  debounceTime(300), // 延迟300毫秒执行
  map(event => event.target.value) // 获取输入值
).subscribe(console.log); // 输出: 用户停止输入后的值