我正在使用RxDart观察更改并相应地更新UI。应用启动时,我正在进行网络呼叫并成功获取数据,请观察更改并相应地更新UI。但是当我Subjects
在关闭屏幕的同时进行配置时。它给出以下错误:
??? EXCEPTION CAUGHT BY WIDGETS LIBRARY ????????????????????????????????????????????????????????????
I/flutter (15524): The following StateError was thrown while finalizing the widget tree:
I/flutter (15524): Bad state: You cannot close the subject while items are being added from addStream
Run Code Online (Sandbox Code Playgroud)
这是bloc类:
class MovieDetailBloc {
final _repository = Repository();
final _movieId = PublishSubject<int>();
final _trailers = BehaviorSubject<Future<TrailerModel>>();
Function(int) get fetchTrailersById => _movieId.sink.add;
Observable<Future<TrailerModel>> get movieTrailers => _trailers.stream;
MovieDetailBloc() {
_movieId.stream.transform(_itemTransformer()).pipe(_trailers);
}
dispose() {
_movieId.close();
_trailers.close();
}
_itemTransformer() {
return ScanStreamTransformer(
(Future<TrailerModel> trailer, int …
Run Code Online (Sandbox Code Playgroud)