Merge IO v2 branch to bleeding edge

tests/standalone/io/socket_many_connections_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.
 //
 // Test creating a large number of socket connections.
 library ServerTest;
 
 import "dart:io";
 import "dart:isolate";
 part "testing_server.dart";
@@ skipping 10 matching lines @@
     _sendPort = spawnFunction(startTestServer);
     initialize();
   }
 
   void run() {
 
     void connectHandler() {
       _connections++;
       if (_connections == CONNECTIONS) {
         for (int i = 0; i < CONNECTIONS; i++) {
-          _sockets[i].close();
+          _sockets[i].destroy();
         }
-        shutdown();
+        close();
       }
     }
 
     for (int i = 0; i < CONNECTIONS; i++) {
-      _sockets[i] = new Socket(TestingServer.HOST, _port);
-      if (_sockets[i] != null) {
-        _sockets[i].onConnect = connectHandler;
-      } else {
-        Expect.fail("socket creation failed");
-      }
+      Socket.connect(TestingServer.HOST, _port).then((socket) {
+        Expect.isNotNull(socket);
+        _sockets[i] = socket;
+        connectHandler();
+      });
     }
   }
 
   void initialize() {
     _receivePort.receive((var message, SendPort replyTo) {
       _port = message;
       run();
     });
     _sendPort.send(TestingServer.INIT, _receivePort.toSendPort());
   }
 
-  void shutdown() {
+  void close() {
     _sendPort.send(TestingServer.SHUTDOWN, _receivePort.toSendPort());
     _receivePort.close();
   }
 
   int _port;
   ReceivePort _receivePort;
   SendPort _sendPort;
   List<Socket> _sockets;
   int _connections;
 }
 
 
 void startTestServer() {
   var server = new TestServer();
   port.receive(server.dispatch);
 }
 
 class TestServer extends TestingServer {
 
   void onConnection(Socket connection) {
     Socket _client;
 
     void closeHandler() {
       connection.close();
     }
 
-    void errorHandler(Exception e) {
+    void errorHandler(e) {
       print("Socket error $e");
       connection.close();
     }
 
     _connections++;
-    connection.onClosed = closeHandler;
-    connection.onError = errorHandler;
+    connection.listen(
+        (data) {},
+        onDone: closeHandler,
+        onError: errorHandler);
   }
 
   int _connections = 0;
 }
 
 main() {
   SocketManyConnectionsTest test = new SocketManyConnectionsTest.start();
 }