Index: test/ports_test.dart |
diff --git a/test/ports_test.dart b/test/ports_test.dart |
index 9586b96da680fb72cad877da7f9d1828eb057ac9..5c1e5e84f2218ede3cbc55c4bc7cfcf1ecc82f09 100644 |
--- a/test/ports_test.dart |
+++ b/test/ports_test.dart |
@@ -48,8 +48,7 @@ void testSingleCallbackPort() { |
test("singleCallbackValueBeforeTimeout", () { |
Completer completer = new Completer.sync(); |
- SendPort p = singleCallbackPort(completer.complete, |
- timeout: MS * 500); |
+ SendPort p = singleCallbackPort(completer.complete, timeout: MS * 500); |
p.send(42); |
return completer.future.then((v) { |
expect(v, 42); |
@@ -58,9 +57,7 @@ void testSingleCallbackPort() { |
test("singleCallbackTimeout", () { |
Completer completer = new Completer.sync(); |
- singleCallbackPort(completer.complete, |
- timeout: MS * 100, |
- timeoutValue: 37); |
+ singleCallbackPort(completer.complete, timeout: MS * 100, timeoutValue: 37); |
return completer.future.then((v) { |
expect(v, 37); |
}); |
@@ -69,8 +66,7 @@ void testSingleCallbackPort() { |
test("singleCallbackTimeoutFirst", () { |
Completer completer = new Completer.sync(); |
SendPort p = singleCallbackPort(completer.complete, |
- timeout: MS * 100, |
- timeoutValue: 37); |
+ timeout: MS * 100, timeoutValue: 37); |
Lasse Reichstein Nielsen
2015/02/26 10:59:15
Indent to after '(' or put completer.complete on n
|
new Timer(MS * 500, () => p.send(42)); |
return completer.future.then((v) { |
expect(v, 37); |
@@ -78,7 +74,6 @@ void testSingleCallbackPort() { |
}); |
} |
- |
void testSingleCompletePort() { |
test("singleCompleteValue", () { |
Completer completer = new Completer.sync(); |
@@ -91,11 +86,10 @@ void testSingleCompletePort() { |
test("singleCompleteValueCallback", () { |
Completer completer = new Completer.sync(); |
- SendPort p = singleCompletePort(completer, |
- callback: (v) { |
- expect(42, v); |
- return 87; |
- }); |
+ SendPort p = singleCompletePort(completer, callback: (v) { |
+ expect(42, v); |
+ return 87; |
+ }); |
Lasse Reichstein Nielsen
2015/02/26 10:59:15
This is much better!
|
p.send(42); |
return completer.future.then((v) { |
expect(v, 87); |
@@ -104,12 +98,10 @@ void testSingleCompletePort() { |
test("singleCompleteValueCallbackFuture", () { |
Completer completer = new Completer.sync(); |
- SendPort p = singleCompletePort(completer, |
- callback: (v) { |
- expect(42, v); |
- return new Future.delayed(MS * 500, |
- () => 88); |
- }); |
+ SendPort p = singleCompletePort(completer, callback: (v) { |
+ expect(42, v); |
+ return new Future.delayed(MS * 500, () => 88); |
+ }); |
p.send(42); |
return completer.future.then((v) { |
expect(v, 88); |
@@ -118,11 +110,10 @@ void testSingleCompletePort() { |
test("singleCompleteValueCallbackThrows", () { |
Completer completer = new Completer.sync(); |
- SendPort p = singleCompletePort(completer, |
- callback: (v) { |
- expect(42, v); |
- throw 89; |
- }); |
+ SendPort p = singleCompletePort(completer, callback: (v) { |
+ expect(42, v); |
+ throw 89; |
+ }); |
p.send(42); |
return completer.future.then((v) { |
fail("unreachable"); |
@@ -133,11 +124,10 @@ void testSingleCompletePort() { |
test("singleCompleteValueCallbackThrowsFuture", () { |
Completer completer = new Completer.sync(); |
- SendPort p = singleCompletePort(completer, |
- callback: (v) { |
- expect(42, v); |
- return new Future.error(90); |
- }); |
+ SendPort p = singleCompletePort(completer, callback: (v) { |
+ expect(42, v); |
+ return new Future.error(90); |
+ }); |
p.send(42); |
return completer.future.then((v) { |
fail("unreachable"); |
@@ -159,9 +149,9 @@ void testSingleCompletePort() { |
test("singleCompleteFirstValueCallback", () { |
Completer completer = new Completer.sync(); |
SendPort p = singleCompletePort(completer, callback: (v) { |
- expect(v, 42); |
- return 87; |
- }); |
+ expect(v, 42); |
+ return 87; |
+ }); |
p.send(42); |
p.send(37); |
return completer.future.then((v) { |
@@ -171,8 +161,7 @@ void testSingleCompletePort() { |
test("singleCompleteValueBeforeTimeout", () { |
Completer completer = new Completer.sync(); |
- SendPort p = singleCompletePort(completer, |
- timeout: MS * 500); |
+ SendPort p = singleCompletePort(completer, timeout: MS * 500); |
p.send(42); |
return completer.future.then((v) { |
expect(v, 42); |
@@ -181,8 +170,7 @@ void testSingleCompletePort() { |
test("singleCompleteTimeout", () { |
Completer completer = new Completer.sync(); |
- singleCompletePort(completer, |
- timeout: MS * 100); |
+ singleCompletePort(completer, timeout: MS * 100); |
return completer.future.then((v) { |
fail("unreachable"); |
}, onError: (e, s) { |
@@ -192,9 +180,7 @@ void testSingleCompletePort() { |
test("singleCompleteTimeoutCallback", () { |
Completer completer = new Completer.sync(); |
- singleCompletePort(completer, |
- timeout: MS * 100, |
- onTimeout: () => 87); |
+ singleCompletePort(completer, timeout: MS * 100, onTimeout: () => 87); |
return completer.future.then((v) { |
expect(v, 87); |
}); |
@@ -202,9 +188,7 @@ void testSingleCompletePort() { |
test("singleCompleteTimeoutCallbackThrows", () { |
Completer completer = new Completer.sync(); |
- singleCompletePort(completer, |
- timeout: MS * 100, |
- onTimeout: () => throw 91); |
+ singleCompletePort(completer, timeout: MS * 100, onTimeout: () => throw 91); |
return completer.future.then((v) { |
fail("unreachable"); |
}, onError: (e, s) { |
@@ -215,8 +199,7 @@ void testSingleCompletePort() { |
test("singleCompleteTimeoutCallbackFuture", () { |
Completer completer = new Completer.sync(); |
singleCompletePort(completer, |
- timeout: MS * 100, |
- onTimeout: () => new Future.value(87)); |
+ timeout: MS * 100, onTimeout: () => new Future.value(87)); |
return completer.future.then((v) { |
expect(v, 87); |
}); |
@@ -225,8 +208,7 @@ void testSingleCompletePort() { |
test("singleCompleteTimeoutCallbackThrowsFuture", () { |
Completer completer = new Completer.sync(); |
singleCompletePort(completer, |
- timeout: MS * 100, |
- onTimeout: () => new Future.error(92)); |
+ timeout: MS * 100, onTimeout: () => new Future.error(92)); |
return completer.future.then((v) { |
fail("unreachable"); |
}, onError: (e, s) { |
@@ -236,8 +218,7 @@ void testSingleCompletePort() { |
test("singleCompleteTimeoutCallbackSLow", () { |
Completer completer = new Completer.sync(); |
- singleCompletePort( |
- completer, |
+ singleCompletePort(completer, |
timeout: MS * 100, |
onTimeout: () => new Future.delayed(MS * 500, () => 87)); |
return completer.future.then((v) { |
@@ -247,8 +228,7 @@ void testSingleCompletePort() { |
test("singleCompleteTimeoutCallbackThrowsSlow", () { |
Completer completer = new Completer.sync(); |
- singleCompletePort( |
- completer, |
+ singleCompletePort(completer, |
timeout: MS * 100, |
onTimeout: () => new Future.delayed(MS * 500, () => throw 87)); |
return completer.future.then((v) { |
@@ -260,9 +240,8 @@ void testSingleCompletePort() { |
test("singleCompleteTimeoutFirst", () { |
Completer completer = new Completer.sync(); |
- SendPort p = singleCompletePort(completer, |
- timeout: MS * 100, |
- onTimeout: () => 37); |
+ SendPort p = |
+ singleCompletePort(completer, timeout: MS * 100, onTimeout: () => 37); |
new Timer(MS * 500, () => p.send(42)); |
return completer.future.then((v) { |
expect(v, 37); |