Use generic functions in zones.

runtime/bin/socket_patch.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.
 
 @patch
 class RawServerSocket {
   @patch
   static Future<RawServerSocket> bind(address, int port,
       {int backlog: 0, bool v6Only: false, bool shared: false}) {
     return _RawServerSocket.bind(address, port, backlog, v6Only, shared);
@@ skipping 1118 matching lines @@
     if (_controller != null) {
       throw new StateError("Stream was already listened to");
     }
     var zone = Zone.current;
     _controller = new StreamController(
         sync: true,
         onListen: _onSubscriptionStateChange,
         onCancel: _onSubscriptionStateChange,
         onPause: _onPauseStateChange,
         onResume: _onPauseStateChange);
-    _socket.setHandlers(read: zone.bindCallback(() {
+    _socket.setHandlers(read: zone.bindCallbackGuarded(() {
       while (_socket.available > 0) {
         var socket = _socket.accept();
         if (socket == null) return;
         _controller.add(new _RawSocket(socket));
         if (_controller.isPaused) return;
       }
-    }), error: zone.bindUnaryCallback((e) {
+    }), error: zone.bindUnaryCallbackGuarded((e) {
       _controller.addError(e);
       _controller.close();
     }), destroyed: () {
       _controller.close();
       if (_referencePort != null) {
         _referencePort.close();
         _referencePort = null;
       }
     });
     return _controller.stream.listen(onData,
@@ skipping 73 matching lines @@
           // The write event handler is automatically disabled by the
           // event handler when it fires.
           writeEventsEnabled = false;
           _controller.add(RawSocketEvent.WRITE);
         },
         closed: () => _controller.add(RawSocketEvent.READ_CLOSED),
         destroyed: () {
           _controller.add(RawSocketEvent.CLOSED);
           _controller.close();
         },
-        error: zone.bindUnaryCallback((e) {
+        error: zone.bindUnaryCallbackGuarded((e) {
           _controller.addError(e);
           _socket.close();
         }));
   }
 
   factory _RawSocket._writePipe() {
     var native = new _NativeSocket.pipe();
     native.isClosedRead = true;
     native.closedReadEventSent = true;
     return new _RawSocket(native);
@@ skipping 476 matching lines @@
           // The write event handler is automatically disabled by the
           // event handler when it fires.
           writeEventsEnabled = false;
           _controller.add(RawSocketEvent.WRITE);
         },
         closed: () => _controller.add(RawSocketEvent.READ_CLOSED),
         destroyed: () {
           _controller.add(RawSocketEvent.CLOSED);
           _controller.close();
         },
-        error: zone.bindUnaryCallback((e) {
+        error: zone.bindUnaryCallbackGuarded((e) {
           _controller.addError(e);
           _socket.close();
         }));
   }
 
   static Future<RawDatagramSocket> bind(host, int port, bool reuseAddress) {
     _throwOnBadPort(port);
     return _NativeSocket
         .bindDatagram(host, port, reuseAddress)
         .then((socket) => new _RawDatagramSocket(socket));
@@ skipping 81 matching lines @@
     } else {
       _socket.close();
     }
   }
 }
 
 Datagram _makeDatagram(
     List<int> data, String address, List<int> in_addr, int port) {
   return new Datagram(data, new _InternetAddress(address, null, in_addr), port);
 }