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 7323e7f183abaf114eeece7ce2a9ccfc3e0900d2..8394032c187bfffbbbf28b2fc2eea756300b3da8 100644 |
--- a/pkg/scheduled_test/lib/src/utils.dart |
+++ b/pkg/scheduled_test/lib/src/utils.dart |
@@ -29,7 +29,7 @@ class Pair<E, F> { |
/// to [completer]. |
void chainToCompleter(Future future, Completer completer) { |
future.then((value) => completer.complete(value), |
- onError: (e) => completer.completeError(e)); |
+ onError: completer.completeError); |
} |
/// Prepends each line in [text] with [prefix]. If [firstPrefix] is passed, the |
@@ -85,7 +85,7 @@ Stream futureStream(Future<Stream> future) { |
future.then((stream) { |
stream.listen( |
controller.add, |
- onError: (error) => controller.addError(error), |
+ onError: controller.addError, |
onDone: controller.close); |
}).catchError((e) { |
controller.addError(e); |
@@ -143,8 +143,8 @@ Pair<Stream, StreamCanceller> streamWithCanceller(Stream stream) { |
var controllerStream = controller.stream; |
var subscription = stream.listen((value) { |
if (!controller.isClosed) controller.add(value); |
- }, onError: (error) { |
- if (!controller.isClosed) controller.addError(error); |
+ }, onError: (error, [StackTrace stackTrace]) { |
+ if (!controller.isClosed) controller.addError(error, stackTrace); |
}, onDone: controller.close); |
return new Pair<Stream, StreamCanceller>(controllerStream, controller.close); |
} |
@@ -159,9 +159,9 @@ Pair<Stream, Stream> tee(Stream stream) { |
stream.listen((value) { |
controller1.add(value); |
controller2.add(value); |
- }, onError: (error) { |
- controller1.addError(error); |
- controller2.addError(error); |
+ }, onError: (error, [StackTrace stackTrace]) { |
+ controller1.addError(error, stackTrace); |
+ controller2.addError(error, stackTrace); |
}, onDone: () { |
controller1.close(); |
controller2.close(); |