| Index: tests/lib/async/stream_controller_async_test.dart
|
| diff --git a/tests/lib/async/stream_controller_async_test.dart b/tests/lib/async/stream_controller_async_test.dart
|
| index dca28e1709e88e9fa8c9792211e56315ed928391..edc31f9659d1265186dcaf48d8b9cdf12ea59724 100644
|
| --- a/tests/lib/async/stream_controller_async_test.dart
|
| +++ b/tests/lib/async/stream_controller_async_test.dart
|
| @@ -29,7 +29,7 @@ testController() {
|
| StreamController c = new StreamController.broadcast();
|
| Stream stream = c.stream;
|
| stream.fold(0, (a,b) { throw "Fnyf!"; })
|
| - .catchError(expectAsync1((e) { Expect.equals("Fnyf!", e.error); }));
|
| + .catchError(expectAsync1((error) { Expect.equals("Fnyf!", error); }));
|
| c.add(42);
|
| });
|
| }
|
| @@ -49,7 +49,7 @@ testSingleController() {
|
| StreamController c = new StreamController();
|
| Stream stream = c.stream;
|
| stream.fold(0, (a,b) { throw "Fnyf!"; })
|
| - .catchError(expectAsync1((e) { Expect.equals("Fnyf!", e.error); }));
|
| + .catchError(expectAsync1((e) { Expect.equals("Fnyf!", e); }));
|
| c.add(42);
|
| });
|
|
|
| @@ -177,8 +177,8 @@ testExtraMethods() {
|
|
|
| test("singleWhere 2", () {
|
| StreamController c = new StreamController();
|
| - Future f = c.stream.singleWhere((x) => (x % 3) == 0); // Matches both 9 and 87..
|
| - f.catchError(expectAsync1((e) { Expect.isTrue(e.error is StateError); }));
|
| + Future f = c.stream.singleWhere((x) => (x % 3) == 0); // Matches 9 and 87..
|
| + f.catchError(expectAsync1((error) { Expect.isTrue(error is StateError); }));
|
| sentEvents.replay(c);
|
| });
|
|
|
| @@ -192,7 +192,7 @@ testExtraMethods() {
|
| test("first empty", () {
|
| StreamController c = new StreamController();
|
| Future f = c.stream.first;
|
| - f.catchError(expectAsync1((e) { Expect.isTrue(e.error is StateError); }));
|
| + f.catchError(expectAsync1((error) { Expect.isTrue(error is StateError); }));
|
| Events emptyEvents = new Events()..close();
|
| emptyEvents.replay(c);
|
| });
|
| @@ -200,7 +200,7 @@ testExtraMethods() {
|
| test("first error", () {
|
| StreamController c = new StreamController();
|
| Future f = c.stream.first;
|
| - f.catchError(expectAsync1((e) { Expect.equals("error", e.error); }));
|
| + f.catchError(expectAsync1((error) { Expect.equals("error", error); }));
|
| Events errorEvents = new Events()..error("error")..close();
|
| errorEvents.replay(c);
|
| });
|
| @@ -208,7 +208,7 @@ testExtraMethods() {
|
| test("first error 2", () {
|
| StreamController c = new StreamController();
|
| Future f = c.stream.first;
|
| - f.catchError(expectAsync1((e) { Expect.equals("error", e.error); }));
|
| + f.catchError(expectAsync1((error) { Expect.equals("error", error); }));
|
| Events errorEvents = new Events()..error("error")..error("error2")..close();
|
| errorEvents.replay(c);
|
| });
|
| @@ -223,7 +223,7 @@ testExtraMethods() {
|
| test("last empty", () {
|
| StreamController c = new StreamController();
|
| Future f = c.stream.last;
|
| - f.catchError(expectAsync1((e) { Expect.isTrue(e.error is StateError); }));
|
| + f.catchError(expectAsync1((error) { Expect.isTrue(error is StateError); }));
|
| Events emptyEvents = new Events()..close();
|
| emptyEvents.replay(c);
|
| });
|
| @@ -231,7 +231,7 @@ testExtraMethods() {
|
| test("last error", () {
|
| StreamController c = new StreamController();
|
| Future f = c.stream.last;
|
| - f.catchError(expectAsync1((e) { Expect.equals("error", e.error); }));
|
| + f.catchError(expectAsync1((error) { Expect.equals("error", error); }));
|
| Events errorEvents = new Events()..error("error")..close();
|
| errorEvents.replay(c);
|
| });
|
| @@ -239,7 +239,7 @@ testExtraMethods() {
|
| test("last error 2", () {
|
| StreamController c = new StreamController();
|
| Future f = c.stream.last;
|
| - f.catchError(expectAsync1((e) { Expect.equals("error", e.error); }));
|
| + f.catchError(expectAsync1((error) { Expect.equals("error", error); }));
|
| Events errorEvents = new Events()..error("error")..error("error2")..close();
|
| errorEvents.replay(c);
|
| });
|
| @@ -254,7 +254,7 @@ testExtraMethods() {
|
| test("elementAt 2", () {
|
| StreamController c = new StreamController();
|
| Future f = c.stream.elementAt(20);
|
| - f.catchError(expectAsync1((e) { Expect.isTrue(e.error is StateError); }));
|
| + f.catchError(expectAsync1((error) { Expect.isTrue(error is StateError); }));
|
| sentEvents.replay(c);
|
| });
|
| }
|
| @@ -369,15 +369,18 @@ testPause() {
|
| });
|
| }
|
|
|
| +class TestError { const TestError(); }
|
| +
|
| testRethrow() {
|
| - AsyncError error = new AsyncError("UNIQUE", "UNIQUE");
|
| + TestError error = const TestError();
|
| +
|
|
|
| testStream(name, streamValueTransform) {
|
| test("rethrow-$name-value", () {
|
| StreamController c = new StreamController();
|
| Stream s = streamValueTransform(c.stream, (v) { throw error; });
|
| s.listen((_) { Expect.fail("unexpected value"); }, onError: expectAsync1(
|
| - (AsyncError e) { Expect.identical(error, e); }));
|
| + (e) { Expect.identical(error, e); }));
|
| c.add(null);
|
| c.close();
|
| });
|
| @@ -388,7 +391,7 @@ testRethrow() {
|
| StreamController c = new StreamController();
|
| Stream s = streamErrorTransform(c.stream, (e) { throw error; });
|
| s.listen((_) { Expect.fail("unexpected value"); }, onError: expectAsync1(
|
| - (AsyncError e) { Expect.identical(error, e); }));
|
| + (e) { Expect.identical(error, e); }));
|
| c.addError(null);
|
| c.close();
|
| });
|
|
|