Remove AsyncError with Expando.

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 105 matching lines @@
       pause();
       if (oldResumeCompleter != null) oldResumeCompleter.complete();
       subscription.resume();
       subscription.onData(controller.add);
       subscription.onDone(controller.close);
       subscription.onError(controller.addError);
     }
   }
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
-                                       {void onError(AsyncError error),
+                                       {void onError(error),
                                         void onDone(),
                                         bool unsubscribeOnError}) {
     return controller.stream.listen(
         onData,
         onError: onError,
         onDone: onDone,
         unsubscribeOnError: unsubscribeOnError);
   }
 
   void resume() {
@@ skipping 72 matching lines @@
 
   _HttpParser._(this._requestParser) {
     _controller = new StreamController<_HttpIncoming>(
           onSubscriptionStateChange: _updateParsePauseState,
           onPauseStateChange: _updateParsePauseState);
     _reset();
   }
 
 
   StreamSubscription<_HttpIncoming> listen(void onData(_HttpIncoming event),
-                                           {void onError(AsyncError error),
+                                           {void onError(error),
                                             void onDone(),
                                             bool unsubscribeOnError}) {
     return _controller.stream.listen(onData,
                                      onError: onError,
                                      onDone: onDone,
                                      unsubscribeOnError: unsubscribeOnError);
   }
 
   Future<_HttpParser> addStream(Stream<List<int>> stream) {
     // Listen to the stream and handle data accordingly. When a
@@ skipping 444 matching lines @@
             break;
 
           default:
             // Should be unreachable.
             assert(false);
             break;
         }
       }
     } catch (e, s) {
       _state = _State.FAILURE;
-      error(new AsyncError(e, s));
+      error(e, s);
     }
 
     _parserCalled = false;
     if (_buffer != null && _index == _buffer.length) {
       // If all data is parsed release the buffer and resume receiving
       // data.
       _releaseBuffer();
       if (_state != _State.UPGRADED && _state != _State.FAILURE) {
         _socketSubscription.resume();
       }
@@ skipping 11 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.addError(
-            new AsyncError(
-                new HttpParserException(
-                    "Connection closed while receiving data")));
+              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) {
       if (!_requestParser) {
-        error(
-            new AsyncError(
-                new HttpParserException(
-                    "Connection closed before full header was received")));
+        error(new HttpParserException(
+                    "Connection closed before full header was received"));
       }
       _controller.close();
       return;
     }
 
     if (_state == _State.UPGRADED) {
       _controller.close();
       return;
     }
 
     if (_state < _State.FIRST_BODY_STATE) {
       _state = _State.FAILURE;
       // Report the error through the error callback if any. Otherwise
       // throw the error.
-      error(
-          new AsyncError(
-              new HttpParserException(
-                  "Connection closed before full header was received")));
+      error(new HttpParserException(
+                  "Connection closed before full header was received"));
       _controller.close();
       return;
     }
 
     if (!_chunked && _transferLength == -1) {
       _state = _State.CLOSED;
     } else {
       _state = _State.FAILURE;
       // Report the error through the error callback if any. Otherwise
       // throw the error.
-      error(
-          new AsyncError(
-              new HttpParserException(
-                  "Connection closed before full body was received")));
+      error(new HttpParserException(
+                  "Connection closed before full body was received"));
     }
     _controller.close();
   }
 
   void _onError(e) {
     _controller.addError(e);
   }
 
   String get version {
     switch (_httpVersion) {
@@ skipping 151 matching lines @@
       }
     } else {
       if (_controller.hasListener && !_controller.isPaused) {
         _continueParsing();
       } else {
         _pauseParsing();
       }
     }
   }
 
-  void error(error) {
+  void error(error, [stackTrace]) {
     if (_socketSubscription != null) _socketSubscription.cancel();
     _state = _State.FAILURE;
-    _controller.addError(error);
+    _controller.addError(error, stackTrace);
     _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;
 }