diff --git a/lib/pool.dart b/lib/pool.dart
index d81386f..86f8363 100644
--- a/lib/pool.dart
+++ b/lib/pool.dart
@@ -78,8 +78,7 @@
   /// If [timeout] is passed, then if that much time passes without any activity
   /// all pending [request] futures will throw a [TimeoutException]. This is
   /// intended to avoid deadlocks.
-  Pool(this._maxAllocatedResources, {Duration timeout})
-      : _timeout = timeout {
+  Pool(this._maxAllocatedResources, {Duration timeout}) : _timeout = timeout {
     if (timeout != null) {
       // Start the timer canceled since we only want to start counting down once
       // we've run out of available resources.
@@ -140,21 +139,21 @@
   ///
   /// This may be called more than once; it returns the same [Future] each time.
   Future close() => _closeMemo.runOnce(() {
-    if (_closeGroup != null) return _closeGroup.future;
+        if (_closeGroup != null) return _closeGroup.future;
 
-    _resetTimer();
+        _resetTimer();
 
-    _closeGroup = new FutureGroup();
-    for (var callback in _onReleaseCallbacks) {
-      _closeGroup.add(new Future.sync(callback));
-    }
+        _closeGroup = new FutureGroup();
+        for (var callback in _onReleaseCallbacks) {
+          _closeGroup.add(new Future.sync(callback));
+        }
 
-    _allocatedResources -= _onReleaseCallbacks.length;
-    _onReleaseCallbacks.clear();
+        _allocatedResources -= _onReleaseCallbacks.length;
+        _onReleaseCallbacks.clear();
 
-    if (_allocatedResources == 0) _closeGroup.close();
-    return _closeGroup.future;
-  });
+        if (_allocatedResources == 0) _closeGroup.close();
+        return _closeGroup.future;
+      });
   final _closeMemo = new AsyncMemoizer();
 
   /// If there are any pending requests, this will fire the oldest one.
@@ -222,7 +221,8 @@
   void _onTimeout() {
     for (var completer in _requestedResources) {
       completer.completeError(
-          new TimeoutException("Pool deadlock: all resources have been "
+          new TimeoutException(
+              "Pool deadlock: all resources have been "
               "allocated for too long.",
               _timeout),
           new Chain.current());
diff --git a/test/pool_test.dart b/test/pool_test.dart
index 7fba9c0..6feba75 100644
--- a/test/pool_test.dart
+++ b/test/pool_test.dart
@@ -299,9 +299,11 @@
     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 @@
       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 @@
       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 @@
       // [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 @@
       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 @@
       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 @@
 ///
 /// 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;
+    });