Update the streams interfaces

runtime/bin/file_impl.dart

 // Copyright (c) 2011, 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 implements FileInputStream {
+class _FileInputStream implements InputStream {
   _FileInputStream(File file) {
     _file = file;
   }
 
-  bool read(List<int> buffer, int offset, int len, void callback()) {
-    int bytesRead = _file.readList(buffer, offset, len);
-
-    if (bytesRead == len) {
-      if (callback != null) {
-        callback();
+  List<int> read([int len]) {
+    int bytesToRead = available();
+    if (bytesToRead == 0) {
+      return null;
+    }
+    if (len != null) {
+      if (len <= 0) {
+        throw new StreamException("Illegal length $len");
+      } else if (bytesToRead > len) {
+        bytesToRead = len;
       }
-      return true;
+    }
+    List<int> buffer = new List<int>(bytesToRead);
+    int bytesRead = _file.readList(buffer, 0, bytesToRead);
+    if (bytesRead < bytesToRead) {
+      List<int> newBuffer = new List<int>(bytesRead);
+      newBuffer.copyFrom(buffer, 0, 0, bytesRead);
+      return newBuffer;
     } else {
-      throw "FileInputStream: read error";
+      return buffer;
     }
   }
 
-  // TODO(srdjan): Reading whole file at once does not scale. Implement partial
-  // file reading and pattern checks.
-  void readUntil(List<int> pattern, void callback(List<int> buffer)) {
-    List<int> buffer = new List<int>(_file.length);
-    int result = _file.readList(buffer, 0, _file.length);
-    if (result > 0) {
-      int index = indexOf(buffer, pattern);
-      if (index != -1) {
-        int resultBufferSize = index + pattern.length;
-        List<int> resultBuffer = new List<int>(resultBufferSize);
-        resultBuffer.copyFrom(buffer, 0, 0, resultBufferSize);
-        callback(resultBuffer);
-      }
-    }
+  int readInto(List<int> buffer, int offset, int len) {
+    if (offset == null) offset = 0;
+    if (len == null) len = buffer.length;
+    if (offset < 0) throw new StreamException("Illegal offset $offset");
+    if (len < 0) throw new StreamException("Illegal length $len");
+    return _file.readList(buffer, offset, len);
   }
 
-  // TODO(srdjan: move this method to Lists.dart (helper method).
-  static int indexOf(List<int> buffer, List<int> pattern) {
-    if (pattern.length == 0) {
-      return buffer.length;
-    }
-    int len = buffer.length - pattern.length + 1;
-    for (int index = 0; index < len; index++) {
-      bool match = true;
-      for (int k = 0; k < pattern.length; k++) {
-        if (buffer[index + k] != pattern[k]) {
-          match = false;
-          break;
-        }
-      }
-      if (match) {
-        return index;
-      }
-    }
-    return -1;
+  int available() {
+    return _file.length - _file.position;
+  }
+
+  bool closed() {
+    _file.position == _file.length;
+  }
+
+  void set dataHandler(void callback()) {
+    // TODO(sgjesse): How to handle this?
+  }
+
+  void set closeHandler(void callback()) {
+    // TODO(sgjesse): How to handle this?
+  }
+
+  void set errorHandler(void callback()) {
+    // TODO(sgjesse): How to handle this?
   }
 
   File _file;
 }
 
-class _FileOutputStream implements FileOutputStream {
+
+class _FileOutputStream implements OutputStream {
   _FileOutputStream(File file) {
     _file = file;
   }
 
   bool write(List<int> buffer, int offset, int len, void callback()) {
     int bytesWritten = _file.writeList(buffer, offset, len);
 
     if (bytesWritten == len) {
       return true;
     } else {
       throw "FileOutputStream: write error";
     }
   }
 
   File _file;
 }
 
+
 // Class for encapsulating the native implementation of files.
 class _File extends FileNativeWrapper implements File {
   // Constructor for file.
   factory _File(String name, bool writable) {
     _File file = new _File._internal();
     if (!file._openFile(name, writable)) {
       return null;
     }
     file._writeable = writable;
     return file;
@@ skipping 99 matching lines @@
   void flush() {
     int result = _flush();
     if (result == -1) {
       throw new FileIOException("Error: flush failed");
     }
   }
   int _flush() native "File_Flush";
 
   // Each file has an unique InputStream.
   InputStream get inputStream() {
-    if (_inputStream === null) {
-      _inputStream = new FileInputStream(this);
+    if (_inputStream == null) {
+      _inputStream = new _FileInputStream(this);
     }
     return _inputStream;
   }
 
   // Each file has an unique OutputStream.
   OutputStream get outputStream() {
     if (!_writeable) {
       throw "File is not writable";
     }
-    if (_outputStream === null) {
-      _outputStream = new FileOutputStream(this);
+    if (_outputStream == null) {
+      _outputStream = new _FileOutputStream(this);
     }
     return _outputStream;
   }
 
   // Set of native methods used to provide file functionality.
   static bool fileExists(String name) native "File_Exists";
 
   bool _writeable;
   InputStream _inputStream;
   OutputStream _outputStream;
 }