Revert "Fix observatory tests broken by running dartfmt."

runtime/tests/vm/dart/hello_fuchsia_test.dart

 // Copyright (c) 2016, 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.
 
 import "dart:async";
 import "dart:convert";
 import "dart:io";
 
 testAddressParse() async {
   print(new InternetAddress("1.0.2.3").rawAddress);
@@ skipping 81 matching lines @@
           bytesRead += buffer.length;
           if (bytesRead == data.length) {
             verifyTestData(data);
             print("client READ event. Done reading, enabling writes");
             client.writeEventsEnabled = true;
             doneReading = true;
           }
           break;
         case RawSocketEvent.WRITE:
           assert(!client.writeEventsEnabled);
-          bytesWritten +=
-              client.write(data, bytesWritten, data.length - bytesWritten);
+          bytesWritten += client.write(
+              data, bytesWritten, data.length - bytesWritten);
           print("client WRITE event: $bytesWritten written");
           if (bytesWritten < data.length) {
             client.writeEventsEnabled = true;
           }
           if (bytesWritten == data.length) {
             print("client WRITE event: done writing.");
           }
           break;
         case RawSocketEvent.READ_CLOSED:
           print("client READ_CLOSED event");
           client.close();
           server.close();
           break;
         case RawSocketEvent.CLOSED:
           assert(!closedEventReceived);
           print("client CLOSED event");
           closedEventReceived = true;
           break;
-        default:
-          throw "Unexpected event $event";
+        default: throw "Unexpected event $event";
       }
-    }, onError: (e) {
-      print("client ERROR $e");
-    }, onDone: () {
-      assert(closedEventReceived);
-    });
+    },
+    onError: (e) { print("client ERROR $e"); },
+    onDone: () {assert(closedEventReceived);});
   });
 
   {
     var completer = new Completer();
     var socket = await RawSocket.connect("127.0.0.1", server.port);
     int bytesRead = 0;
     int bytesWritten = 0;
     bool closedEventReceived = false;
     List<int> data = createTestData();
 
     socket.listen((event) {
       switch (event) {
         case RawSocketEvent.READ:
           assert(socket.available() > 0);
           print("server READ event: ${bytesRead} read");
           var buffer = socket.read();
           print("server READ event: read ${buffer.length} more bytes");
           data.setRange(bytesRead, bytesRead + buffer.length, buffer);
           bytesRead += buffer.length;
           if (bytesRead == messageSize) {
             print("server READ event: done reading");
             socket.close();
           }
           break;
         case RawSocketEvent.WRITE:
           assert(bytesRead == 0);
           assert(!socket.writeEventsEnabled);
-          bytesWritten +=
-              socket.write(data, bytesWritten, data.length - bytesWritten);
+          bytesWritten += socket.write(
+              data, bytesWritten, data.length - bytesWritten);
           print("server WRITE event: ${bytesWritten} written");
           if (bytesWritten < data.length) {
             socket.writeEventsEnabled = true;
           } else {
             print("server WRITE event: done writing");
             data = new List<int>(messageSize);
           }
           break;
         case RawSocketEvent.READ_CLOSED:
           print("server READ_CLOSED event");
           verifyTestData(data);
           socket.close();
           break;
         case RawSocketEvent.CLOSED:
           assert(!closedEventReceived);
           print("server CLOSED event");
           closedEventReceived = true;
           break;
-        default:
-          throw "Unexpected event $event";
+        default: throw "Unexpected event $event";
       }
-    }, onError: (e) {
-      print("server ERROR $e");
-    }, onDone: () {
+    },
+    onError: (e) { print("server ERROR $e"); },
+    onDone: () {
       assert(closedEventReceived);
       completer.complete(null);
     });
 
     return completer.future;
   }
 }
 
 testSimpleReadWriteShutdown({bool dropReads}) async {
   // This test creates a server and a client connects. The client then
@@ skipping 49 matching lines @@
           bytesRead += buffer.length;
           if (bytesRead == data.length) {
             verifyTestData(data);
             print("client READ event. Done reading, enabling writes");
             client.writeEventsEnabled = true;
             doneReading = true;
           }
           break;
         case RawSocketEvent.WRITE:
           assert(!client.writeEventsEnabled);
-          bytesWritten +=
-              client.write(data, bytesWritten, data.length - bytesWritten);
+          bytesWritten += client.write(
+              data, bytesWritten, data.length - bytesWritten);
           print("client WRITE event: $bytesWritten written");
           if (bytesWritten < data.length) {
             client.writeEventsEnabled = true;
           }
           if (bytesWritten == data.length) {
             print("client WRITE event: done writing.");
             client.shutdown(SocketDirection.SEND);
           }
           break;
         case RawSocketEvent.READ_CLOSED:
           print("client READ_CLOSED event");
           server.close();
           break;
         case RawSocketEvent.CLOSED:
           assert(!closedEventReceived);
           print("client CLOSED event");
           closedEventReceived = true;
           break;
-        default:
-          throw "Unexpected event $event";
+        default: throw "Unexpected event $event";
       }
