问题描述
我有一个返回 subscribetoLiveOrders
的方法 Future<http.StreamedResponse>
。流应该是无限的(它根据后端的实时活动不断发出值)。
var subscription;
subscribetoLiveOrders()
.then((streamedResponse) => streamedResponse.stream.transform(utf8.decoder))
.then((value) => value.map((event) => mapEvent(event)))
.then((value) {
subscription = value.listen((order) => doSomeStuff(order));
print('XXX');
});
我正在尝试获取对通过调用 listen() 方法创建的订阅的引用,但由于流永远不会结束,因此永远不会调用分配(和 print('XXX'))。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)