Format all tests.

tests/standalone/io/socket_test.dart

 // Copyright (c) 2013, 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=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 import "dart:async";
@@ skipping 13 matching lines @@
   ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((s) {
     Expect.isTrue(s.port > 0);
     s.close();
     asyncEnd();
   });
 }
 
 void testInvalidBind() {
   // Bind to a unknown DNS name.
   asyncStart();
-  ServerSocket.bind("ko.faar.__hest__", 0)
-      .then((_) { Expect.fail("Failure expected"); } )
-      .catchError((error) {
-        Expect.isTrue(error is SocketException);
-        asyncEnd();
-      });
+  ServerSocket.bind("ko.faar.__hest__", 0).then((_) {
+    Expect.fail("Failure expected");
+  }).catchError((error) {
+    Expect.isTrue(error is SocketException);
+    asyncEnd();
+  });
 
   // Bind to an unavaliable IP-address.
   asyncStart();
-  ServerSocket.bind("8.8.8.8", 0)
-      .then((_) { Expect.fail("Failure expected"); } )
-      .catchError((error) {
-        Expect.isTrue(error is SocketException);
-        asyncEnd();
-      });
+  ServerSocket.bind("8.8.8.8", 0).then((_) {
+    Expect.fail("Failure expected");
+  }).catchError((error) {
+    Expect.isTrue(error is SocketException);
+    asyncEnd();
+  });
 
   // Bind to a port already in use.
   asyncStart();
-  ServerSocket.bind("127.0.0.1", 0)
-      .then((s) {
-        ServerSocket.bind("127.0.0.1", s.port)
-            .then((t) {
-              Expect.fail("Multiple listens on same port");
-            })
-            .catchError((error) {
-              Expect.isTrue(error is SocketException);
-              s.close();
-              asyncEnd();
-            });
-      });
+  ServerSocket.bind("127.0.0.1", 0).then((s) {
+    ServerSocket.bind("127.0.0.1", s.port).then((t) {
+      Expect.fail("Multiple listens on same port");
+    }).catchError((error) {
+      Expect.isTrue(error is SocketException);
+      s.close();
+      asyncEnd();
+    });
+  });
 }
 
 void testConnectImmediateDestroy() {
   asyncStart();
   ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
-    server.listen((_) { });
+    server.listen((_) {});
     Socket.connect("127.0.0.1", server.port).then((socket) {
       socket.destroy();
       server.close();
       asyncEnd();
     });
   });
 }
 
 void testConnectConsumerClose() {
   // Connect socket then immediate close the consumer without
   // listening on the stream.
   asyncStart();
   ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
-    server.listen((_) { });
+    server.listen((_) {});
     Socket.connect("127.0.0.1", server.port).then((socket) {
       socket.close();
       socket.done.then((_) {
         socket.destroy();
         server.close();
         asyncEnd();
       });
     });
   });
 }
 
 void testConnectConsumerWriteClose() {
   // Connect socket write some data immediate close the consumer
   // without listening on the stream.
   asyncStart();
   ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
-    server.listen((_) { });
+    server.listen((_) {});
     Socket.connect("127.0.0.1", server.port).then((socket) {
       socket.add([0, 1, 2, 3, 4, 5, 6, 7, 8, 9]);
       socket.close();
       socket.done.then((_) {
         socket.destroy();
         server.close();
         asyncEnd();
       });
     });
   });
 }
 
 void testConnectStreamClose() {
   // Connect socket and listen on the stream. The server closes
   // immediately so only a done event is received.
   asyncStart();
   ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
     server.listen((client) {
-                    client.close();
-                    client.done.then((_) => client.destroy());
-                  });
+      client.close();
+      client.done.then((_) => client.destroy());
+    });
     Socket.connect("127.0.0.1", server.port).then((socket) {
-        bool onDoneCalled = false;
-        socket.listen((_) { Expect.fail("Unexpected data"); },
-                      onDone: () {
-                        Expect.isFalse(onDoneCalled);
-                        onDoneCalled = true;
-                        socket.close();
-                        server.close();
-                        asyncEnd();
-                      });
+      bool onDoneCalled = false;
+      socket.listen((_) {
+        Expect.fail("Unexpected data");
+      }, onDone: () {
+        Expect.isFalse(onDoneCalled);
+        onDoneCalled = true;
+        socket.close();
+        server.close();
+        asyncEnd();
+      });
     });
   });
 }
 
 void testConnectStreamDataClose(bool useDestroy) {
   // Connect socket and listen on the stream. The server sends data
   // and then closes so both data and a done event is received.
   List<int> sendData = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
   asyncStart();
   ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
-    server.listen(
-        (client) {
-          client.add(sendData);
-          if (useDestroy) {
-            client.destroy();
-          } else {
-            client.close();
-          }
-          client.done.then((_) { if (!useDestroy) { client.destroy(); } });
-        });
+    server.listen((client) {
+      client.add(sendData);
+      if (useDestroy) {
+        client.destroy();
+      } else {
+        client.close();
+      }
+      client.done.then((_) {
+        if (!useDestroy) {
+          client.destroy();
+        }
+      });
+    });
     Socket.connect("127.0.0.1", server.port).then((socket) {
-        List<int> data = [];
-        bool onDoneCalled = false;
-        socket.listen(data.addAll,
-                      onDone: () {
-                        Expect.isFalse(onDoneCalled);
-                        onDoneCalled = true;
-                        if (!useDestroy) Expect.listEquals(sendData, data);
-                        socket.add([0]);
-                        socket.close();
-                        server.close();
-                        asyncEnd();
-                      });
+      List<int> data = [];
+      bool onDoneCalled = false;
+      socket.listen(data.addAll, onDone: () {
+        Expect.isFalse(onDoneCalled);
+        onDoneCalled = true;
+        if (!useDestroy) Expect.listEquals(sendData, data);
+        socket.add([0]);
+        socket.close();
+        server.close();
+        asyncEnd();
+      });
     });
   });
 }
 
 void testConnectStreamDataCloseCancel(bool useDestroy) {
   List<int> sendData = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
   asyncStart();
   ServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
-    server.listen(
-        (client) {
-          client.add(sendData);
-          if (useDestroy) {
-            client.destroy();
-          } else {
-            client.close();
-          }
-          client.done
-              .then((_) {
-                if (!useDestroy) client.destroy();
-              })
-              .catchError((e) { /* can happen with short writes */ });
-        });
+    server.listen((client) {
+      client.add(sendData);
+      if (useDestroy) {
+        client.destroy();
+      } else {
+        client.close();
+      }
+      client.done.then((_) {
+        if (!useDestroy) client.destroy();
+      }).catchError((e) {/* can happen with short writes */});
+    });
     Socket.connect("127.0.0.1", server.port).then((socket) {
-        List<int> data = [];
-        bool onDoneCalled = false;
-        var subscription;
-        subscription = socket.listen(
-            (_) {
-              subscription.cancel();
-              socket.close();
-              server.close();
-              asyncEnd();
-            },
-            onDone: () { Expect.fail("Unexpected pipe completion"); });
+      List<int> data = [];
+      bool onDoneCalled = false;
+      var subscription;
+      subscription = socket.listen((_) {
+        subscription.cancel();
+        socket.close();
+        server.close();
+        asyncEnd();
+      }, onDone: () {
+        Expect.fail("Unexpected pipe completion");
+      });
     });
   });
 }
 
 main() {
   testArguments();
   testSimpleBind();
   testInvalidBind();
   testConnectImmediateDestroy();
   testConnectConsumerClose();
   testConnectConsumerWriteClose();
   testConnectStreamClose();
   testConnectStreamDataClose(true);
   testConnectStreamDataClose(false);
   testConnectStreamDataCloseCancel(true);
   testConnectStreamDataCloseCancel(false);
 }