有一个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);
}
}
你能不能找个人给我给予。我做错了什么?
2条答案
按热度按时间rm5edbpk1#
single
将不工作,因为它将返回流中的下一个项目,但是,必须首先添加。这意味着single
将等待下一个项目,在您的情况下,它不会发生。因为你已经在使用
rxdart
和BehaviorSubject
了,你可以很容易地像这样访问当前元素:在本例中,我使用了
BehaviorSubject.value
,这实际上是该类的全部意义。现在,你可以在tap处理程序中使用
currentDate
:yuvru6vn2#
从provider使用
StreamProvider
监听一个Stream并公开最新发出的值。