Make event-handlers edge-triggered and move socket-state to Dart.

tests/standalone/io/raw_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 46 matching lines @@
             .catchError((error) {
               Expect.isTrue(error is SocketException);
               asyncEnd();
             });
       });
 }
 
 void testSimpleConnect() {
   asyncStart();
   RawServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
-    server.listen((_) { });
-    RawSocket.connect("127.0.0.1", server.port).then((_) {
+    server.listen((socket) { socket.close(); });
+    RawSocket.connect("127.0.0.1", server.port).then((socket) {
       server.close();
+      socket.close();
       asyncEnd();
     });
   });
 }
 
 void testCloseOneEnd(String toClose) {
   asyncStart();
   Completer serverDone = new Completer();
   Completer serverEndDone = new Completer();
   Completer clientEndDone = new Completer();
@@ skipping 26 matching lines @@
         server.close();
       });
     });
   });
 }
 
 void testServerListenAfterConnect() {
   asyncStart();
   RawServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
     Expect.isTrue(server.port > 0);
-    RawSocket.connect("127.0.0.1", server.port).then((_) {
-      server.listen((_) {
+    RawSocket.connect("127.0.0.1", server.port).then((client) {
+      server.listen((socket) {
+        client.close();
         server.close();
+        socket.close();
         asyncEnd();
       });
     });
   });
 }
 
 void testSimpleReadWrite({bool dropReads}) {
   // This test creates a server and a client connects. The client then
   // writes and the server echos. When the server has finished its
   // echo it half-closes. When the client gets the close event is
@@ skipping 122 matching lines @@
 }
 
 testPauseServerSocket() {
   const int socketCount = 10;
   var acceptCount = 0;
   var resumed = false;
 
   asyncStart();
   RawServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
     Expect.isTrue(server.port > 0);
-    var subscription = server.listen((_) {
+    var subscription = server.listen((socket) {
+      socket.close();
       Expect.isTrue(resumed);
       if (++acceptCount == socketCount) {
         server.close();
         asyncEnd();
       }
     });
 
     // Pause the server socket subscription and resume it after having
     // connected a number client sockets. Then connect more client
     // sockets.
     subscription.pause();
     var connectCount = 0;
     for (int i = 0; i < socketCount / 2; i++) {
-      RawSocket.connect("127.0.0.1", server.port).then((_) {
+      RawSocket.connect("127.0.0.1", server.port).then((socket) {
         if (++connectCount == socketCount / 2) {
           subscription.resume();
           resumed = true;
           for (int i = connectCount; i < socketCount; i++) {
-            RawSocket.connect("127.0.0.1", server.port).then((_) {});
+            RawSocket.connect("127.0.0.1", server.port).then((socket) {
+              socket.close();
+            });
           }
         }
+        socket.close();
       });
     }
   });
 }
 
 void testPauseSocket() {
   const messageSize = 1000;
   const loopCount = 10;
   Completer connected = new Completer();
   int pauseResumeCount = 0;
@@ skipping 150 matching lines @@
   testSimpleConnect();
   testServerListenAfterConnect();
   testSimpleReadWrite(dropReads: false);
   testSimpleReadWrite(dropReads: true);
   testPauseServerSocket();
   testPauseSocket();
   testSocketZone();
   testSocketZoneError();
   asyncEnd();
 }