Handle addError on a WebSocket

tests/standalone/io/web_socket_error_test.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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 library dart.io;
@@ skipping 76 matching lines @@
                 closeCount++;
                 if (closeCount == totalConnections) {
                   server.close();
                 }
               });
           });
       }
     });
   }
 
+  void testAddErrorServer() {
+    asyncStart();
+    asyncStart();
+    asyncStart();
+    asyncStart();
+    createServer().then((server) {
+      server.transform(new WebSocketTransformer()).listen((webSocket) {
+        webSocket.listen(
+            (message) {
+              webSocket.addError("ERROR");
+            },
+            onDone: () {
+              Expect.equals(WebSocketStatus.ABNORMAL_CLOSURE,
+                            webSocket.closeCode);
+              server.close();
+            },
+            onError: (e) {
+              Expect.equals("ERROR", e);
+              asyncEnd();
+            });
+
+        webSocket.done.then((_) {
+          Expect.fail("unexpected done completion");
+        }).catchError((e) {
+          Expect.equals("ERROR", e);
+          asyncEnd();
+        });
+        }, onDone: () {
+          asyncEnd();
+        });
+
+      createClient(server.port).then((webSocket) {
+        webSocket.add("message");
+        webSocket.listen(
+            (message) {
+              Expect.fail("unexpected message");
+            },
+            onDone: () {
+              Expect.equals(WebSocketStatus.ABNORMAL_CLOSURE,
+                            webSocket.closeCode);
+              server.close();
+              asyncEnd();
+            },
+            onError: (e) {
+              Expect.fail("unexpected onError");
+            });
+
+      });
+    });
+  }
+
+  void testAddErrorClient() {
+    asyncStart();
+    asyncStart();
+    asyncStart();
+    asyncStart();
+    createServer().then((server) {
+      server.transform(new WebSocketTransformer()).listen((webSocket) {
+        webSocket.listen(
+            (message) {
+              Expect.fail("unexpected message");
+            },
+            onDone: () {
+              Expect.equals(WebSocketStatus.ABNORMAL_CLOSURE,
+                            webSocket.closeCode);
+              asyncEnd();
+            });
+        }, onDone: () {
+          asyncEnd();
+        });
+
+      createClient(server.port).then((webSocket) {
+        webSocket.addError("ERROR");
+        webSocket.listen(
+            (message) {
+              Expect.fail("unexpected message");
+            },
+            onDone: () {
+              Expect.equals(WebSocketStatus.ABNORMAL_CLOSURE,
+                            webSocket.closeCode);
+              server.close();
+            },
+            onError: (e) {
+              Expect.equals("ERROR", e);
+              asyncEnd();
+            });
+
+        webSocket.done.then((_) {
+          Expect.fail("unexpected done completion");
+        }).catchError((e) {
+          Expect.equals("ERROR", e);
+          asyncEnd();
+        });
+      });
+    });
+  }
+
   void runTests() {
     testForceCloseServerEnd(10);
+    testAddErrorServer();
+    testAddErrorClient();
   }
 }
 
 
 main() {
   asyncStart();
   new SecurityConfiguration(secure: false).runTests();
   // TODO(whesse): WebSocket.connect needs an optional context: parameter
   // new SecurityConfiguration(secure: true).runTests();
   asyncEnd();
 }