Index: sdk/lib/_internal/pub/test/error_group_test.dart |
diff --git a/sdk/lib/_internal/pub/test/error_group_test.dart b/sdk/lib/_internal/pub/test/error_group_test.dart |
index d22f12cf63ee7421178f2a6893610bdea7d8db79..cedb338491fe6429ac26211ec68b1a079b39240f 100644 |
--- a/sdk/lib/_internal/pub/test/error_group_test.dart |
+++ b/sdk/lib/_internal/pub/test/error_group_test.dart |
@@ -38,7 +38,7 @@ main() { |
expect(() => errorGroup.registerFuture(new Future.value()), |
throwsStateError); |
- expect(() => errorGroup.registerStream(new StreamController().stream), |
+ expect(() => errorGroup.registerStream(new StreamController(sync: true).stream), |
floitsch
2013/05/30 12:13:48
long line.
Lasse Reichstein Nielsen
2013/05/31 05:51:59
Done.
|
throwsStateError); |
}); |
}); |
@@ -66,7 +66,7 @@ main() { |
completer.future.then(expectAsync1((_) { |
expect(() => errorGroup.registerFuture(new Future.value()), |
throwsStateError); |
- expect(() => errorGroup.registerStream(new StreamController().stream), |
+ expect(() => errorGroup.registerStream(new StreamController(sync: true).stream), |
floitsch
2013/05/30 12:13:48
ditto.
Lasse Reichstein Nielsen
2013/05/31 05:51:59
Done.
|
throwsStateError); |
})); |
}); |
@@ -205,7 +205,7 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller = new StreamController(); |
+ controller = new StreamController(sync: true); |
stream = errorGroup.registerStream(controller.stream.asBroadcastStream()); |
}); |
@@ -277,7 +277,7 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller = new StreamController(); |
+ controller = new StreamController(sync: true); |
stream = errorGroup.registerStream(controller.stream); |
}); |
@@ -326,8 +326,8 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller1 = new StreamController(); |
- controller2 = new StreamController(); |
+ controller1 = new StreamController(sync: true); |
+ controller2 = new StreamController(sync: true); |
stream1 = errorGroup.registerStream(controller1.stream.asBroadcastStream()); |
stream2 = errorGroup.registerStream(controller2.stream.asBroadcastStream()); |
}); |
@@ -385,7 +385,7 @@ main() { |
setUp(() { |
errorGroup = new ErrorGroup(); |
- controller = new StreamController(); |
+ controller = new StreamController(sync: true); |
stream = errorGroup.registerStream(controller.stream.asBroadcastStream()); |
completer = new Completer(); |
future = errorGroup.registerFuture(completer.future); |