| Index: pkg/scheduled_test/lib/src/utils.dart
|
| diff --git a/pkg/scheduled_test/lib/src/utils.dart b/pkg/scheduled_test/lib/src/utils.dart
|
| index 77de0fba4f5187c9f4c47887ffb780d19a7aa7ef..d686ef99022b511ccc980c5c9ff718e63471b8d7 100644
|
| --- a/pkg/scheduled_test/lib/src/utils.dart
|
| +++ b/pkg/scheduled_test/lib/src/utils.dart
|
| @@ -133,7 +133,7 @@ Pair<Stream, StreamCanceller> streamWithCanceller(Stream stream) {
|
| var subscription = stream.listen((value) {
|
| if (!controller.isClosed) controller.add(value);
|
| }, onError: (error) {
|
| - if (!controller.isClosed) controller.signalError(error);
|
| + if (!controller.isClosed) controller.addError(error);
|
| }, onDone: controller.close);
|
| return new Pair<Stream, StreamCanceller>(controllerStream, controller.close);
|
| }
|
| @@ -149,8 +149,8 @@ Pair<Stream, Stream> tee(Stream stream) {
|
| controller1.add(value);
|
| controller2.add(value);
|
| }, onError: (error) {
|
| - controller1.signalError(error);
|
| - controller2.signalError(error);
|
| + controller1.addError(error);
|
| + controller2.addError(error);
|
| }, onDone: () {
|
| controller1.close();
|
| controller2.close();
|
|
|