Add a flush operations to IOSink

sdk/lib/io/file_impl.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.
 
 part of dart.io;
 
 // Read the file in blocks of size 64k.
 const int _BLOCK_SIZE = 64 * 1024;
 
 
@@ skipping 188 matching lines @@
       })
       .catchError((e) {
         completer.completeError(e);
       });
     return completer.future;
   }
 
   Future<File> close() {
     return _openFuture.then((openedFile) => openedFile.close());
   }
+
+  Future flush() {
+    return _openFuture
+        .then((openedFile) => openedFile.flush())
+        .then((randomAccessfile) => new Future.value(null));
+  }
 }
 
 
 // Class for encapsulating the native implementation of files.
 class _File extends FileSystemEntity implements File {
   final String path;
 
   // Constructor for file.
   _File(String this.path) {
     if (path is! String) {
@@ skipping 256 matching lines @@
     return readAsBytes().then((bytes) {
       return _decodeLines(bytes, encoding);
     });
   }
 
   List<String> readAsLinesSync({Encoding encoding: UTF8}) {
     return _decodeLines(readAsBytesSync(), encoding);
   }
 
   Future<File> writeAsBytes(List<int> bytes,
-                            {FileMode mode: FileMode.WRITE}) {
+                            {FileMode mode: FileMode.WRITE,
+                             bool flush: false}) {
     try {
       IOSink sink = openWrite(mode: mode);
       sink.add(bytes);
-      sink.close();
+      if (flush) {
+        sink.flush().then((_) => sink.close());
+      } else {
+        sink.close();
+      }
       return sink.done.then((_) => this);
     } catch (e) {
       return new Future.error(e);
     }
   }
 
-  void writeAsBytesSync(List<int> bytes, {FileMode mode: FileMode.WRITE}) {
+  void writeAsBytesSync(List<int> bytes,
+                        {FileMode mode: FileMode.WRITE,
+                         bool flush: false}) {
     RandomAccessFile opened = openSync(mode: mode);
     opened.writeFromSync(bytes, 0, bytes.length);
+    if (flush) opened.flushSync();
     opened.closeSync();
   }
 
   Future<File> writeAsString(String contents,
                              {FileMode mode: FileMode.WRITE,
-                              Encoding encoding: UTF8}) {
+                              Encoding encoding: UTF8,
+                              bool flush: false}) {
     try {
       return writeAsBytes(encoding.encode(contents), mode: mode);
     } catch (e) {
       return new Future.error(e);
     }
   }
 
   void writeAsStringSync(String contents,
                          {FileMode mode: FileMode.WRITE,
-                          Encoding encoding: UTF8}) {
+                          Encoding encoding: UTF8,
+                          bool flush: false}) {
     writeAsBytesSync(encoding.encode(contents), mode: mode);
   }
 
   String toString() => "File: '$path'";
 
   static throwIfError(Object result, String msg, String path) {
     if (result is OSError) {
       throw new FileSystemException(msg, path, result);
     }
   }
@@ skipping 342 matching lines @@
 
   void _checkAvailable() {
     if (_asyncDispatched) {
       throw new FileSystemException("An async operation is currently pending", path);
     }
     if (closed) {
       throw new FileSystemException("File closed", path);
     }
   }
 }