如何在RxJS中按ID去抖动

import { fromEvent } from 'rxjs';
import { debounceTime, groupBy, mergeMap } from 'rxjs/operators';

// 模拟一系列事件流，每个事件包含ID和值
const events = [
  { id: 1, value: 'A' },
  { id: 2, value: 'B' },
  { id: 1, value: 'C' },
  { id: 3, value: 'D' },
  { id: 2, value: 'E' },
  { id: 1, value: 'F' },
];

// 将事件流转换为Observable
const eventStream$ = fromEvent(events, 'data');

// 按ID进行分组
const groupedStream$ = eventStream$.pipe(
  groupBy(event => event.id),
  mergeMap(group => group.pipe(
    // 按ID去抖动，设置去抖时间为500ms
    debounceTime(500)
  ))
);

// 订阅去抖后的事件流
groupedStream$.subscribe(event => {
  console.log(`ID: ${event.id}, Value: ${event.value}`);
});