dart 从Stream获取当前值

nuypyhwy  于 2023-10-13  发布在  其他
关注(0)|答案(2)|浏览(104)

有一个StreamBuilder(使用RxDart)显示一些日期。点击InkWell小部件后,我需要在旧的基础上计算一个新的日期。下面的代码只是简单地解释了算法,但是当我运行它时,什么也没有发生,执行在下划线行之后停止,即。我从未看到lastCalcDate的值。
GUI:

child: StreamBuilder(
  stream: bloc.getDate,
  builder: (context,snapshot) {
    return InkWell(
      onTap: () => tapHandler
    );
}),

void tapHandler() async {
  var lastCalcDate = await bloc.getDate.single;
  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  print(lastCalcDate);
  var newCalcDate = lastCalcDate.add(Duration(days:1));
  bloc.setDate(newCalcDate)
}

BLoC:

class Bloc {
  // BehaviourSubject is usedto be sure that last sent date will be accessible in `tapHandler`.
  final _dateSubject = BehaviourSubject<DateTime>(); 
  Observable<DateTime> get getDate => _dateSubject.stream;
  Function(DateTime) get setDate => _dateSubject.add;
}

为了实现我需要的东西,我创建了一些变通方法,但我不喜欢它,因为我认为我可以使用可观的东西做同样的事情。
BLoC(变通方法):

class Bloc {
  final _dateSubject = BehaviourSubject<DateTime>(); 
  Observable<DateTime> get getDate => _dateSubject.stream;
  DateTime _date;
  void setDateWorkaround(DateTime date) {
    _date = date;
    _dateSubject.add(date);
  }
}

你能不能找个人给我给予。我做错了什么?

rm5edbpk

rm5edbpk1#

single将不工作,因为它将返回流中的下一个项目,但是,必须首先添加。这意味着single将等待下一个项目,在您的情况下,它不会发生。
因为你已经在使用rxdartBehaviorSubject了,你可以很容易地像这样访问当前元素:

class Bloc {
  final _dateSubject = BehaviourSubject<DateTime>(); 
  Observable<DateTime> get getDate => _dateSubject.stream;
  Function(DateTime) get setDate => _dateSubject.add;

  DateTime get currentDate => _dateSubject.value;
}

在本例中,我使用了BehaviorSubject.value,这实际上是该类的全部意义。
现在,你可以在tap处理程序中使用currentDate

void tapHandler() async {
  var lastCalcDate = bloc.currentDate;
  print(lastCalcDate);
  var newCalcDate = lastCalcDate.add(Duration(days:1));
  bloc.setDate(newCalcDate)
}
yuvru6vn

yuvru6vn2#

provider使用StreamProvider
监听一个Stream并公开最新发出的值。

相关问题