Index: utils/tests/pub/error_group_test.dart |
diff --git a/utils/tests/pub/error_group_test.dart b/utils/tests/pub/error_group_test.dart |
index de46d1e283646dfd481cf3154488c18fbc20368d..13f24153c91faf905d8e3d0e5e8b48a7bc3ba7c6 100644 |
--- a/utils/tests/pub/error_group_test.dart |
+++ b/utils/tests/pub/error_group_test.dart |
@@ -248,43 +248,18 @@ main() { |
errorGroup.signalError(new FormatException()); |
}); |
- test("should complete .done when the stream is done even if the stream " |
- "doesn't have a listener", () { |
+ test("should see one value and complete .done when the stream is done even " |
+ "if the stream doesn't have a listener", () { |
expect(errorGroup.done, completes); |
controller.add('value'); |
controller.close(); |
- // A listener added afterwards should see an empty stream, since it's not |
- // single-subscription |
+ // Now that broadcast controllers have been removed a listener should |
+ // see the value that has been put into the controller. |
expect(errorGroup.done.then((_) => stream.toList()), |
- completion(isEmpty)); |
- }); |
- |
- test("should pipe an exception from the stream to .done if the stream " |
- "doesn't have a listener", () { |
- expect(errorGroup.done, throwsFormatException); |
- controller.addError(new FormatException()); |
- |
- // A listener added afterwards should see an empty stream, since it's not |
- // single-subscription |
- expect(errorGroup.done.catchError((_) { |
- controller.add('value'); // should be ignored |
- return stream.toList(); |
- }), completion(isEmpty)); |
+ completion(equals(['value']))); |
}); |
- test("should pass a signaled exception to .done if the stream doesn't " |
- "have a listener", |
- () { |
- expect(errorGroup.done, throwsFormatException); |
- errorGroup.signalError(new FormatException()); |
- |
- // A listener added afterwards should receive the exception |
- expect(errorGroup.done.catchError((_) { |
- controller.add('value'); // should be ignored |
- return stream.toList(); |
- }), completion(isEmpty)); |
- }); |
}); |
group('with a single single-subscription stream', () { |