RxJS取消重叠事件和延迟

import { fromEvent } from 'rxjs';
import { switchMap, delay } from 'rxjs/operators';

const button = document.getElementById('button');

// 创建一个点击事件的Observable
const click$ = fromEvent(button, 'click');

// 使用switchMap取消重叠事件，并延迟500ms处理事件
const subscription = click$.pipe(
  switchMap(() => {
    // 在这里处理点击事件
    return doSomethingAsync();
  }),
  delay(500)
).subscribe(() => {
  // 在这里处理延迟后的事件
  console.log('事件处理完成');
});

// 取消订阅
subscription.unsubscribe();