Add error handling to socket streams

runtime/bin/file_impl.dart

 // Copyright (c) 2012, 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.
 
 class _FileInputStream extends _BaseDataInputStream implements InputStream {
   _FileInputStream(String name) {
     _file = new File(name);
     _data = [];
     _position = 0;
     _file.onError = (e) {
       if (_clientErrorHandler != null) {
-        _clientErrorHandler();
+        _clientErrorHandler(e);
       }
     };
     _file.open(FileMode.READ, (openedFile) {
       _readDataFromFile(openedFile);
     });
   }
 
   _FileInputStream.fromStdio(int fd) {
     assert(fd == 0);
     _file = _File._openStdioSync(fd);
     _data = [];
     _position = 0;
     _readDataFromFile(_file);
   }
 
   void _readDataFromFile(RandomAccessFile openedFile) {
     openedFile.onError = (e) {
       if (_clientErrorHandler != null) {
-        _clientErrorHandler();
+        _clientErrorHandler(e);
       }
     };
     openedFile.length((length) {
       var contents = new ByteArray(length);
       if (length != 0) {
         openedFile.readList(contents, 0, length, (read) {
           if (read != length) {
             if (_clientErrorHandler != null) {
               _clientErrorHandler();
             }
@@ skipping 52 matching lines @@
 class _FileOutputStream extends _BaseOutputStream implements OutputStream {
   _FileOutputStream(String name, FileMode mode) {
     _pendingOperations = new List<List<int>>();
     var f = new File(name);
     f.open(mode, (openedFile) {
       _file = openedFile;
       _setupFileHandlers();
       _processPendingOperations();
     });
     f.onError = (e) {
-      if (_onError != null) _onError();
+      if (_onError != null) _onError(e);
     };
   }
 
   _FileOutputStream.fromStdio(int fd) {
     assert(1 <= fd && fd <= 2);
     _file = _File._openStdioSync(fd);
     _setupFileHandlers();
   }
 
 
   void _setupFileHandlers() {
     _file.onError = (e) {
-      if (_onError != null) _onError();
+      if (_onError != null) _onError(e);
     };
     _file.onNoPendingWrites = () {
       if (!_streamMarkedClosed && _onNoPendingWrites != null) {
         _onNoPendingWrites();
       }
     };
   }
 
   bool write(List<int> buffer, [bool copyBuffer = false]) {
     var data = buffer;
@@ skipping 34 matching lines @@
   }
 
   void set onNoPendingWrites(void callback()) {
     _onNoPendingWrites = callback;
   }
 
   void set onClosed(void callback()) {
     _onClosed = callback;
   }
 
-  void set onError(void callback()) {
+  void set onError(void callback(Exception e)) {
     _onError = callback;
   }
 
   void _processPendingOperations() {
     _pendingOperations.forEach((buffer) {
       (buffer != null) ? write(buffer) : close();
     });
     _pendingOperations = null;
   }
 
@@ skipping 370 matching lines @@
     _asyncUsed = true;
     var chunks = new _BufferList();
     var stream = openInputStream();
     stream.onClosed = () {
       callback(chunks.readBytes(chunks.length));
     };
     stream.onData = () {
       var chunk = stream.read();
       chunks.add(chunk);
     };
-    stream.onError = () {
+    stream.onError = (e) {
       if (_onError != null) {
-        _onError("Failed to read file");
+        _onError(e);
       }
     };
   }
 
   List<int> readAsBytesSync() {
     if (_asyncUsed) {
       throw new FileIOException(
           "Mixed use of synchronous and asynchronous API");
     }
     var opened = openSync();
     var length = opened.lengthSync();
     var result = new ByteArray(length);
     var read = opened.readListSync(result, 0, length);
     if (read != length) {
       throw new FileIOException("Failed to read file");
     }
     opened.closeSync();
     return result;
   }
 
   void readAsText(Encoding encoding, void callback(String text)) {
     _asyncUsed = true;
     var decoder = _StringDecoders.decoder(encoding);
     readAsBytes((bytes) {
       try {
         decoder.write(bytes);
       } catch (var e) {
         if (_onError != null) {
-          _onError(e.toString());
+          _onError(e);
           return;
         }
       }
       callback(decoder.decoded);
     });
   }
 
   String readAsTextSync([Encoding encoding = Encoding.UTF_8]) {
     if (_asyncUsed) {
       throw new FileIOException(
@@ skipping 22 matching lines @@
   }
 
   void readAsLines(Encoding encoding, void callback(List<String> lines)) {
     _asyncUsed = true;
     var decoder = _StringDecoders.decoder(encoding);
     readAsBytes((bytes) {
       try {
         decoder.write(bytes);
       } catch (var e) {
         if (_onError != null) {
-          _onError(e.toString());
+          _onError(e);
           return;
         }
       }
       callback(_getDecodedLines(decoder));
     });
   }
 
   List<String> readAsLinesSync([Encoding encoding = Encoding.UTF_8]) {
     if (_asyncUsed) {
       throw new FileIOException(
@@ skipping 450 matching lines @@
   bool _asyncUsed;
   int _pendingWrites = 0;
 
   SendPort _fileService;
 
   Timer _noPendingWriteTimer;
 
   Function _onNoPendingWrites;
   Function _onError;
 }