Change handling of accepting socket connections

runtime/bin/socket_impl.dart

 // Copyright (c) 2011, 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.
 
 
 class _SocketBase {
   // Bit flags used when communicating between the eventhandler and
   // dart code. The EVENT flags are used to indicate events of
   // interest when sending a message from dart code to the
   // eventhandler. When receiving a message from the eventhandler the
@@ skipping 222 matching lines @@
     }
     throw new
         SocketIOException("Error: accept failed - invalid socket handle");
   }
 
   bool _accept(Socket socket) native "ServerSocket_Accept";
 
   bool _createBindListen(String bindAddress, int port, int backlog)
       native "ServerSocket_CreateBindListen";
 
-  void set connectionHandler(void callback()) {
-    _setHandler(_IN_EVENT, callback);
+  void set connectionHandler(void callback(Socket connection)) {
+    _clientConnectionHandler = callback;
+    _setHandler(_IN_EVENT,
+                _clientConnectionHandler != null ? _connectionHandler : null);
+  }
+
+  void _connectionHandler() {
+    if (_id >= 0) {
+      _Socket socket = new _Socket._internal();
+      if (_accept(socket)) _clientConnectionHandler(socket);
+    }
   }
 
   bool _isListenSocket() => true;
   bool _isPipe() => false;
+
+  var _clientConnectionHandler;
 }
 
 
 class _Socket extends _SocketBase implements Socket {
   /*
    * Constructor for socket. First a socket object is allocated
    * in which the native socket is stored. After that _createConnect is
    * called which creates a file discriptor and connects to the given
    * host on the given port. Null is returned if file descriptor creation
    * or connect failed.
@@ skipping 126 matching lines @@
     return _outputStream;
   }
 
   bool _closedRead = false;
   bool _closedWrite = false;
   bool _pipe = false;
   SocketInputStream _inputStream;
   SocketOutputStream _outputStream;
 }