Renamed StreamSink to EventSink. Renamed signalError to addError.

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([String address = "127.0.0.1",
                                                    int port = 0,
                                                    int backlog = 0]) {
     return _RawServerSocket.bind(address, port, backlog);
   }
@@ skipping 416 matching lines @@
     _controller = new StreamController(
         onSubscriptionStateChange: _onSubscriptionStateChange,
         onPauseStateChange: _onPauseStateChange);
     _socket.closeFuture.then((_) => _controller.close());
     _socket.setHandlers(
       read: () {
         var socket = _socket.accept();
         if (socket != null) _controller.add(new _RawSocket(socket));
       },
       error: (e) {
-        _controller.signalError(new AsyncError(e));
+        _controller.addError(new AsyncError(e));
         _controller.close();
       }
     );
   }
 
   StreamSubscription<RawSocket> listen(void onData(RawSocket event),
                                        {void onError(AsyncError error),
                                         void onDone(),
                                         bool unsubscribeOnError}) {
     return _controller.stream.listen(
@@ skipping 52 matching lines @@
     _socket.setHandlers(
       read: () => _controller.add(RawSocketEvent.READ),
       write: () {
         // 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),
       error: (e) {
-        _controller.signalError(new AsyncError(e));
+        _controller.addError(new AsyncError(e));
         close();
       }
     );
   }
 
   factory _RawSocket._writePipe(int fd) {
     var native = new _NativeSocket.pipe();
     native.isClosedRead = true;
     if (fd != null) _getStdioHandle(native, fd);
     return new _RawSocket(native);
@@ skipping 335 matching lines @@
     if (!_controllerClosed) {
       _controllerClosed = true;
       _controller.close();
     }
     _done();
   }
 
   void _onError(error) {
     if (!_controllerClosed) {
       _controllerClosed = true;
-      _controller.signalError(error);
+      _controller.addError(error);
       _controller.close();
     }
     _done(error);
   }
 
   get _doneFuture {
     if (_doneCompleter == null) {
       _ensureRawSocketSubscription();
       _doneCompleter = new Completer();
     }
@@ skipping 45 matching lines @@
     _raw.onBadCertificate = callback;
   }
 
   X509Certificate get peerCertificate {
     if (_raw == null) {
      throw new StateError("peerCertificate called on destroyed SecureSocket");
     }
     return _raw.peerCertificate;
   }
 }