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 178 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));
+  }
 }
 
 
 const int _EXISTS_REQUEST = 0;
 const int _CREATE_REQUEST = 1;
 const int _DELETE_REQUEST = 2;
 const int _RENAME_REQUEST = 3;
 const int _OPEN_REQUEST = 4;
 const int _FULL_PATH_REQUEST = 5;
 const int _CLOSE_REQUEST = 6;
@@ skipping 324 matching lines @@
     return readAsBytes().then((bytes) {
       return _decodeLines(bytes, encoding);
     });
   }
 
   List<String> readAsLinesSync({Encoding encoding: Encoding.UTF_8}) {
     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: Encoding.UTF_8}) {
+                              Encoding encoding: Encoding.UTF_8,
+                              bool flush: false}) {
     try {
-      return writeAsBytes(_encodeString(contents, encoding), mode: mode);
+      return writeAsBytes(
+          _encodeString(contents, encoding), mode: mode, flush: flush);
     } catch (e) {
       return new Future.error(e);
     }
   }
 
   void writeAsStringSync(String contents,
                          {FileMode mode: FileMode.WRITE,
-                          Encoding encoding: Encoding.UTF_8}) {
-    writeAsBytesSync(_encodeString(contents, encoding), mode: mode);
+                          Encoding encoding: Encoding.UTF_8,
+                          bool flush: false}) {
+    writeAsBytesSync(
+        _encodeString(contents, encoding), mode: mode, flush: flush);
   }
 
   String get path => _path;
 
   String toString() => "File: '$path'";
 
   void _ensureFileService() {
     if (_fileService == null) {
       _fileService = _FileUtils._newServicePort();
     }
@@ skipping 402 matching lines @@
 
   Future _closedException() {
     return new Future.error(new FileException("File closed", _path));
   }
 
   final String _path;
   int _id;
 
   SendPort _fileService;
 }