Make FileInputStream and FileOutputStream actually asynchronous.

runtime/bin/chunked_stream.dart

-// Copyright (c) 2011, the Dart project authors.  Please see the AUTHORS file
+// 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 _ChunkedInputStream implements ChunkedInputStream {
   _ChunkedInputStream(InputStream this._input, [int chunkSize])
       : _chunkSize = chunkSize, _bufferList = new _BufferList() {
     if (_chunkSize === null) {
       _chunkSize = 0;
     }
     _input.closeHandler = _closeHandler;
@@ skipping 91 matching lines @@
 
     void issueCloseCallback(Timer timer) {
       _scheduledCloseCallback = null;
       if (!_closed) {
         if (_clientCloseHandler !== null) _clientCloseHandler();
         _closed = true;
       }
     }
 
     // Schedule data callback if enough data in buffer.
-    if ((_bufferList.length >=_chunkSize ||
+    if ((_bufferList.length >= _chunkSize ||
          (_bufferList.length > 0 && _inputClosed)) &&
         _clientDataHandler !== null &&
         _scheduledDataCallback == null) {
       _scheduledDataCallback = new Timer(issueDataCallback, 0);
     }
 
     // Schedule close callback if no more data and input is closed.
     if (_bufferList.length == 0 &&
         _inputClosed &&
         !_closed &&
         _scheduledCloseCallback == null) {
+      if (_scheduledDataCallback != null) {

[Søren Gjesse, 2012/02/28 07:40:25]

Woops!

+        _scheduledDataCallback.cancel();
+      }
       _scheduledCloseCallback = new Timer(issueCloseCallback, 0);
     }
   }
 
   InputStream _input;
   _BufferList _bufferList;
   int _chunkSize;
   bool _inputClosed = false;  // Is the underlying input stream closed?
   bool _closed = false;  // Has the close handler been called?.
   Timer _scheduledDataCallback;
   Timer _scheduledCloseCallback;
   Function _clientDataHandler;
   Function _clientCloseHandler;
 }