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(); |