Format all tests.

tests/standalone/io/web_socket_protocol_processor_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.
 
 library dart.io;
 
 import "package:async_helper/async_helper.dart";
 import "package:expect/expect.dart";
 import "dart:async";
 import "dart:collection";
@@ skipping 42 matching lines @@
 class WebSocketMessageCollector {
   List<int> expectedMessage;
 
   int messageCount = 0;
 
   var data;
 
   Function onClosed;
 
   WebSocketMessageCollector(Stream stream,
-                            [List<int> this.expectedMessage = null]) {
+      [List<int> this.expectedMessage = null]) {
     stream.listen(onMessageData, onDone: onClosed, onError: onError);
   }
 
   void onMessageData(buffer) {
     if (buffer is String) {
       buffer = UTF8.encode(buffer);
     }
     Expect.listEquals(expectedMessage, buffer);
     messageCount++;
     data = buffer;
   }
 
   void onError(e, trace) {
     String msg = "Unexpected error $e";
     if (trace != null) msg += "\nStackTrace: $trace";
     Expect.fail(msg);
   }
-
 }
 
-
 // Web socket constants.
 const int FRAME_OPCODE_TEXT = 1;
 const int FRAME_OPCODE_BINARY = 2;
 
-
 // Function for building a web socket frame.
-List<int> createFrame(bool fin,
-                      int opcode,
-                      int maskingKey,
-                      List<int> data,
-                      int offset,
-                      int count) {
+List<int> createFrame(bool fin, int opcode, int maskingKey, List<int> data,
+    int offset, int count) {
   int frameSize = 2;
   if (count > 125) frameSize += 2;
   if (count > 65535) frameSize += 6;
   frameSize += count;
   // No masking.
   assert(maskingKey == null);
   List<int> frame = new Uint8List(frameSize);
   int frameIndex = 0;
   frame[frameIndex++] = (fin ? 0x80 : 0x00) | opcode;
   if (count < 126) {
     frame[frameIndex++] = count;
   } else if (count < 65536) {
     frame[frameIndex++] = 126;
     frame[frameIndex++] = count >> 8;
     frame[frameIndex++] = count & 0xFF;
   } else {
     frame[frameIndex++] = 127;
     for (int i = 0; i < 8; i++) {
       frame[frameIndex++] = count >> ((7 - i) * 8) & 0xFF;
     }
   }
   frame.setRange(frameIndex, frameIndex + count, data, offset);
   return frame;
 }
 
-
 // Test processing messages which are sent in a single frame.
 void testFullMessages() {
   void testMessage(int opcode, List<int> message) {
     int messageCount = 0;
     // Use the same web socket protocol transformer for all frames.
     var transformer = new _WebSocketProtocolTransformer();
     var controller = new StreamController(sync: true);
     WebSocketMessageCollector mc = new WebSocketMessageCollector(
-        controller.stream.transform(transformer),
-        message);
+        controller.stream.transform(transformer), message);
 
-    List<int> frame = createFrame(
-        true, opcode, null, message, 0, message.length);
+    List<int> frame =
+        createFrame(true, opcode, null, message, 0, message.length);
 
     // Update the transformer with one big chunk.
     messageCount++;
     controller.add(frame);
     mc.onClosed = () {
       Expect.isNotNull(mc.data);
       Expect.equals(0, transformer._state);
 
       mc.data = null;
 
@@ skipping 32 matching lines @@
     }
   }
 
   // Test different message sizes.
   runTest(0, 10, 1);
   runTest(120, 130, 1);
   runTest(0, 1000, 100);
   runTest(65534, 65537, 1);
 }
 
-
 // Test processing of frames which are split into fragments.
 void testFragmentedMessages() {
   // Use the same web socket protocol transformer for all frames.
   var transformer = new _WebSocketProtocolTransformer();
   var controller = new StreamController(sync: true);
-  WebSocketMessageCollector mc = new WebSocketMessageCollector(
-      controller.stream.transform(transformer));
+  WebSocketMessageCollector mc =
+      new WebSocketMessageCollector(controller.stream.transform(transformer));
 
   int messageCount = 0;
   int frameCount = 0;
 
   void testFragmentMessage(int opcode, List<int> message, int fragmentSize) {
     messageCount++;
     int messageIndex = 0;
     int remaining = message.length;
     bool firstFrame = true;
     bool lastFrame = false;
     while (!lastFrame) {
       int payloadSize = min(fragmentSize, remaining);
       lastFrame = payloadSize == remaining;
-      List<int> frame = createFrame(lastFrame,
-                                    firstFrame ? opcode : 0x00,
-                                    null,
-                                    message,
-                                    messageIndex,
-                                    payloadSize);
+      List<int> frame = createFrame(lastFrame, firstFrame ? opcode : 0x00, null,
+          message, messageIndex, payloadSize);
       frameCount++;
       messageIndex += payloadSize;
       controller.add(frame);
       remaining -= payloadSize;
       firstFrame = false;
     }
   }
 
   void testMessageFragmentation(int opcode, List<int> message) {
     mc.expectedMessage = message;
@@ skipping 29 matching lines @@
 }
 
 void testUnmaskedMessage() {
   var transformer = new _WebSocketProtocolTransformer(true);
   var controller = new StreamController(sync: true);
   asyncStart();
   controller.stream.transform(transformer).listen((_) {}, onError: (e) {
     asyncEnd();
   });
   var message = new Uint8List(10);
-  List<int> frame = createFrame(
-      true, FRAME_OPCODE_BINARY, null, message, 0, message.length);
+  List<int> frame =
+      createFrame(true, FRAME_OPCODE_BINARY, null, message, 0, message.length);
   controller.add(frame);
 }
 
-
 void main() {
   testFullMessages();
   testFragmentedMessages();
   testUnmaskedMessage();
 }