Update dart:io tests to use asyncStart/asyncEnd

tests/standalone/io/stream_pipe_test.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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
-library ServerTest;
 
+import "dart:io";
+
+import "package:async_helper/async_helper.dart";
 import "package:expect/expect.dart";
-import "dart:io";
-import "dart:isolate";
 
 // Helper method to be able to run the test from the runtime
 // directory, or the top directory.
 String getDataFilename(String path) =>
     new File(path).existsSync() ? path : '../$path';
 
 
 bool compareFileContent(String fileName1,
                         String fileName2,
                         {int file1Offset: 0,
@@ skipping 30 matching lines @@
   file2.closeSync();
   return true;
 }
 
 
 // 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();
-  donePort.receive((message, ignore) { donePort.close(); });
+  asyncStart();
 
   String srcFileName =
       getDataFilename("tests/standalone/io/readline_test1.dat");
   var srcStream = new File(srcFileName).openRead();
 
   var tempDir = new Directory('').createTempSync();
   String dstFileName = tempDir.path + "/readline_test1.dat";
   new File(dstFileName).createSync();
   var output = new File(dstFileName).openWrite();
   srcStream.pipe(output).then((_) {
     bool result = compareFileContent(srcFileName, dstFileName);
     new File(dstFileName).deleteSync();
     tempDir.deleteSync();
     Expect.isTrue(result);
-    donePort.toSendPort().send(null);
+    asyncEnd();
   });
 }
 
 
 // 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();
-  donePort.receive((message, ignore) { donePort.close(); });
+  asyncStart();
 
   String srcFileName =
       getDataFilename("tests/standalone/io/readline_test1.dat");
   var srcFile = new File(srcFileName);
   var srcStream = srcFile.openRead();
 
   var tempDir = new Directory('').createTempSync();
   var dstFileName = tempDir.path + "/readline_test1.dat";
   var dstFile = new File(dstFileName);
   dstFile.createSync();
@@ skipping 11 matching lines @@
                                        dstFileName,
                                        count: srcLength));
       dst.setPositionSync(srcLength);
       var data = new List<int>(1);
       var read2 = dst.readIntoSync(data, 0, 1);
       Expect.equals(32, data[0]);
       src.closeSync();
       dst.closeSync();
       dstFile.deleteSync();
       tempDir.deleteSync();
-      donePort.toSendPort().send(null);
+      asyncEnd();
     });
   });
 }
 
 
 // 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();
-  donePort.receive((message, ignore) { donePort.close(); });
+  asyncStart();
 
   String srcFileName =
       getDataFilename("tests/standalone/io/readline_test1.dat");
   var srcFile = new File(srcFileName);
   var srcStream = srcFile.openRead();
 
   var tempDir = new Directory('').createTempSync();
   var dstFileName = tempDir.path + "/readline_test1.dat";
   var dstFile = new File(dstFileName);
   dstFile.createSync();
@@ skipping 12 matching lines @@
                                          dstFileName,
                                          count: srcLength));
         Expect.isTrue(compareFileContent(srcFileName,
                                          dstFileName,
                                          file2Offset: srcLength,
                                          count: srcLength));
         src.closeSync();
         dst.closeSync();
         dstFile.deleteSync();
         tempDir.deleteSync();
-        donePort.toSendPort().send(null);
+        asyncEnd();
       });
     });
   });
 }
 
 
 main() {
   testFileToFilePipe1();
   testFileToFilePipe2();
   testFileToFilePipe3();
 }