如何利用Dart的异步能力处理回调间取值等待及防抖延迟触发问题

核心原因 #

该执行顺序问题由防抖逻辑的延后特性和回调触发时序冲突导致：onUpdate的防抖回调会被延后500ms执行，而onComplete会在数据源停止推送事件后立刻触发，因此会出现onComplete执行完成后，最后一次防抖的onUpdate才执行的情况。

方案1：使用EasyDebounce内置方法强制执行待处理任务（最便捷） #

EasyDebounce提供了flush方法，可以直接跳过等待时间，立刻执行指定标记的待执行防抖任务，直接在onComplete回调中调用即可：

onComplete: () {
  // 立刻执行tag为sigController/onUpdate的待执行防抖任务
  EasyDebounce.flush('sigController/onUpdate');
  // 执行完成后清理对应防抖任务，避免后续冗余执行
  EasyDebounce.cancel('sigController/onUpdate');
  // 此处即可直接使用state中已更新的最终details数据做后续处理
  yourFollowUpLogic();
}

方案2：自定义带完成感知的防抖逻辑（无第三方依赖） #

如果不想依赖EasyDebounce的能力，可以自己基于Dart原生Timer实现适配该场景的防抖逻辑：

// 控制器/类内定义全局变量
Timer? _updateDebounceTimer;
Details? _lastReceivedDetails;
bool _isSignalCompleted = false;

onUpdate: (details) {
  _lastReceivedDetails = details;
  _updateDebounceTimer?.cancel();
  // 如果已经收到完成信号，跳过防抖直接执行更新
  if (_isSignalCompleted) {
    _handleDetailsUpdate(details);
    return;
  }
  _updateDebounceTimer = Timer(const Duration(milliseconds: 500), () {
    _handleDetailsUpdate(details);
  });
},

onComplete: () {
  _isSignalCompleted = true;
  // 存在待执行的防抖任务时，立刻执行更新
  if (_updateDebounceTimer?.isActive ?? false) {
    _updateDebounceTimer?.cancel();
    if (_lastReceivedDetails != null) {
      _handleDetailsUpdate(_lastReceivedDetails!);
    }
  }
  // 后续业务逻辑
  yourFollowUpLogic();
}

// 抽离公共的详情更新逻辑
void _handleDetailsUpdate(Details details) {
  state.setDetails(details);
}

方案3：结合Completer做异步协调（适合后续逻辑强依赖最终数据的场景） #

如果onComplete后的逻辑必须等待最终details数据就绪才能执行，可以用Dart的Completer做异步封装，保证执行顺序符合预期：

// 控制器/类内定义全局变量
Timer? _updateDebounceTimer;
Details? _lastReceivedDetails;
Completer<Details>? _finalDetailsCompleter;

onUpdate: (details) {
  _lastReceivedDetails = details;
  _updateDebounceTimer?.cancel();
  // 已完成信号触发后直接更新数据
  if (_finalDetailsCompleter?.isCompleted ?? false) {
    state.setDetails(details);
    return;
  }
  _updateDebounceTimer = Timer(const Duration(milliseconds: 500), () {
    state.setDetails(details);
  });
},

onComplete: () async {
  _finalDetailsCompleter = Completer<Details>();
  // 强制完成最后一次更新
  _updateDebounceTimer?.cancel();
  if (_lastReceivedDetails != null) {
    state.setDetails(_lastReceivedDetails!);
    _finalDetailsCompleter!.complete(_lastReceivedDetails!);
  } else {
    // 处理未收到任何数据就触发完成的边界异常
    _finalDetailsCompleter!.completeError(StateError('No details data received'));
  }

  // await等待最终数据就绪后再执行后续逻辑
  try {
    final finalDetails = await _finalDetailsCompleter!.future;
    // 依赖最终数据的业务逻辑
    processFinalData(finalDetails);
  } catch (e) {
    // 异常处理逻辑
    handleError(e);
  }
}

注意事项 #

• 所有方案都需要在控制器/页面销毁时，主动取消Timer或者EasyDebounce的对应任务，避免内存泄漏
• 如果存在onComplete触发后依然可能收到onUpdate回调的极端场景，可以保留_isSignalCompleted标记位，后续收到的更新直接跳过防抖执行

内容的提问来源于stack exchange，提问作者user1354934