Update dart:io tests to use asyncStart/asyncEnd

tests/standalone/io/raw_secure_server_socket_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
 
+import "dart:async";
+import "dart:io";
+
+import "package:async_helper/async_helper.dart";
 import "package:expect/expect.dart";
 import "package:path/path.dart";
-import "dart:async";
-import "dart:io";
-import "dart:isolate";
 
 const HOST_NAME = "localhost";
 const CERTIFICATE = "localhost_cert";
 
 void testSimpleBind() {
-  ReceivePort port = new ReceivePort();
+  asyncStart();
   RawSecureServerSocket.bind(HOST_NAME, 0, CERTIFICATE).then((s) {
     Expect.isTrue(s.port > 0);
     s.close();
-    port.close();
+    asyncEnd();
   });
 }
 
 void testInvalidBind() {
   int count = 0;
-  ReceivePort port = new ReceivePort();
-  port.receive((_, __) { count++; if (count == 3) port.close(); });
 
   // Bind to a unknown DNS name.
+  asyncStart();
   RawSecureServerSocket.bind("ko.faar.__hest__", 0, CERTIFICATE).then((_) {
     Expect.fail("Failure expected");
   }).catchError((error) {
     Expect.isTrue(error is SocketException);
-    port.toSendPort().send(1);
+    asyncEnd();
   });
 
   // Bind to an unavaliable IP-address.
+  asyncStart();
   RawSecureServerSocket.bind("8.8.8.8", 0, CERTIFICATE).then((_) {
     Expect.fail("Failure expected");
   }).catchError((error) {
     Expect.isTrue(error is SocketException);
-    port.toSendPort().send(1);
+    asyncEnd();
   });
 
   // Bind to a port already in use.
+  asyncStart();
   RawSecureServerSocket.bind(HOST_NAME, 0, CERTIFICATE).then((s) {
     RawSecureServerSocket.bind(HOST_NAME,
                                s.port,
                                CERTIFICATE).then((t) {
       Expect.fail("Multiple listens on same port");
       s.close();
       t.close();
       port.toSendPort().send(1);
     })
     .catchError((error) {
       Expect.isTrue(error is SocketException);
       s.close();
-      port.toSendPort().send(1);
+    asyncEnd();
     });
   });
 }
 
 void testSimpleConnect(String certificate) {
-  ReceivePort port = new ReceivePort();
+  asyncStart();
   RawSecureServerSocket.bind(HOST_NAME, 0, certificate).then((server) {
     var clientEndFuture = RawSecureSocket.connect(HOST_NAME, server.port);
     server.listen((serverEnd) {
       clientEndFuture.then((clientEnd) {
         clientEnd.shutdown(SocketDirection.SEND);
         serverEnd.shutdown(SocketDirection.SEND);
         server.close();
-        port.close();
+        asyncEnd();
       });
     });
   });
 }
 
 void testSimpleConnectFail(String certificate, bool cancelOnError) {
-  ReceivePort port = new ReceivePort();
+  asyncStart();
   RawSecureServerSocket.bind(HOST_NAME, 0, certificate).then((server) {
     var clientEndFuture = RawSecureSocket.connect(HOST_NAME, server.port)
       .then((clientEnd) {
         Expect.fail("No client connection expected.");
       })
       .catchError((error) {
         Expect.isTrue(error is SocketException ||
                       error is HandshakeException);
       });
     server.listen((serverEnd) {
       Expect.fail("No server connection expected.");
     },
     onError: (error) {
       Expect.isTrue(error is CertificateException);
       clientEndFuture.then((_) {
         if (!cancelOnError) server.close();
-        port.close();
+        asyncEnd();
       });
     },
     cancelOnError: cancelOnError);
   });
 }
 
 void testServerListenAfterConnect() {
-  ReceivePort port = new ReceivePort();
+  asyncStart();
   RawSecureServerSocket.bind(HOST_NAME, 0, CERTIFICATE).then((server) {
     Expect.isTrue(server.port > 0);
     var clientEndFuture = RawSecureSocket.connect(HOST_NAME, server.port);
     new Timer(const Duration(milliseconds: 500), () {
       server.listen((serverEnd) {
         clientEndFuture.then((clientEnd) {
           clientEnd.shutdown(SocketDirection.SEND);
           serverEnd.shutdown(SocketDirection.SEND);
           server.close();
-          port.close();
+          asyncEnd();
         });
       });
     });
   });
 }
 
 // This test creates a server and a client connects. The client then
 // writes and the server echos. When the server has finished its echo
 // it half-closes. When the client gets the close event is closes
 // fully.
@@ skipping 28 matching lines @@
                           bool handshakeBeforeSecure,
                           bool postponeSecure,
                           bool dropReads}) {
   int clientReads = 0;
   int serverReads = 0;
   if (handshakeBeforeSecure == true &&
       (listenSecure == true || connectSecure == true)) {
     Expect.fail("Invalid arguments to testSimpleReadWrite");
   }
 
-  ReceivePort port = new ReceivePort();
+  asyncStart();
 
   const messageSize = 1000;
   const handshakeMessageSize = 100;
 
   List<int> createTestData() {
     List<int> data = new List<int>(messageSize);
     for (int i = 0; i < messageSize; i++) {
       data[i] = i & 0xff;
     }
     return data;
@@ skipping 274 matching lines @@
                 subscription: secure[0],
                 bufferedData: secure[1]).then((client) {
             runServer(client).then((_) => server.close());
           });
         });
       }
     });
 
     connectClient(server.port).then(runClient).then((socket) {
       socket.close();
-      port.close();
+      asyncEnd();
     });
   }
 
   if (listenSecure) {
     RawSecureServerSocket.bind(
         HOST_NAME, 0, CERTIFICATE).then(serverReady);
   } else {
     RawServerSocket.bind(HOST_NAME, 0).then(serverReady);
   }
 }
@@ skipping 46 matching lines @@
                       connectSecure: true,
                       handshakeBeforeSecure: false,
                       postponeSecure: false,
                       dropReads: true);
   testSimpleReadWrite(listenSecure: false,
                       connectSecure: false,
                       handshakeBeforeSecure: true,
                       postponeSecure: true,
                       dropReads: true);
 }