Merge IO v2 branch to bleeding edge

tests/standalone/io/file_output_stream_test.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.
 // Testing file input stream, VM-only, standalone test.
 
 import "dart:io";
 import "dart:isolate";
 
 void testOpenOutputStreamSync() {
   Directory tempDirectory = new Directory('').createTempSync();
 
   // Create a port for waiting on the final result of this test.
   ReceivePort done = new ReceivePort();
   done.receive((message, replyTo) {
     tempDirectory.deleteSync();
     done.close();
   });
 
   String fileName = "${tempDirectory.path}/test";
   File file = new File(fileName);
   file.createSync();
-  OutputStream x = file.openOutputStream();
-  x.write([65, 66, 67]);
-  Expect.isFalse(x.closed);
+  IOSink x = file.openWrite();
+  var data = [65, 66, 67];
+  x.add(data);
   x.close();
-  Expect.isTrue(x.closed);
-  x.onClosed = () {
-    Expect.isTrue(x.closed);
+  x.done.then((_) {
+    Expect.listEquals(file.readAsBytesSync(), data);
     file.deleteSync();
     done.toSendPort().send("done");
-  };
-}
-
-
-void testOutputStreamNoPendingWrite() {
-  var tempDirectory;
-
-  // Create a port for waiting on the final result of this test.
-  ReceivePort done = new ReceivePort();
-  done.receive((message, replyTo) {
-    tempDirectory.delete(recursive: true).then((ignore) => done.close());
-  });
-
-  new Directory('').createTemp().then((temp) {
-    tempDirectory = temp;
-    String fileName = "${tempDirectory.path}/test";
-    File file = new File(fileName);
-    file.create().then((ignore) {
-      OutputStream stream = file.openOutputStream();
-      final total = 100;
-      var count = 0;
-      stream.onNoPendingWrites = () {
-        stream.write([count++]);
-        if (count == total) {
-          stream.close();
-        }
-        stream.onClosed = () {
-          List buffer = new List<int>.fixedLength(total);
-          File fileSync = new File(fileName);
-          var openedFile = fileSync.openSync();
-          openedFile.readListSync(buffer, 0, total);
-          for (var i = 0; i < total; i++) {
-            Expect.equals(i, buffer[i]);
-          }
-          openedFile.closeSync();
-          fileSync.deleteSync();
-          done.toSendPort().send("done");
-        };
-      };
-    });
   });
 }
 
 
-void testOutputStreamFlush() {
-  Directory tempDirectory = new Directory('').createTempSync();
-
-  // Create a port for waiting on the final result of this test.
-  ReceivePort done = new ReceivePort();
-  done.receive((message, replyTo) {
-    tempDirectory.deleteSync();
-    done.close();
-  });
-
-  String fileName = "${tempDirectory.path}/test";
-  File file = new File(fileName);
-  file.createSync();
-  OutputStream x = file.openOutputStream();
-  x.write([65, 66, 67]);
-  x.flush();
-  x.write([68, 69, 70]);
-  x.flush();
-  x.write([71, 72, 73]);
-  x.onClosed = () {
-    file.deleteSync();
-    done.toSendPort().send("done");
-  };
-  x.close();
-  x.onError = (e) => Expect.fail("No error expected");
-}
-
 main() {
   testOpenOutputStreamSync();
-  testOutputStreamNoPendingWrite();
-  testOutputStreamFlush();
 }