tests/lib/async/future_test.dart - Issue 2774783002: Re-land "Format all multitests"

Unified Diff: tests/lib/async/future_test.dart

Issue 2774783002: Re-land "Format all multitests" (Closed)

Patch Set: Created 3 years, 9 months ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View side-by-side diff with in-line comments

Index: tests/lib/async/future_test.dart

diff --git a/tests/lib/async/future_test.dart b/tests/lib/async/future_test.dart

index 2e64e729092a7915475578fe6e7019553ac3876b..5d84ff15f76ab8822f7199fe59cf0823ac746b90 100644

--- a/tests/lib/async/future_test.dart

+++ b/tests/lib/async/future_test.dart

@@ -24,25 +24,32 @@ void testSync() {

// Compare the results of the following two futures.

Future f1 = new Future.sync(func);

Future f2 = new Future.value().then((_) => func());

- f2.catchError((_){}); // I'll get the error later.

- f1.then((v1) { f2.then((v2) { Expect.equals(v1, v2); }); },

- onError: (e1) {

- f2.then((_) { Expect.fail("Expected error"); },

- onError: (e2) {

- Expect.equals(e1, e2);

- });

+ f2.catchError((_) {}); // I'll get the error later.

+ f1.then((v1) {

+ f2.then((v2) {

+ Expect.equals(v1, v2);

+ });

+ }, onError: (e1) {

+ f2.then((_) {

+ Expect.fail("Expected error");

+ }, onError: (e2) {

+ Expect.equals(e1, e2);

+ });

}

Future val = new Future.value(42);

- Future err1 = new Future.error("Error")..catchError((_){});

+ Future err1 = new Future.error("Error")..catchError((_) {});

try {

throw new List(0);

} catch (e, st) {

- Future err2 = new Future.error(e, st)..catchError((_){});

+ Future err2 = new Future.error(e, st)..catchError((_) {});

}

compare(() => 42);

compare(() => val);

- compare(() { throw "Flif"; });

+ compare(() {

+ throw "Flif";

+ });

compare(() => err1);

bool hasExecuted = false;

compare(() {

@@ -79,11 +86,12 @@ void testCompleteWithSuccessHandlerBeforeComplete() {

int after;

asyncStart();

- future.then((int v) { after = v; })

- .then((_) {

- Expect.equals(3, after);

- asyncEnd();

- });

+ future.then((int v) {

+ after = v;

+ }).then((_) {

+ Expect.equals(3, after);

+ asyncEnd();

+ });

completer.complete(3);

Expect.isNull(after);

@@ -98,11 +106,12 @@ void testCompleteWithSuccessHandlerAfterComplete() {

Expect.isNull(after);

asyncStart();

- future.then((int v) { after = v; })

- .then((_) {

- Expect.equals(3, after);

- asyncEnd();

- });

+ future.then((int v) {

+ after = v;

+ }).then((_) {

+ Expect.equals(3, after);

+ asyncEnd();

+ });

}

void testCompleteManySuccessHandlers() {

@@ -113,10 +122,16 @@ void testCompleteManySuccessHandlers() {

int after2;

var futures = [];

- futures.add(future.then((int v) { before = v; }));

+ futures.add(future.then((int v) {

+ before = v;

+ }));

completer.complete(3);

- futures.add(future.then((int v) { after1 = v; }));

- futures.add(future.then((int v) { after2 = v; }));

+ futures.add(future.then((int v) {

+ after1 = v;

+ }));

+ futures.add(future.then((int v) {

+ after2 = v;

+ }));

asyncStart();

Future.wait(futures).then((_) {

@@ -135,12 +150,12 @@ void testException() {

final ex = new Exception();

asyncStart();

- future

- .then((v) { throw "Value not expected"; })

- .catchError((error) {

- Expect.equals(error, ex);

- asyncEnd();

- }, test: (e) => e == ex);

+ future.then((v) {

+ throw "Value not expected";

+ }).catchError((error) {

+ Expect.equals(error, ex);

+ asyncEnd();

+ }, test: (e) => e == ex);

completer.completeError(ex);

}

@@ -150,7 +165,9 @@ void testExceptionHandler() {

final ex = new Exception();

var ex2;

- var done = future.catchError((error) { ex2 = error; });

+ var done = future.catchError((error) {

+ ex2 = error;

+ });

Expect.isFalse(completer.isCompleted);

completer.completeError(ex);

@@ -169,9 +186,10 @@ void testExceptionHandlerReturnsTrue() {

final ex = new Exception();

bool reached = false;

- future.catchError((e) { });

- future.catchError((e) { reached = true; }, test: (e) => false)

- .catchError((e) {});

+ future.catchError((e) {});

+ future.catchError((e) {

+ reached = true;

+ }, test: (e) => false).catchError((e) {});

Expect.isFalse(completer.isCompleted);

completer.completeError(ex);

Expect.isTrue(completer.isCompleted);

@@ -184,9 +202,9 @@ void testExceptionHandlerReturnsTrue2() {

final ex = new Exception();

bool reached = false;

- var done = future

- .catchError((e) { }, test: (e) => false)

- .catchError((e) { reached = true; });

+ var done = future.catchError((e) {}, test: (e) => false).catchError((e) {

+ reached = true;

+ });

completer.completeError(ex);

asyncStart();

@@ -203,10 +221,11 @@ void testExceptionHandlerReturnsFalse() {

bool reached = false;

- future.catchError((e) { });

+ future.catchError((e) {});

- future.catchError((e) { reached = true; }, test: (e) => false)

- .catchError((e) { });

+ future.catchError((e) {

+ reached = true;

+ }, test: (e) => false).catchError((e) {});

completer.completeError(ex);

@@ -217,16 +236,14 @@ void testFutureAsStreamCompleteAfter() {

var completer = new Completer();

bool gotValue = false;

asyncStart();

- completer.future.asStream().listen(

- (data) {

- Expect.isFalse(gotValue);

- gotValue = true;

- Expect.equals("value", data);

- },

- onDone: () {

- Expect.isTrue(gotValue);

- asyncEnd();

- });

+ completer.future.asStream().listen((data) {

+ Expect.isFalse(gotValue);

+ gotValue = true;

+ Expect.equals("value", data);

+ }, onDone: () {

+ Expect.isTrue(gotValue);

+ asyncEnd();

+ });

completer.complete("value");

}

@@ -235,50 +252,43 @@ void testFutureAsStreamCompleteBefore() {

bool gotValue = false;

asyncStart();

completer.complete("value");

- completer.future.asStream().listen(

- (data) {

- Expect.isFalse(gotValue);

- gotValue = true;

- Expect.equals("value", data);

- },

- onDone: () {

- Expect.isTrue(gotValue);

- asyncEnd();

- });

+ completer.future.asStream().listen((data) {

+ Expect.isFalse(gotValue);

+ gotValue = true;

+ Expect.equals("value", data);

+ }, onDone: () {

+ Expect.isTrue(gotValue);

+ asyncEnd();

+ });

}

void testFutureAsStreamCompleteImmediate() {

bool gotValue = false;

asyncStart();

- new Future.value("value").asStream().listen(

- (data) {

- Expect.isFalse(gotValue);

- gotValue = true;

- Expect.equals("value", data);

- },

- onDone: () {

- Expect.isTrue(gotValue);

- asyncEnd();

- });

+ new Future.value("value").asStream().listen((data) {

+ Expect.isFalse(gotValue);

+ gotValue = true;

+ Expect.equals("value", data);

+ }, onDone: () {

+ Expect.isTrue(gotValue);

+ asyncEnd();

+ });

}

void testFutureAsStreamCompleteErrorAfter() {

var completer = new Completer();

bool gotError = false;

asyncStart();

- completer.future.asStream().listen(

- (data) {

- Expect.fail("Unexpected data");

- },

- onError: (error) {

- Expect.isFalse(gotError);

- gotError = true;

- Expect.equals("error", error);

- },

- onDone: () {

- Expect.isTrue(gotError);

- asyncEnd();

- });

+ completer.future.asStream().listen((data) {

+ Expect.fail("Unexpected data");

+ }, onError: (error) {

+ Expect.isFalse(gotError);

+ gotError = true;

+ Expect.equals("error", error);

+ }, onDone: () {

+ Expect.isTrue(gotError);

+ asyncEnd();

+ });

completer.completeError("error");

}

@@ -288,17 +298,18 @@ void testFutureAsStreamWrapper() {

asyncStart();

completer.complete("value");

completer.future

- .catchError((_) { throw "not possible"; }) // Returns a future wrapper.

- .asStream().listen(

- (data) {

- Expect.isFalse(gotValue);

- gotValue = true;

- Expect.equals("value", data);

- },

- onDone: () {

- Expect.isTrue(gotValue);

- asyncEnd();

- });

+ .catchError((_) {

+ throw "not possible";

+ }) // Returns a future wrapper.

+ .asStream()

+ .listen((data) {

+ Expect.isFalse(gotValue);

+ gotValue = true;

+ Expect.equals("value", data);

+ }, onDone: () {

+ Expect.isTrue(gotValue);

+ asyncEnd();

+ });

}

void testFutureWhenCompleteValue() {

@@ -307,6 +318,7 @@ void testFutureWhenCompleteValue() {

countDown() {

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

Future future = completer.future;

Future later = future.whenComplete(countDown);

@@ -323,6 +335,7 @@ void testFutureWhenCompleteError() {

countDown() {

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

Future future = completer.future;

Future later = future.whenComplete(countDown);

@@ -339,6 +352,7 @@ void testFutureWhenCompleteValueNewError() {

countDown() {

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

Future future = completer.future;

Future later = future.whenComplete(() {

@@ -358,6 +372,7 @@ void testFutureWhenCompleteErrorNewError() {

countDown() {

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

Future future = completer.future;

Future later = future.whenComplete(() {

@@ -377,6 +392,7 @@ void testFutureWhenCompletePreValue() {

countDown() {

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

Future future = completer.future;

completer.complete(42);

@@ -390,13 +406,13 @@ void testFutureWhenCompletePreValue() {

}

void testFutureWhenValueFutureValue() {

asyncStart();

int counter = 3;

countDown(int expect) {

Expect.equals(expect, counter);

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

completer.future.whenComplete(() {

countDown(3);

@@ -421,6 +437,7 @@ void testFutureWhenValueFutureError() {

Expect.equals(expect, counter);

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

completer.future.whenComplete(() {

countDown(3);

@@ -447,6 +464,7 @@ void testFutureWhenErrorFutureValue() {

Expect.equals(expect, counter);

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

completer.future.whenComplete(() {

countDown(3);

@@ -473,6 +491,7 @@ void testFutureWhenErrorFutureError() {

Expect.equals(expect, counter);

if (--counter == 0) asyncEnd();

}

var completer = new Completer();

completer.future.whenComplete(() {

countDown(3);

@@ -691,11 +710,10 @@ void testChainedFutureValue() {

final future = completer.future;

asyncStart();

- future.then((v) => new Future.value(v * 2))

- .then((v) {

- Expect.equals(42, v);

- asyncEnd();

- });

+ future.then((v) => new Future.value(v * 2)).then((v) {

+ Expect.equals(42, v);

+ asyncEnd();

+ });

completer.complete(21);

}

@@ -704,23 +722,23 @@ void testChainedFutureValueDelay() {

final future = completer.future;

asyncStart();

- future.then((v) => new Future.delayed(const Duration(milliseconds: 10),

- () => v * 2))

- .then((v) {

- Expect.equals(42, v);

- asyncEnd();

- });

+ future

+ .then((v) =>

+ new Future.delayed(const Duration(milliseconds: 10), () => v * 2))

+ .then((v) {

+ Expect.equals(42, v);

+ asyncEnd();

+ });

completer.complete(21);

}

void testChainedFutureValue2Delay() {

asyncStart();

- new Future.delayed(const Duration(milliseconds: 10))

- .then((v) {

- Expect.isNull(v);

- asyncEnd();

- });

+ new Future.delayed(const Duration(milliseconds: 10)).then((v) {

+ Expect.isNull(v);

+ asyncEnd();

+ });

}

void testChainedFutureError() {

@@ -728,11 +746,12 @@ void testChainedFutureError() {

final future = completer.future;

asyncStart();

- future.then((v) => new Future.error("Fehler"))

- .then((v) { Expect.fail("unreachable!"); }, onError: (error) {

- Expect.equals("Fehler", error);

- asyncEnd();

- });

+ future.then((v) => new Future.error("Fehler")).then((v) {

+ Expect.fail("unreachable!");

+ }, onError: (error) {

+ Expect.equals("Fehler", error);

+ asyncEnd();

+ });

completer.complete(21);

}

@@ -740,13 +759,13 @@ void testSyncFuture_i13368() {

asyncStart();

final future = new Future<int>.sync(() {

- return new Future<int>.value(42);

- });

+ return new Future<int>.value(42);

+ });

future.then((int val) {

- Expect.equals(val, 42);

- asyncEnd();

- });

+ Expect.equals(val, 42);

+ asyncEnd();

+ });

}

void testWaitCleanUp() {

@@ -762,8 +781,7 @@ void testWaitCleanUp() {

int permuteTmp = permute;

for (int i = 0; i < 3; i++) {

bool throws = (mask & (1 << i)) != 0;

- var future = new Future.delayed(

- new Duration(milliseconds: 100 * (i + 1)),

+ var future = new Future.delayed(new Duration(milliseconds: 100 * (i + 1)),

() => (throws ? throw "Error $i($mask-$permute)" : i));

int mod = 3 - i;

int position = permuteTmp % mod;

@@ -776,12 +794,13 @@ void testWaitCleanUp() {

Expect.isFalse(cleanup[index]);

cleanup[index] = true;

}

- Future.wait(futures, cleanUp: cleanUp)

- .then((_) { Expect.fail("No error: $stringId"); },

- onError: (e, s) {

- Expect.listEquals([true, true, true], cleanup);

- asyncEnd();

- });

+ Future.wait(futures, cleanUp: cleanUp).then((_) {

+ Expect.fail("No error: $stringId");

+ }, onError: (e, s) {

+ Expect.listEquals([true, true, true], cleanup);

+ asyncEnd();

+ });

}

for (int i = 1; i < 8; i++) {

@@ -807,8 +826,7 @@ void testWaitCleanUpEager() {

int permuteTmp = permute;

for (int i = 0; i < 3; i++) {

bool throws = (mask & (1 << i)) != 0;

- var future = new Future.delayed(

- new Duration(milliseconds: 100 * (i + 1)),

+ var future = new Future.delayed(new Duration(milliseconds: 100 * (i + 1)),

() => (throws ? throw "Error $i($mask-$permute)" : i));

int mod = 3 - i;

int position = permuteTmp % mod;

@@ -824,18 +842,20 @@ void testWaitCleanUpEager() {

asyncEnd();

}

void cleanUp(index) {

Expect.isFalse(cleanup[index]);

cleanup[index] = true;

// Cleanup might happen before and after the wait().then() callback.

checkDone();

}

- Future.wait(futures, eagerError: true, cleanUp: cleanUp)

- .then((_) { Expect.fail("No error: $stringId"); },

- onError: (e, s) {

- asyncEnd();

- checkDone();

- });

+ Future.wait(futures, eagerError: true, cleanUp: cleanUp).then((_) {

+ Expect.fail("No error: $stringId");

+ }, onError: (e, s) {

+ asyncEnd();

+ checkDone();

+ });

}

for (int i = 1; i < 8; i++) {

@@ -854,20 +874,19 @@ void testWaitCleanUpError() {

asyncStart();

runZoned(() {

- Future.wait([new Future.delayed(cms, () => 0),

- new Future.delayed(cms * 2, ()=> throw 1),

- new Future.delayed(cms * 3, () => 2)],

- cleanUp: (index) {

- Expect.isTrue(index == 0 || index == 2, "$index");

- Expect.isFalse(cleanups[index]);

- cleanups[index] = true;

- throw index;

- })

- .catchError((e) {

- Expect.equals(e, 1);

- asyncEnd();

- });

+ Future.wait([

+ new Future.delayed(cms, () => 0),

+ new Future.delayed(cms * 2, () => throw 1),

+ new Future.delayed(cms * 3, () => 2)

+ ], cleanUp: (index) {

+ Expect.isTrue(index == 0 || index == 2, "$index");

+ Expect.isFalse(cleanups[index]);

+ cleanups[index] = true;

+ throw index;

+ }).catchError((e) {

+ Expect.equals(e, 1);

+ asyncEnd();

+ });

}, onError: (int index, s) {

Expect.isTrue(index == 0 || index == 2, "$index");

Expect.isFalse(uncaughts[index]);

@@ -882,10 +901,11 @@ void testWaitSyncError() {

asyncStart();

runZoned(() {

- Future.wait(new Iterable.generate(5, (i) {

- if (i != 3) return new Future.delayed(cms * (i + 1), () => i);

- throw "throwing synchronously in iterable";

- }), cleanUp: (index) {

+ Future.wait(

+ new Iterable.generate(5, (i) {

+ if (i != 3) return new Future.delayed(cms * (i + 1), () => i);

+ throw "throwing synchronously in iterable";

+ }), cleanUp: (index) {

Expect.isFalse(cleanups[index]);

cleanups[index] = true;

if (cleanups.every((x) => x)) asyncEnd();

@@ -913,9 +933,8 @@ void testWaitSyncError3() {

var caughtError;

var count = 0;

- AsyncError errorCallback(

- Zone self, ZoneDelegate parent, Zone zone, Object error,

- StackTrace stackTrace) {

+ AsyncError errorCallback(Zone self, ZoneDelegate parent, Zone zone,

+ Object error, StackTrace stackTrace) {

Expect.equals(0, count);

count++;

caughtError = error;

@@ -938,18 +957,20 @@ void testBadFuture() {

asyncStart();

Completer completer = new Completer();

completer.complete(bad);

- completer.future.then((_) { Expect.fail("unreachable"); },

- onError: (e, s) {

- Expect.isTrue(completer.isCompleted);

- asyncEnd();

- });

+ completer.future.then((_) {

+ Expect.fail("unreachable");

+ }, onError: (e, s) {

+ Expect.isTrue(completer.isCompleted);

+ asyncEnd();

+ });

asyncStart();

var f = new Future.value().then((_) => bad);

- f.then((_) { Expect.fail("unreachable"); },

- onError: (e, s) {

- asyncEnd();

- });

+ f.then((_) {

+ Expect.fail("unreachable");

+ }, onError: (e, s) {

+ asyncEnd();

+ });

}

void testTypes() {

@@ -960,26 +981,26 @@ void testTypes() {

Expect.isFalse(future is Future<String>, "$desc is! Future<String>");

var stream = future.asStream();

Expect.isTrue(stream is Stream<int>, "$desc.asStream() is Stream<int>");

- Expect.isFalse(stream is Stream<String>,

- "$desc.asStream() is! Stream<String>");

+ Expect.isFalse(

+ stream is Stream<String>, "$desc.asStream() is! Stream<String>");

if (depth > 0) {

- testType(name, future.whenComplete((){}), depth - 1);

+ testType(name, future.whenComplete(() {}), depth - 1);

}

for (var value in [42, null]) {

- testType("Future($value)",

- new Future<int>(() => value));

+ testType("Future($value)", new Future<int>(() => value));

testType("Future.delayed($value)",

- new Future<int>.delayed(Duration.ZERO, () => value));

- testType("Future.microtask($value)",

- new Future<int>.microtask(() => value));

+ new Future<int>.delayed(Duration.ZERO, () => value));

+ testType(

+ "Future.microtask($value)", new Future<int>.microtask(() => value));

testType("Future.sync($value)", new Future<int>.sync(() => value)); // //# 01: ok

testType("Future.sync(future($value))", // //# 01: continued

new Future<int>.sync(() async => new Future.value(value))); //# 01: continued

testType("Future.value($value)", new Future<int>.value(value));

}

testType("Completer.future", new Completer<int>().future);

- testType("Future.error", new Future<int>.error("ERR")..catchError((_){}));

+ testType("Future.error", new Future<int>.error("ERR")..catchError((_) {}));

}

void testAnyValue() {

@@ -1055,7 +1076,9 @@ void testFutureResult() {

() async {

var f = new UglyFuture(5);

// Sanity check that our future is as mis-behaved as we think.

- f.then((v) { Expect.isTrue(v is Future); });

+ f.then((v) {

+ Expect.isTrue(v is Future);

+ });

var v = await f;

// The static type of await is Flatten(static-type-of-expression), so it

@@ -1170,15 +1193,19 @@ class BadFuture<T> implements Future<T> {

Future then(action(T result), {Function onError}) {

throw "then GOTCHA!";

}

Future catchError(Function onError, {bool test(e)}) {

throw "catch GOTCHA!";

}

Future whenComplete(action()) {

throw "finally GOTCHA!";

}

Stream<T> asStream() {

throw "asStream GOTCHA!";

}

Future timeout(Duration duration, {onTimeout()}) {

throw "timeout GOTCHA!";

}

@@ -1187,20 +1214,26 @@ class BadFuture<T> implements Future<T> {

// An evil future that completes with another future.

class UglyFuture implements Future<dynamic> {

final _result;

- UglyFuture(int badness) :

- _result = (badness == 0) ? 42 : new UglyFuture(badness - 1);

+ UglyFuture(int badness)

+ : _result = (badness == 0) ? 42 : new UglyFuture(badness - 1);

Future then(action(value), {onError(error, StackTrace stack)}) {

var c = new Completer();

c.complete(new Future.microtask(() => action(_result)));

return c.future;

}

- Future catchError(onError, {test}) => this; // Never an error.

+ Future catchError(onError, {test}) => this; // Never an error.

Future whenComplete(action()) {

return new Future.microtask(action).then((_) => this);

}

Stream asStream() {

- return (new StreamController()..add(_result)..close()).stream;

+ return (new StreamController()

+ ..add(_result)

+ ..close())

+ .stream;

}

Future timeout(Duration duration, {onTimeout()}) {

return this;

}

« no previous file with comments | « tests/lib/async/future_or_only_in_async_test.dart ('k') | tests/lib/async/print_test.dart » ('j') | no next file with comments »