Format all tests.

tests/lib_strong/async/slow_consumer3_test.dart

 // Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 // VMOptions=--old_gen_heap_size=64
 
 library slow_consumer3_test;
 
 import 'package:async_helper/async_helper.dart';
 import "package:expect/expect.dart";
@@ skipping 13 matching lines @@
 
   SlowConsumer(int this.bytesPerSecond, int this.bufferSize);
 
   Future consume(Stream stream) {
     return addStream(stream).then((_) => close());
   }
 
   Future addStream(Stream stream) {
     Completer result = new Completer();
     var subscription;
-    subscription = stream.listen(
-      (List<int> data) {
-        receivedCount += data.length;
-        usedBufferSize += data.length;
-        bufferedData.add(data);
-        int currentBufferedDataLength = bufferedData.length;
-        if (usedBufferSize > bufferSize) {
-          subscription.pause();
-          usedBufferSize = 0;
-          int ms = data.length * 1000 ~/ bytesPerSecond;
-          Duration duration = new Duration(milliseconds: ms);
-          new Timer(duration, () {
-            for (int i = 0; i < currentBufferedDataLength; i++) {
-              bufferedData[i] = null;
-            }
-            subscription.resume();
-          });
-        }
-      },
-      onDone: () {
-        finalCount = receivedCount;
-        result.complete(receivedCount);
-      });
+    subscription = stream.listen((List<int> data) {
+      receivedCount += data.length;
+      usedBufferSize += data.length;
+      bufferedData.add(data);
+      int currentBufferedDataLength = bufferedData.length;
+      if (usedBufferSize > bufferSize) {
+        subscription.pause();
+        usedBufferSize = 0;
+        int ms = data.length * 1000 ~/ bytesPerSecond;
+        Duration duration = new Duration(milliseconds: ms);
+        new Timer(duration, () {
+          for (int i = 0; i < currentBufferedDataLength; i++) {
+            bufferedData[i] = null;
+          }
+          subscription.resume();
+        });
+      }
+    }, onDone: () {
+      finalCount = receivedCount;
+      result.complete(receivedCount);
+    });
     return result.future;
   }
 
   Future close() {
     return new Future.value(finalCount);
   }
 }
 
 Stream<List> dataGenerator(int bytesTotal, int chunkSize) {
   int chunks = bytesTotal ~/ chunkSize;
@@ skipping 12 matching lines @@
   // Notice that we aren't really counting bytes, but words, since we use normal
   // lists where each entry takes up a full word. In 64-bit VMs this will be
   // 8 bytes per entry, so the 3*MB buffer is picked to stay below 32 actual
   // MiB.
   //
   // This test is limited to 32MB of heap-space (see VMOptions on top of the
   // file). If the consumer doesn't pause the data-provider it will run out of
   // heap-space.
 
   dataGenerator(100 * MB, 512 * KB)
-    .pipe(new SlowConsumer(200 * MB, 3 * MB))
-    .then((count) {
-      Expect.equals(100 * MB, count);
-      asyncEnd();
-    });
+      .pipe(new SlowConsumer(200 * MB, 3 * MB))
+      .then((count) {
+    Expect.equals(100 * MB, count);
+    asyncEnd();
+  });
 }