提交数据时如何避免终端用户连续点击，不使用高阶Observable有哪些方案？

针对你仅需单次执行DB写入、不需要高阶Observable能力的场景，有3种更轻量的实现可选：

• 方案1：直接订阅单次异步Observable，无额外操作符
  如果你的DB新增方法本身已经封装为返回Observable的形式，直接订阅即可，不需要嵌套任何高阶映射操作符：

  // addRowToDb为自定义的DB新增方法，入参为行数据，返回Observable<新增行ID>
  const addTask$ = addRowToDb(targetRowData);
  addTask$.subscribe({
    next: (newRowId) => console.log('新增成功，行ID为：', newRowId),
    error: (err) => console.error('新增失败：', err)
  });
  

• 方案2：绑定触发事件时自行实现提交锁，替代exhaustMap的限流能力
  如果你需要通过按钮点击等事件触发新增，且要避免重复提交，可以手动加状态锁，不需要依赖exhaustMap的内置限流逻辑：

  let isSubmitting = false;
  // click$为按钮点击的事件流
  click$.subscribe(() => {
    if (isSubmitting) return;
    isSubmitting = true;
    addRowToDb(targetRowData).subscribe({
      next: (newRowId) => console.log('新增成功，行ID为：', newRowId),
      error: (err) => {
        console.error('新增失败：', err);
        isSubmitting = false;
      },
      complete: () => isSubmitting = false
    })
  })
  

• 方案3：完全放弃Rxjs，使用原生Promise实现
  如果你的项目中只有这一处异步逻辑，完全没必要引入Rxjs的相关依赖，用原生async/await写法更简洁：

  async function handleAddRow() {
    try {
      const newRowId = await addRowToDbPromise(targetRowData);
      console.log('新增成功，行ID为：', newRowId);
    } catch (err) {
      console.error('新增失败：', err);
    }
  }
  

注意：exhaustMap等高阶操作符的核心价值是处理「多流嵌套、需要做流切换/限流」的复杂异步场景，你当前的单次写入场景完全不需要为了使用Rxjs API而引入额外的复杂度，选择最贴合业务的写法即可。

内容的提问来源于stack exchange，提问作者Thuận Dương Minh