Add an OutputStream.closed getter.

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)
       : _data = const [],
         _position = 0,
         _filePosition = 0 {
     var file = new File(name);
@@ skipping 196 matching lines @@
   }
 
 
   void flush() {
     if (_file == null) {
       _pendingOperations.add(_PendingOperation.FLUSH);
     } else {
       _file.flush().then((ignored) => null);
     }
   }
 

[Bill Hesse, 2012/08/08 14:21:11]

This will all need some work if we want writes after close() to throw
exceptions, instead of calling onError, but it is working as it was previously
this way, so OK.

 
   void close() {
+    _streamMarkedClosed = true;
     if (_file == null) {
       _pendingOperations.add(_PendingOperation.CLOSE);
-    } else if (!_streamMarkedClosed) {
+    } else if (!_closeCallbackCalled) {

[Bill Hesse, 2012/08/08 14:21:11]

Call this _closeCallbackScheduled.

[nweiz, 2012/08/09 19:39:52]

Done.

       _file.close().then((ignore) {
         if (_onClosed != null) _onClosed();
       });
-      _streamMarkedClosed = true;
+      _closeCallbackCalled = true;
     }
   }
 
   void set onNoPendingWrites(void callback()) {
     _onNoPendingWrites = callback;
     if (((_pendingOperations == null) || (_pendingOperations.length == 0)) &&
         (outstandingWrites == 0) &&
         !_streamMarkedClosed &&
         (_onNoPendingWrites != null)) {
       new Timer(0, (t) {
@@ skipping 24 matching lines @@
     _pendingOperations = null;
   }
 
   void _write(List<int> buffer, int offset, int len) {
     outstandingWrites++;
     var writeListFuture = _file.writeList(buffer, offset, len);
     writeListFuture.then((ignore) {
         outstandingWrites--;
         if ((outstandingWrites == 0) &&
             !_streamMarkedClosed &&
             (_onNoPendingWrites != null)) {

[Bill Hesse, 2012/08/08 14:21:11]

Extra parentheses.

[nweiz, 2012/08/09 19:39:52]

Done.

           _onNoPendingWrites();
         }
     });
     writeListFuture.handleException((e) {
       outstandingWrites--;
       _reportError(e);
       return true;
     });
   }
 
+  bool get closed() => _streamMarkedClosed;
+
   RandomAccessFile _file;
 
   // When this is set to true the stream is marked closed. When a
   // stream is marked closed no more data can be written.
   bool _streamMarkedClosed = false;
 
   // When this is set to true the close callback has been called and

[Bill Hesse, 2012/08/08 14:21:11]

Change the comment and the name to closeCallbackScheduled.

[nweiz, 2012/08/09 19:39:52]

Done.

   // the stream is fully closed.
   bool _closeCallbackCalled = false;
 
   // Number of writes that have not yet completed.
   int outstandingWrites = 0;
 
   // List of pending writes that were issued before the underlying
   // file was successfully opened.
   List _pendingOperations;
 
@@ skipping 859 matching lines @@
           new FileIOException("File closed '$_name'"));
     });
     return completer.future;
   }
 
   final String _name;
   int _id;
 
   SendPort _fileService;
 }