Chromium Code Reviews| 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); |