Renamed StreamSink to EventSink. Renamed signalError to addError.

sdk/lib/io/http_parser.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.
 
 part of dart.io;
 
 // Global constants.
 class _Const {
   // Bytes for "HTTP".
   static const HTTP = const [72, 84, 84, 80];
@@ skipping 100 matching lines @@
     if (subscription == null) {
       // Socket was already closed.
       if (carryOverData != null) controller.add(carryOverData);
       controller.close();
     } else {
       pause();
       if (oldResumeCompleter != null) oldResumeCompleter.complete();
       subscription.resume();
       subscription.onData(controller.add);
       subscription.onDone(controller.close);
-      subscription.onError(controller.signalError);
+      subscription.onError(controller.addError);
     }
   }
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {void onError(AsyncError error),
                                         void onDone(),
                                         bool unsubscribeOnError}) {
     return controller.stream.listen(
         onData,
         onError: onError,
@@ skipping 569 matching lines @@
 
   void _onDone() {
     // onDone cancles the subscription.
     _socketSubscription = null;
     if (_state == _State.CLOSED || _state == _State.FAILURE) return;
 
     if (_incoming != null) {
       if (_state != _State.UPGRADED &&
           !(_state == _State.START && !_requestParser) &&
           !(_state == _State.BODY && !_chunked && _transferLength == -1)) {
-        _bodyController.signalError(
+        _bodyController.addError(
             new AsyncError(
                 new HttpParserException(
                     "Connection closed while receiving data")));
       }
       _closeIncoming();
       _controller.close();
       return;
     }
     // If the connection is idle the HTTP stream is closed.
     if (_state == _State.START) {
@@ skipping 32 matching lines @@
       // throw the error.
       error(
           new AsyncError(
               new HttpParserException(
                   "Connection closed before full body was received")));
     }
     _controller.close();
   }
 
   void _onError(e) {
-    _controller.signalError(e);
+    _controller.addError(e);
   }
 
   String get version {
     switch (_httpVersion) {
       case _HttpVersion.HTTP10:
         return "1.0";
       case _HttpVersion.HTTP11:
         return "1.1";
     }
     return null;
@@ skipping 147 matching lines @@
         _continueParsing();
       } else {
         _pauseParsing();
       }
     }
   }
 
   void error(error) {
     if (_socketSubscription != null) _socketSubscription.cancel();
     _state = _State.FAILURE;
-    _controller.signalError(error);
+    _controller.addError(error);
     _controller.close();
   }
 
   // State.
   bool _parserCalled = false;
 
   // The data that is currently being parsed.
   List<int> _buffer;
   int _index;
 
@@ skipping 27 matching lines @@
   StreamController<_HttpIncoming> _controller;
   StreamController<List<int>> _bodyController;
 }
 
 
 class HttpParserException implements Exception {
   const HttpParserException([String this.message = ""]);
   String toString() => "HttpParserException: $message";
   final String message;
 }