-    }, onDone: () {
-      assert(closedEventReceived);
-    });
+    },
+    onDone: () {assert(closedEventReceived);});
   });
 
   {
     var completer = new Completer();
     var socket = await RawSocket.connect("127.0.0.1", server.port);
     int bytesRead = 0;
     int bytesWritten = 0;
     bool closedEventReceived = false;
     List<int> data = createTestData();
 
@@ skipping 11 matching lines @@
           }
           print("server READ event: ${bytesRead} read");
           var buffer = socket.read();
           print("server READ event: read ${buffer.length} more bytes");
           data.setRange(bytesRead, bytesRead + buffer.length, buffer);
           bytesRead += buffer.length;
           break;
         case RawSocketEvent.WRITE:
           assert(bytesRead == 0);
           assert(!socket.writeEventsEnabled);
-          bytesWritten +=
-              socket.write(data, bytesWritten, data.length - bytesWritten);
+          bytesWritten += socket.write(
+              data, bytesWritten, data.length - bytesWritten);
           print("server WRITE event: ${bytesWritten} written");
           if (bytesWritten < data.length) {
             socket.writeEventsEnabled = true;
           } else {
             print("server WRITE event: done writing");
             data = new List<int>(messageSize);
           }
           break;
         case RawSocketEvent.READ_CLOSED:
           print("server READ_CLOSED event");
           verifyTestData(data);
           socket.close();
           break;
         case RawSocketEvent.CLOSED:
           assert(!closedEventReceived);
           print("server CLOSED event");
           closedEventReceived = true;
           break;
-        default:
-          throw "Unexpected event $event";
+        default: throw "Unexpected event $event";
       }
-    }, onDone: () {
+    },
+    onDone: () {
       assert(closedEventReceived);
       completer.complete(null);
     });
 
     return completer.future;
   }
 }
 
 Future testGoogleHttp(SecurityContext context, String outcome) async {
   var client = new HttpClient(context: context);
   try {
     // First, check if the lookup works.
     var address = await InternetAddress.lookup('www.google.com');
     print(address);
     var request = await client.getUrl(Uri.parse('http://www.google.com/'));
     request.followRedirects = false;
     var response = await request.close();
     assert('pass' == outcome);
-    try {
-      await response.drain();
-    } catch (e) {
+    try { await response.drain(); } catch (e) {
       print('drain failed: $e');
     }
   } catch (e) {
     // Lookup failed or connection failed.  Don't report a failure.
     print("SocketException: $e");
   } finally {
     client.close();
   }
 }
 
 Future testGoogleHttps(SecurityContext context, String outcome) async {
   // If this isn't reasonable, the certificate will be rejected.
   print(new DateTime.now());
 
   var client = new HttpClient(context: context);
   // We need to use an external server that is backed by a
   // built-in root certificate authority.
   try {
     // First, check if the lookup works.
     var address = await InternetAddress.lookup('www.google.com');
     print(address);
     var request = await client.getUrl(Uri.parse('https://www.google.com/'));
     request.followRedirects = false;
     var response = await request.close();
     assert('pass' == outcome);
-    try {
-      await response.drain();
-    } catch (e) {
+    try { await response.drain(); } catch (e) {
       print('drain failed: $e');
     }
   } catch (e) {
     // Lookup failed or connection failed.  Don't report a failure.
     print("SocketException: $e");
   } finally {
     client.close();
   }
 }
 
@@ skipping 142 matching lines @@
   print("testCopy");
   await testCopy();
   print("testCopy done");
 
   print("testRecursiveDelete");
   await testRecursiveDelete();
   print("testRecursiveDelete done");
 
   print("Goodbyte, Fuchsia!");
 }