Make FileInputStream and FileOutputStream actually asynchronous.

tests/standalone/src/StreamPipeTest.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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 #library("StreamPipeTest");
@@ skipping 141 matching lines @@
   void connectionHandler(Socket connection) {
     connection.errorHandler = () { Expect.fail("Socket error"); };
     connection.inputStream.pipe(connection.outputStream);
   }
 }
 
 
 // Test piping from one file to another and closing both streams
 // after wards.
 testFileToFilePipe1() {
+  // Force test to timeout if one of the handlers is
+  // not called.
+  ReceivePort donePort = new ReceivePort.singleShot();
+  donePort.receive((message, ignore) {});
+
   String srcFileName =
       getDataFilename("tests/standalone/src/readline_test1.dat");
   var srcStream = new File(srcFileName).openInputStreamSync();
 
   var tempDir = new Directory('');
   tempDir.createTempSync();
   String dstFileName = tempDir.path + "/readline_test1.dat";
   new File(dstFileName).createSync();
   var dstStream = new File(dstFileName).openOutputStreamSync();
 
-  srcStream.closeHandler = () {
+  dstStream.closeHandler = () {
     bool result = compareFileContent(srcFileName, dstFileName);
     new File(dstFileName).deleteSync();
     tempDir.deleteSync();
     Expect.isTrue(result);
+    donePort.toSendPort().send(null);
   };
 
   srcStream.pipe(dstStream);
 }
 
 
 // Test piping from one file to another and write additional data to
 // the output stream after piping finished.
 testFileToFilePipe2() {
+  // Force test to timeout if one of the handlers is
+  // not called.
+  ReceivePort donePort = new ReceivePort.singleShot();
+  donePort.receive((message, ignore) {});
+
   String srcFileName =
       getDataFilename("tests/standalone/src/readline_test1.dat");
   var srcFile = new File(srcFileName);
   var srcStream = srcFile.openInputStreamSync();
 
   var tempDir = new Directory('');
   tempDir.createTempSync();
   var dstFileName = tempDir.path + "/readline_test1.dat";
   var dstFile = new File(dstFileName);
   dstFile.createSync();
   var dstStream = dstFile.openOutputStreamSync();
 
   srcStream.closeHandler = () {
     dstStream.write([32]);
     dstStream.close();
-    var src = srcFile.openSync();
-    var dst = dstFile.openSync();
-    var srcLength = src.lengthSync();
-    var dstLength = dst.lengthSync();
-    Expect.equals(srcLength + 1, dstLength);
-    Expect.isTrue(compareFileContent(srcFileName,
-                                     dstFileName,
-                                     count: srcLength));
-    dst.setPositionSync(srcLength);
-    var data = new List<int>(1);
-    var read2 = dst.readListSync(data, 0, 1);
-    Expect.equals(32, data[0]);
-    src.closeSync();
-    dst.closeSync();
-    dstFile.deleteSync();
-    tempDir.deleteSync();
+    dstStream.closeHandler = () {
+      var src = srcFile.openSync();
+      var dst = dstFile.openSync();
+      var srcLength = src.lengthSync();
+      var dstLength = dst.lengthSync();
+      Expect.equals(srcLength + 1, dstLength);
+      Expect.isTrue(compareFileContent(srcFileName,
+                                       dstFileName,
+                                       count: srcLength));
+      dst.setPositionSync(srcLength);
+      var data = new List<int>(1);
+      var read2 = dst.readListSync(data, 0, 1);
+      Expect.equals(32, data[0]);
+      src.closeSync();
+      dst.closeSync();
+      dstFile.deleteSync();
+      tempDir.deleteSync();
+      donePort.toSendPort().send(null);
+    };
   };
 
   srcStream.pipe(dstStream, close: false);
 }
 
 
 // Test piping two copies of one file to another.
 testFileToFilePipe3() {
+  // Force test to timeout if one of the handlers is
+  // not called.
+  ReceivePort donePort = new ReceivePort.singleShot();
+  donePort.receive((message, ignore) {});
+
   String srcFileName =
       getDataFilename("tests/standalone/src/readline_test1.dat");
   var srcFile = new File(srcFileName);
   var srcStream = srcFile.openInputStreamSync();
 
   var tempDir = new Directory('');
   tempDir.createTempSync();
   var dstFileName = tempDir.path + "/readline_test1.dat";
   var dstFile = new File(dstFileName);
   dstFile.createSync();
   var dstStream = dstFile.openOutputStreamSync();
 
   srcStream.closeHandler = () {
     var srcStream2 = srcFile.openInputStreamSync();
 
-    srcStream2.closeHandler = () {
+    dstStream.closeHandler = () {
       var src = srcFile.openSync();
       var dst = dstFile.openSync();
       var srcLength = src.lengthSync();
       var dstLength = dst.lengthSync();
       Expect.equals(srcLength * 2, dstLength);
       Expect.isTrue(compareFileContent(srcFileName,
                                        dstFileName,
                                        count: srcLength));
       Expect.isTrue(compareFileContent(srcFileName,
                                        dstFileName,
                                        file2Offset: srcLength,
                                        count: srcLength));
       src.closeSync();
       dst.closeSync();
       dstFile.deleteSync();
       tempDir.deleteSync();
+      donePort.toSendPort().send(null);
     };
 
     // Pipe another copy of the source file.
     srcStream2.pipe(dstStream);
   };
 
   srcStream.pipe(dstStream, close: false);
 }
 
 
 main() {
   testFileToFilePipe1();
   testFileToFilePipe2();
   testFileToFilePipe3();
   PipeServerGame echoServerGame = new PipeServerGame.start();
 }