Merge IO v2 branch to bleeding edge

tests/standalone/io/process_stdout_test.dart

Index: tests/standalone/io/process_stdout_test.dart
diff --git a/tests/standalone/io/process_stdout_test.dart b/tests/standalone/io/process_stdout_test.dart
index 200faf0ca4fac40f6c707a47e6058ece79667bff..698ab57bff46f57b38fcbac863821d3bd8e58019 100644
--- a/tests/standalone/io/process_stdout_test.dart
+++ b/tests/standalone/io/process_stdout_test.dart
@@ -17,20 +17,18 @@ import "process_test_util.dart";
 
 void test(Future<Process> future, int expectedExitCode) {
   future.then((process) {
-    process.onExit = (exitCode) {
+    process.exitCode.then((exitCode) {
       Expect.equals(expectedExitCode, exitCode);
-    };
+    });
 
     List<int> data = "ABCDEFGHI\n".charCodes;
     final int dataSize = data.length;
 
-    InputStream out = process.stdout;
-
     int received = 0;
     List<int> buffer = [];
 
-    void readData() {
-      buffer.addAll(out.read());
+    void readData(data) {
+      buffer.addAll(data);
       for (int i = received;
            i < min(data.length, buffer.length) - 1;
            i++) {
@@ -47,10 +45,10 @@ void test(Future<Process> future, int expectedExitCode) {
       }
     }
 
-    process.stdin.write(data);
+    process.stderr.listen((_) {});
+    process.stdin.add(data);
     process.stdin.close();
-    out.onData = readData;
-    process.stderr.onData = process.stderr.read;
+    process.stdout.listen(readData);
   });
 }