Index: sdk/lib/_internal/pub_generated/test/error_group_test.dart |
diff --git a/sdk/lib/_internal/pub/test/error_group_test.dart b/sdk/lib/_internal/pub_generated/test/error_group_test.dart |
similarity index 66% |
copy from sdk/lib/_internal/pub/test/error_group_test.dart |
copy to sdk/lib/_internal/pub_generated/test/error_group_test.dart |
index 331a1ffd92bebf907458735045105f4fc28fc3a4..3589b3eb5495f1a769f79b1966057a15656a66db 100644 |
--- a/sdk/lib/_internal/pub/test/error_group_test.dart |
+++ b/sdk/lib/_internal/pub_generated/test/error_group_test.dart |
@@ -31,15 +31,18 @@ main() { |
errorGroup.signalError(new FormatException()); |
}); |
- test("shouldn't allow additional futures or streams once an error has been " |
- "signaled", () { |
+ test( |
+ "shouldn't allow additional futures or streams once an error has been " |
+ "signaled", |
+ () { |
expect(errorGroup.done, throwsFormatException); |
errorGroup.signalError(new FormatException()); |
- expect(() => errorGroup.registerFuture(new Future.value()), |
+ expect( |
+ () => errorGroup.registerFuture(new Future.value()), |
throwsStateError); |
- expect(() => errorGroup.registerStream( |
- new StreamController(sync: true).stream), |
+ expect( |
+ () => errorGroup.registerStream(new StreamController(sync: true).stream), |
throwsStateError); |
}); |
}); |
@@ -60,68 +63,81 @@ main() { |
completer.complete('value'); |
}); |
- test("shouldn't allow additional futures or streams once .done has " |
- "been called", () { |
+ test( |
+ "shouldn't allow additional futures or streams once .done has " "been called", |
+ () { |
completer.complete('value'); |
- expect(completer.future |
- .then((_) => errorGroup.registerFuture(new Future.value())), |
- throwsStateError); |
- expect(completer.future |
- .then((_) => errorGroup.registerStream( |
- new StreamController(sync: true).stream)), |
- throwsStateError); |
+ expect( |
+ completer.future.then((_) => errorGroup.registerFuture(new Future.value())), |
+ throwsStateError); |
+ expect( |
+ completer.future.then( |
+ (_) => errorGroup.registerStream(new StreamController(sync: true).stream)), |
+ throwsStateError); |
}); |
- test('should pass through an exception from the future if it has a ' |
- 'listener', () { |
+ test( |
+ 'should pass through an exception from the future if it has a ' 'listener', |
+ () { |
expect(future, throwsFormatException); |
// errorGroup shouldn't top-level the exception |
completer.completeError(new FormatException()); |
}); |
- test('should notify the error group of an exception from the future even ' |
- 'if it has a listener', () { |
+ test( |
+ 'should notify the error group of an exception from the future even ' |
+ 'if it has a listener', |
+ () { |
expect(future, throwsFormatException); |
expect(errorGroup.done, throwsFormatException); |
completer.completeError(new FormatException()); |
}); |
- test('should pass a signaled exception to the future if it has a listener ' |
- 'and should ignore a subsequent value from that future', () { |
+ test( |
+ 'should pass a signaled exception to the future if it has a listener ' |
+ 'and should ignore a subsequent value from that future', |
+ () { |
expect(future, throwsFormatException); |
// errorGroup shouldn't top-level the exception |
errorGroup.signalError(new FormatException()); |
completer.complete('value'); |
}); |
- test('should pass a signaled exception to the future if it has a listener ' |
- 'and should ignore a subsequent exception from that future', () { |
+ test( |
+ 'should pass a signaled exception to the future if it has a listener ' |
+ 'and should ignore a subsequent exception from that future', |
+ () { |
expect(future, throwsFormatException); |
// errorGroup shouldn't top-level the exception |
errorGroup.signalError(new FormatException()); |
completer.completeError(new ArgumentError()); |
}); |
- test('should notify the error group of a signaled exception even if the ' |
- 'future has a listener', () { |
+ test( |
+ 'should notify the error group of a signaled exception even if the ' |
+ 'future has a listener', |
+ () { |
expect(future, throwsFormatException); |
expect(errorGroup.done, throwsFormatException); |
errorGroup.signalError(new FormatException()); |
}); |
- test("should complete .done if the future receives a value even if the " |
- "future doesn't have a listener", () { |
+ test( |
+ "should complete .done if the future receives a value even if the " |
+ "future doesn't have a listener", |
+ () { |
expect(errorGroup.done, completes); |
completer.complete('value'); |
// A listener added afterwards should receive the value |
- expect(errorGroup.done.then((_) => future), |
- completion(equals('value'))); |
+ expect(errorGroup.done.then((_) => future), completion(equals('value'))); |
}); |
- test("should pipe an exception from the future to .done if the future " |
- "doesn't have a listener", () { |
+ test( |
+ "should pipe an exception from the future to .done if the future " |
+ "doesn't have a listener", |
+ () { |
expect(errorGroup.done, throwsFormatException); |
completer.completeError(new FormatException()); |
@@ -131,8 +147,9 @@ main() { |
}), completes); |
}); |
- test("should pass a signaled exception to .done if the future doesn't have " |
- "a listener", |
+ test( |
+ "should pass a signaled exception to .done if the future doesn't have " |
+ "a listener", |
() { |
expect(errorGroup.done, throwsFormatException); |
errorGroup.signalError(new FormatException()); |
@@ -159,8 +176,9 @@ main() { |
future2 = errorGroup.registerFuture(completer2.future); |
}); |
- test("should pipe exceptions from one future to the other and to " |
- ".complete", () { |
+ test( |
+ "should pipe exceptions from one future to the other and to " ".complete", |
+ () { |
expect(future1, throwsFormatException); |
expect(future2, throwsFormatException); |
expect(errorGroup.done, throwsFormatException); |
@@ -168,8 +186,9 @@ main() { |
completer1.completeError(new FormatException()); |
}); |
- test("each future should be able to complete with a value " |
- "independently", () { |
+ test( |
+ "each future should be able to complete with a value " "independently", |
+ () { |
expect(future1, completion(equals('value1'))); |
expect(future2, completion(equals('value2'))); |
expect(errorGroup.done, completes); |
@@ -178,8 +197,10 @@ main() { |
completer2.complete('value2'); |
}); |
- test("shouldn't throw a top-level exception if a future receives an error " |
- "after the other listened future completes", () { |
+ test( |
+ "shouldn't throw a top-level exception if a future receives an error " |
+ "after the other listened future completes", |
+ () { |
expect(future1, completion(equals('value'))); |
completer1.complete('value'); |
@@ -189,8 +210,10 @@ main() { |
}), completes); |
}); |
- test("shouldn't throw a top-level exception if an error is signaled after " |
- "one listened future completes", () { |
+ test( |
+ "shouldn't throw a top-level exception if an error is signaled after " |
+ "one listened future completes", |
+ () { |
expect(future1, completion(equals('value'))); |
completer1.complete('value'); |
@@ -224,25 +247,33 @@ main() { |
}); |
expect(errorGroup.done, completes); |
- controller..add(1)..add(2)..close(); |
+ controller |
+ ..add(1) |
+ ..add(2) |
+ ..close(); |
}); |
- test('should pass through an error from the stream if it has a ' |
- 'listener', () { |
+ test( |
+ 'should pass through an error from the stream if it has a ' 'listener', |
+ () { |
expect(stream.first, throwsFormatException); |
// errorGroup shouldn't top-level the exception |
controller.addError(new FormatException()); |
}); |
- test('should notify the error group of an exception from the stream even ' |
- 'if it has a listener', () { |
+ test( |
+ 'should notify the error group of an exception from the stream even ' |
+ 'if it has a listener', |
+ () { |
expect(stream.first, throwsFormatException); |
expect(errorGroup.done, throwsFormatException); |
controller.addError(new FormatException()); |
}); |
- test('should pass a signaled exception to the stream if it has a listener ' |
- 'and should unsubscribe that stream', () { |
+ test( |
+ 'should pass a signaled exception to the stream if it has a listener ' |
+ 'and should unsubscribe that stream', |
+ () { |
// errorGroup shouldn't top-level the exception |
expect(stream.first, throwsFormatException); |
errorGroup.signalError(new FormatException()); |
@@ -252,22 +283,27 @@ main() { |
}), completes); |
}); |
- test('should notify the error group of a signaled exception even if the ' |
- 'stream has a listener', () { |
+ test( |
+ 'should notify the error group of a signaled exception even if the ' |
+ 'stream has a listener', |
+ () { |
expect(stream.first, throwsFormatException); |
expect(errorGroup.done, throwsFormatException); |
errorGroup.signalError(new FormatException()); |
}); |
- test("should see one value and 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(); |
// 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()), |
+ expect( |
+ errorGroup.done.then((_) => stream.toList()), |
completion(equals(['value']))); |
}); |
@@ -283,19 +319,24 @@ main() { |
stream = errorGroup.registerStream(controller.stream); |
}); |
- test("should complete .done when the stream is done even if the stream " |
- "doesn't have a listener", () { |
+ test( |
+ "should 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 receive the value |
- expect(errorGroup.done.then((_) => stream.toList()), |
+ expect( |
+ errorGroup.done.then((_) => stream.toList()), |
completion(equals(['value']))); |
}); |
- test("should pipe an exception from the stream to .done if the stream " |
- "doesn't have a listener", () { |
+ 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()); |
@@ -306,8 +347,9 @@ main() { |
}), completes); |
}); |
- test("should pass a signaled exception to .done if the stream doesn't " |
- "have a listener", |
+ test( |
+ "should pass a signaled exception to .done if the stream doesn't " |
+ "have a listener", |
() { |
expect(errorGroup.done, throwsFormatException); |
errorGroup.signalError(new FormatException()); |
@@ -334,7 +376,8 @@ main() { |
stream2 = errorGroup.registerStream(controller2.stream); |
}); |
- test("should pipe exceptions from one stream to the other and to .done", |
+ test( |
+ "should pipe exceptions from one stream to the other and to .done", |
() { |
expect(stream1.first, throwsFormatException); |
expect(stream2.first, throwsFormatException); |
@@ -348,16 +391,28 @@ main() { |
expect(stream2.toList(), completion(equals(['value2.1', 'value2.2']))); |
expect(errorGroup.done, completes); |
- controller1..add('value1.1')..add('value1.2')..close(); |
- controller2..add('value2.1')..add('value2.2')..close(); |
+ controller1 |
+ ..add('value1.1') |
+ ..add('value1.2') |
+ ..close(); |
+ controller2 |
+ ..add('value2.1') |
+ ..add('value2.2') |
+ ..close(); |
}); |
- test("shouldn't throw a top-level exception if a stream receives an error " |
- "after the other listened stream completes", () { |
+ test( |
+ "shouldn't throw a top-level exception if a stream receives an error " |
+ "after the other listened stream completes", |
+ () { |
var signal = new Completer(); |
- expect(stream1.toList().whenComplete(signal.complete), |
- completion(equals(['value1', 'value2']))); |
- controller1..add('value1')..add('value2')..close(); |
+ expect( |
+ stream1.toList().whenComplete(signal.complete), |
+ completion(equals(['value1', 'value2']))); |
+ controller1 |
+ ..add('value1') |
+ ..add('value2') |
+ ..close(); |
expect(signal.future.then((_) { |
// shouldn't cause a top-level exception |
@@ -365,12 +420,18 @@ main() { |
}), completes); |
}); |
- test("shouldn't throw a top-level exception if an error is signaled after " |
- "one listened stream completes", () { |
+ test( |
+ "shouldn't throw a top-level exception if an error is signaled after " |
+ "one listened stream completes", |
+ () { |
var signal = new Completer(); |
- expect(stream1.toList().whenComplete(signal.complete), |
- completion(equals(['value1', 'value2']))); |
- controller1..add('value1')..add('value2')..close(); |
+ expect( |
+ stream1.toList().whenComplete(signal.complete), |
+ completion(equals(['value1', 'value2']))); |
+ controller1 |
+ ..add('value1') |
+ ..add('value2') |
+ ..close(); |
expect(signal.future.then((_) { |
// shouldn't cause a top-level exception |
@@ -409,18 +470,25 @@ main() { |
completer.completeError(new FormatException()); |
}); |
- test("the stream and the future should be able to complete/emit values " |
- "independently", () { |
+ test( |
+ "the stream and the future should be able to complete/emit values " |
+ "independently", |
+ () { |
expect(stream.toList(), completion(equals(['value1.1', 'value1.2']))); |
expect(future, completion(equals('value2.0'))); |
expect(errorGroup.done, completes); |
- controller..add('value1.1')..add('value1.2')..close(); |
+ controller |
+ ..add('value1.1') |
+ ..add('value1.2') |
+ ..close(); |
completer.complete('value2.0'); |
}); |
- test("shouldn't throw a top-level exception if the stream receives an error " |
- "after the listened future completes", () { |
+ test( |
+ "shouldn't throw a top-level exception if the stream receives an error " |
+ "after the listened future completes", |
+ () { |
expect(future, completion(equals('value'))); |
completer.complete('value'); |
@@ -430,12 +498,18 @@ main() { |
}), completes); |
}); |
- test("shouldn't throw a top-level exception if the future receives an " |
- "error after the listened stream completes", () { |
+ test( |
+ "shouldn't throw a top-level exception if the future receives an " |
+ "error after the listened stream completes", |
+ () { |
var signal = new Completer(); |
- expect(stream.toList().whenComplete(signal.complete), |
- completion(equals(['value1', 'value2']))); |
- controller..add('value1')..add('value2')..close(); |
+ expect( |
+ stream.toList().whenComplete(signal.complete), |
+ completion(equals(['value1', 'value2']))); |
+ controller |
+ ..add('value1') |
+ ..add('value2') |
+ ..close(); |
expect(signal.future.then((_) { |
// shouldn't cause a top-level exception |