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 b880a2d4832b0200279b5f0eace3c33585bdabfe..8b6780a2530bb6d6025a42ea7a3689c0b7fcce13 100644 |
--- a/pkg/scheduled_test/lib/src/utils.dart |
+++ b/pkg/scheduled_test/lib/src/utils.dart |
@@ -52,10 +52,10 @@ Stream futureStream(Future<Stream> future) { |
future.then((stream) { |
stream.listen( |
controller.add, |
- onError: (error) => controller.signalError(error), |
+ onError: (error) => controller.addError(error), |
onDone: controller.close); |
}).catchError((e) { |
- controller.signalError(e); |
+ controller.addError(e); |
controller.close(); |
}); |
return controller.stream; |