Remove AsyncError with Expando.

sdk/lib/io/secure_socket.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;
 
 /**
  * A high-level class for communicating securely over a TCP socket, using
  * TLS and SSL. The [SecureSocket] exposes both a [Stream] and an
  * [IOSink] interface, making it ideal for using together with
@@ skipping 270 matching lines @@
       _status = HANDSHAKE;
       _secureHandshake();
     })
     .catchError((error) {
       _handshakeComplete.completeError(error);
       _close();
     });
   }
 
   StreamSubscription listen(void onData(RawSocketEvent data),
-                            {void onError(AsyncError error),
+                            {void onError(error),
                              void onDone(),
                              bool unsubscribeOnError}) {
     if (_writeEventsEnabled) {
       _writeEventsEnabled = false;
       _controller.add(RawSocketEvent.WRITE);
     }
     return _stream.listen(onData,
                           onError: onError,
                           onDone: onDone,
                           unsubscribeOnError: unsubscribeOnError);
@@ skipping 155 matching lines @@
     }
 
     return result;
   }
 
   // Write the data to the socket, and flush it as much as possible
   // until it would block.  If the write would block, _writeEncryptedData sets
   // up handlers to flush the pipeline when possible.
   int write(List<int> data, [int offset, int bytes]) {
     if (_closedWrite) {
-      _controller.addError(new AsyncError(new SocketIOException(
-          "Writing to a closed socket")));
+      _controller.addError(new SocketIOException("Writing to a closed socket"));
       return 0;
     }
     if (_status != CONNECTED) return 0;
 
     if (offset == null) offset = 0;
     if (bytes == null) bytes = data.length - offset;
 
     var buffer = _secureFilter.buffers[WRITE_PLAINTEXT];
     if (bytes > buffer.free) {
       bytes = buffer.free;
@@ skipping 81 matching lines @@
   void _doneHandler() {
     if (_filterReadEmpty) {
       _close();
     }
   }
 
   void _errorHandler(e) {
     _reportError(e, 'Error on underlying RawSocket');
   }
 
-  void _reportError(error, String message) {
+  void _reportError(e, String message) {
     // TODO(whesse): Call _reportError from all internal functions that throw.
-    var e;
-    if (error is AsyncError) {
-      e = error;
-    } else if (error is SocketIOException) {
+    if (e is SocketIOException) {
       e = new SocketIOException('$message (${error.message})', error.osError);
     } else if (error is OSError) {
       e = new SocketIOException(message, error);
     } else {
       e = new SocketIOException('$message (${error.toString()})', null);
     }
     if (_connectPending) {
       _handshakeComplete.completeError(e);
     } else {
       _controller.addError(e);
@@ skipping 171 matching lines @@
   void destroy();
   void handshake();
   void init();
   X509Certificate get peerCertificate;
   int processBuffer(int bufferIndex);
   void registerBadCertificateCallback(Function callback);
   void registerHandshakeCompleteCallback(Function handshakeCompleteHandler);
 
   List<_ExternalBuffer> get buffers;
 }