| 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..7cad9be8904f65bd223608688671e25bb1a522a7 100644
|
| --- a/sdk/lib/_internal/pub/test/error_group_test.dart
|
| +++ b/sdk/lib/_internal/pub/test/error_group_test.dart
|
| @@ -38,7 +38,8 @@ main() {
|
|
|
| expect(() => errorGroup.registerFuture(new Future.value()),
|
| throwsStateError);
|
| - expect(() => errorGroup.registerStream(new StreamController().stream),
|
| + expect(() => errorGroup.registerStream(
|
| + new StreamController(sync: true).stream),
|
| throwsStateError);
|
| });
|
| });
|
| @@ -66,7 +67,8 @@ 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),
|
| throwsStateError);
|
| }));
|
| });
|
| @@ -205,7 +207,7 @@ main() {
|
|
|
| setUp(() {
|
| errorGroup = new ErrorGroup();
|
| - controller = new StreamController();
|
| + controller = new StreamController(sync: true);
|
| stream = errorGroup.registerStream(controller.stream.asBroadcastStream());
|
| });
|
|
|
| @@ -277,7 +279,7 @@ main() {
|
|
|
| setUp(() {
|
| errorGroup = new ErrorGroup();
|
| - controller = new StreamController();
|
| + controller = new StreamController(sync: true);
|
| stream = errorGroup.registerStream(controller.stream);
|
| });
|
|
|
| @@ -326,8 +328,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 +387,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);
|
|
|