Flutter BLoC 事件竞争条件

Question

假设我们有一个应用程序，其中用户有一个日历，他可以在其中 select 他想要获取事件列表的日期。当用户 select 是日期时，我们添加一个事件 CalendarSelectedDateChanged(DateTime)。每次我们收到这样的事件时，Bloc 组件都会从 API 获取数据。我们可以想象一种情况，当以不同的延迟收到响应时。这将产生以下场景：

用户点击日期 1
API 使用参数 date=1 进行调用
状态设置为正在加载
用户点击日期 2
状态设置为正在加载
已收到请求 date=2 的响应
状态设置为 dataLoadSuccess(date=2)

预期结果是我们在此处丢弃请求 date=1 的响应

已收到请求 date=1 的响应
状态设置为 dataLoadSuccess(date=1)

我们如何以最优雅的方式解决这种竞争条件（最好同时针对应用程序中的所有 BLoC）？

下面是会产生此类问题的示例代码：

class ExampleBloc extends Bloc<ExampleEvent, ExampleState> {

  ExampleBloc()
      : super(ExampleDataLoadInProgress(DateTime.now())) {
    on<ExampleSelectedDateChanged>((event, emit) async {
      await _fetchData(event.date, emit);
    });
  }

  Future<void> _fetchData(DateTime selectedDate,
      Emitter<ExampleState> emit,) async {
    emit(ExampleDataLoadInProgress(selectedDateTime));
    try {
      final data = callAPI(selectedDateTime);
      emit(ExampleDataLoadSuccess(data, selectedDate));
    } on ApiException catch (e) {
      emit(ExampleDataLoadFailure(e, selectedDateTime));
    }
  }
}

Answer 1

默认情况下，所有事件都是并发处理的，您可以通过设置自定义转换器来更改该行为：

您可以在此处阅读有关变压器的更多信息：https://pub.dev/packages/bloc_concurrency

class ExampleBloc extends Bloc<ExampleEvent, ExampleState> {

  ExampleBloc()
      : super(ExampleDataLoadInProgress(DateTime.now())) {
    on<ExampleSelectedDateChanged>((event, emit) async {
      await _fetchData(event.date, emit);
    },
      transformer: restartable(), // ADD THIS LINE 
    );
  }

  Future<void> _fetchData(DateTime selectedDate,
      Emitter<ExampleState> emit,) async {
    emit(ExampleDataLoadInProgress(selectedDateTime));
    try {
      final data = callAPI(selectedDateTime);
      emit(ExampleDataLoadSuccess(data, selectedDate));
    } on ApiException catch (e) {
      emit(ExampleDataLoadFailure(e, selectedDateTime));
    }
  }
}

Flutter BLoC 事件竞争条件

Flutter BLoC event race condition

dart

flutter

bloc

flutter-bloc