1

更新了代码

我厌倦了调试这些错误而没有结果任何人都知道错了什么？？？！？！？！

当添加的 Stream 发出正常事件时，它可以正常工作，但是在发出错误时，它由 onErorr 方法处理，并且发生了一个奇怪的错误，正如您在 StackTrace 中看到的那样。

test("Testing the Stream", () async {

 final _categoriesInfosSubject = new PublishSubject<String>();
 var errorThrown = false;

 Observable<String>  categories$ = _categoriesInfosSubject.stream;
 categories$.listen(any, onError: (err){ print("ErrorHappened"); errorThrown = true;});

 await _categoriesInfosSubject.addStream(
  Observable.error(Error()),
 );
 await Future.delayed(Duration(seconds: 2), (){});
 expect(errorThrown , true);

});

ErrorHappened
dart:async                                              _Completer.completeError
package:rxdart/src/subjects/subject.dart 101:19         Subject.addStream. 
<fn>
===== asynchronous gap ===========================
dart:async                                              _StreamImpl.listen
package:rxdart/src/streams/error.dart 25:30             ErrorStream.listen
package:rxdart/src/observables/observable.dart 1729:20  Observable.listen
package:rxdart/src/subjects/subject.dart 94:12          Subject.addStream
test\home_screen\home_bloc.dart 77:35                   main.<fn>

Instance of 'Error'
4

0 回答 0