State 和 BlocListener Flutter 之间的时序问题

Question

我正在使用flutter_bloc，并且我的MapScreen 抽屉中有一个按钮，该按钮导航到AlarmsScreen 并将Event 发送到该集团，以便AlarmsScreen 接收带有所需数据的State在其 BlocListener 中构建 UI。 我注意到AlarmsScreen 并不总是根据使用State 传入侦听器的数据进行构建，经过几次尝试后，我注意到如果我按下按钮稍长一点（按钮上会出现加载栏？？）比AlarmsScreen 总是正确绘制。这意味着，正如 BLocListener 和 Bloc 中的打印结果所证实的那样，有时屏幕会在 State 流式传输之后加载，而 BlocListener 没有捕捉到它，因为它还没有初始化。为了确保我添加了一个延迟 200 毫秒的计时器来发送事件，现在它永远不会失败。 计时器只是一种解决方法，但是有没有办法在屏幕加载时读取块流式传输的最新状态？ . 一如既往，非常感谢您的时间和帮助。 这是按钮：

FlatButton.icon(
                          icon: Image.asset(
                            'assets/schedulerButton.png',
                            height: 55,
                            width: 55,
                          ),
                          label: Text(
                            'Check scheduler',
                            style: TextStyle(
                                color: Colors.white,
                                fontSize: 18,
                                fontWeight: FontWeight.w400),
                          ),
                          color: Colors.transparent,
                          onPressed: () {
                            // TODO call LoadAlarms and navigate to SchedulerScreen
                            print('pressed');
                            cache.play('tableViewOpen.mp3');
                            BlocProvider.of<SchedulerBloc>(context)
                                .add(LoadAlarms());
                            Navigator.push(
                              context,
                              MaterialPageRoute(
                                  builder: (_) => BlocProvider.value(
                                        value: BlocProvider.of<SchedulerBloc>(
                                            context),
                                        child: SchedulerScreen(
                                            widget.key, widget.user),
                                      )),
                            );
                            Timer(Duration(milliseconds: 200), () {
                              BlocProvider.of<SchedulerBloc>(context)
                                  .add(LoadAlarms());
                            });
                          },
                        ),

这是屏幕：

class _SchedulerScreenState extends State<SchedulerScreen> {
  AudioCache cache = new AudioCache();

  List<Alarm> alarms = [];
  List<SchedulerCell> cells = [];

  @override
  Widget build(BuildContext context) {
    cache.loadAll(['click.mp3', 'tableViewOpen.mp3', 'tableViewClose.mp3']);
    dynamic backButton =
        Platform.isIOS ? CupertinoIcons.back : Icons.arrow_back;
    dynamic addButton = Platform.isIOS ? CupertinoIcons.add : Icons.add;
    return BlocListener<SchedulerBloc, SchedulerState>(
      listener: (BuildContext context, SchedulerState state) {
        if (state is AlarmsLoaded) {
          setState(() {
            alarms = state.alarms;
            print('ShedulerListener : alarms are $alarms');
            cells = state.cells;
            print('ShedulerListener : cells are $cells');
          });
        }
      },
      child: Scaffold(
        appBar: AppBar(
          elevation: 0,
          backgroundColor: Colors.transparent,
          leading: IconButton(
              icon: Icon(backButton),
              color: Colors.redAccent,
              onPressed: () {
                cache.play('tableViewClose.mp3');
                Navigator.pop(context);
              }),
          title: Text(
            'Controlli tragitti',
            textAlign: TextAlign.center,
            style: TextStyle(
                color: Colors.orange,
                fontSize: 22,
                fontWeight: FontWeight.w500,
                letterSpacing: 1),
          ),
          centerTitle: true,
          actions: <Widget>[
            IconButton(
              icon: Icon(addButton),
              color: Colors.redAccent,
              onPressed: () {
                // TODO navigate to AddEditCheckScreen
                cache.play('tableViewOpen.mp3');
                Navigator.push(
                  context,
                  MaterialPageRoute<AddEditCheckScreen>(
                      builder: (_) => BlocProvider.value(
                            value: BlocProvider.of<SchedulerBloc>(context),
                            child: AddEditCheckScreen(
                                key: widget.key,
                                isEditing: false,
                                user: widget.user),
                          )),
                );
              },
            ),
            IconButton(
              icon: Icon(Icons.clear),
              color: Colors.redAccent,
              onPressed: () {
                BlocProvider.of<SchedulerBloc>(context).add(ClearAlarms());
                // TODO navigate to AddEditCheckScreen
                cache.play('tableViewOpen.mp3');
              },
            )
          ],
        ),
        body: ListView.builder(
          padding: EdgeInsets.all(20),
          itemCount: alarms.length,
          itemBuilder: (BuildContext context, int index) => Container(
            color: Colors.redAccent,
            child: cells[index],
          ),
        ),
      ),
    );
  }
}

Answer 1

尝试添加

@override
  Stream<Transition<ComplexEvent, ComplexState>> transformEvents(
    Stream<ComplexEvent> events,
    TransitionFunction<ComplexEvent, ComplexState> transitionFn,
  ) {
    return events.switchMap(transitionFn);
  }

到你的 Bloc 班。它将仅执行最新事件并丢弃任何以前的事件。您可以使用https://rxmarbles.com/ 来帮助您理解 rx 概念。