Index: packages/pool/test/pool_test.dart |
diff --git a/packages/pool/test/pool_test.dart b/packages/pool/test/pool_test.dart |
index 7fba9c0b06812470bc85befc890498a16f1e38d4..6feba75c34efd9691ab96fc43d69cffbb128b077 100644 |
--- a/packages/pool/test/pool_test.dart |
+++ b/packages/pool/test/pool_test.dart |
@@ -299,9 +299,11 @@ void main() { |
test("pending requests are fulfilled", () async { |
var pool = new Pool(1); |
var resource1 = await pool.request(); |
- expect(pool.request().then((resource2) { |
- resource2.release(); |
- }), completes); |
+ expect( |
+ pool.request().then((resource2) { |
+ resource2.release(); |
+ }), |
+ completes); |
expect(pool.done, completes); |
expect(pool.close(), completes); |
resource1.release(); |
@@ -312,10 +314,12 @@ void main() { |
var resource1 = await pool.request(); |
var completer = new Completer(); |
- expect(pool.request().then((resource2) { |
- expect(completer.isCompleted, isTrue); |
- resource2.release(); |
- }), completes); |
+ expect( |
+ pool.request().then((resource2) { |
+ expect(completer.isCompleted, isTrue); |
+ resource2.release(); |
+ }), |
+ completes); |
expect(pool.close(), completes); |
resource1.allowRelease(() => completer.future); |
@@ -333,11 +337,13 @@ void main() { |
var resource1Released = false; |
var resource2Released = false; |
var resource3Released = false; |
- expect(pool.close().then((_) { |
- expect(resource1Released, isTrue); |
- expect(resource2Released, isTrue); |
- expect(resource3Released, isTrue); |
- }), completes); |
+ expect( |
+ pool.close().then((_) { |
+ expect(resource1Released, isTrue); |
+ expect(resource2Released, isTrue); |
+ expect(resource3Released, isTrue); |
+ }), |
+ completes); |
resource1Released = true; |
resource1.release(); |
@@ -360,9 +366,11 @@ void main() { |
// [completer]. |
var completer = new Completer(); |
resource.allowRelease(() => completer.future); |
- expect(pool.request().then((_) { |
- expect(completer.isCompleted, isTrue); |
- }), completes); |
+ expect( |
+ pool.request().then((_) { |
+ expect(completer.isCompleted, isTrue); |
+ }), |
+ completes); |
await new Future.delayed(Duration.ZERO); |
pool.close(); |
@@ -381,10 +389,12 @@ void main() { |
var completer2 = new Completer(); |
resource2.allowRelease(() => completer2.future); |
- expect(pool.close().then((_) { |
- expect(completer1.isCompleted, isTrue); |
- expect(completer2.isCompleted, isTrue); |
- }), completes); |
+ expect( |
+ pool.close().then((_) { |
+ expect(completer1.isCompleted, isTrue); |
+ expect(completer2.isCompleted, isTrue); |
+ }), |
+ completes); |
await new Future.delayed(Duration.ZERO); |
completer1.complete(); |
@@ -398,9 +408,11 @@ void main() { |
var resource = await pool.request(); |
var completer = new Completer(); |
- expect(pool.close().then((_) { |
- expect(completer.isCompleted, isTrue); |
- }), completes); |
+ expect( |
+ pool.close().then((_) { |
+ expect(completer.isCompleted, isTrue); |
+ }), |
+ completes); |
await new Future.delayed(Duration.ZERO); |
resource.allowRelease(() => completer.future); |
@@ -438,10 +450,10 @@ Function expectNoAsync() { |
/// |
/// This should only be called within a [FakeAsync.run] zone. |
Matcher get doesNotComplete => predicate((future) { |
- expect(future, new isInstanceOf<Future>()); |
+ expect(future, new isInstanceOf<Future>()); |
- var stack = new Trace.current(1); |
- future.then((_) => registerException( |
- new TestFailure("Expected future not to complete."), stack)); |
- return true; |
-}); |
+ var stack = new Trace.current(1); |
+ future.then((_) => registerException( |
+ new TestFailure("Expected future not to complete."), stack)); |
+ return true; |
+ }); |