我收到一个错误“类型'未来'不是我的BLOC中”StreamTransformer,List>类型的子类型“。
这是我的应用程序的结构:一个BLOC(即reports_bloc)。存储库(即存储库)。 API提供程序(即api_provider)。
详细地说,API Provider文件在线获取数据。 Repository文件准备好来自API Provider的数据(实际上,我也在使用DB,这就是我选择拥有Repository文件的原因)。 BLOC旨在从Repository获取数据并相应地将其添加到Stream和Sink。我相信问题出在BLOC中(关于添加Stream和“Sinking”数据,我可能在这里弄错了)。
代码在这里:
//reports_bloc.dart
import 'package:rxdart/rxdart.dart';
import '../resources/repository.dart';
class ReportsBloc {
final _repository = Repository();
final _allReports = PublishSubject<List<dynamic>>();
Observable<List<dynamic>> allReports;
ReportsBloc(){
allReports = _allReports.stream.transform(fetchAllReports());
}
fetchAllReports() async{
var reports = await _repository.fetchAllReports();
_allReports.sink.add(reports);
}
dispose() {
_allReports.close();
}
}
//repository.dart
import 'dart:async';
import 'api_provider.dart';
class Repository {
ApiProvider apiProvider = ApiProvider();
Future<List<dynamic>> fetchAllReports(){
var response = apiProvider.getAllReports();
return response;
}
}
//api_provider.dart
Future<List<dynamic>> getAllReports() async {
List<dynamic> reports = [];
final response = await http.get("$_root$_getAllReports");
var result = json.decode(response.body);
for(var i = 0; i < result.length; i++){
reports.add(result[i]);
print(reports[i]['type']);
}
return reports;
}
预期的结果是能够从存储库添加数据并将其接收。
我已经能够解决这个错误。简单地说,我所做的是重新定义ReportsBloc类的构造函数,如下所示:
ReportsBloc(){
fetchAllReports();
allReports = _allReports.stream;
}
但是,我不确定这是不是一个好习惯,但无论如何它解决了我的问题。