Updated ddbg to use new streams API.

tools/ddbg.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.
 
 // Simple interactive debugger shell that connects to the Dart VM's debugger
 // connection port.
 
 import "dart:io";
 import "dart:json" as json;
 import "dart:utf";
 import "dart:async";
 
 
 Map<int, Completer> outstandingCommands;
 
 Socket vmSock;
 String vmData;
-OutputStream vmStream;
+StreamSubscription<String> streamSubscription;
 int seqNum = 0;
 int isolate_id = -1;
 
 bool verbose = false;
 
 // The current stack trace, while the VM is paused. It's a list
 // of activation frames.
 List stackTrace;
 
 // The current activation frame, while the VM is paused.
@@ skipping 20 matching lines @@
   ls <lib_id> List loaded scripts in library
   gs <lib_id> <script_url> Get source text of script in library
   epi <none|all|unhandled>  Set exception pause info
   i <id> Interrupt execution of given isolate id
   h   Print help
 """);
 }
 
 
 void quitShell() {
-  vmStream.close();
+  streamSubscription.cancel();
   vmSock.close();
   stdin.close();
 }
 
 
 Future sendCmd(Map<String, dynamic> cmd) {
   var completer = new Completer();
   int id = cmd["id"];
   outstandingCommands[id] = completer;
   if (verbose) {
     print("sending: '${json.stringify(cmd)}'");
   }
-  vmStream.writeString(json.stringify(cmd));
+  vmSock.addString(json.stringify(cmd));
   return completer.future;
 }
 
 
 void processCommand(String cmdLine) {
   seqNum++;
   var args = cmdLine.split(' ');
   if (args.length == 0) {
     return;
   }
@@ skipping 438 matching lines @@
       // Strings can contain braces. Skip their content.
       index = skipString(index);
     }
   }
   return 0;
 }
 
 
 void debuggerMain() {
   outstandingCommands = new Map<int, Completer>();
-  vmSock = new Socket("127.0.0.1", 5858);
-  vmStream = vmSock.outputStream;
-  var stdinStream = new StringInputStream(stdin);
-  stdinStream.onLine = () {
-    processCommand(stdinStream.readLine());
-  };
-  var vmInStream = vmSock.inputStream;
-  vmInStream.onData = () {
-    String s = decodeUtf8(vmInStream.read());
-    processVmData(s);
-  };
-  vmInStream.onError = (err) {
-    print("Error in debug connection: $err");
-    quitShell();
-  };
-  vmInStream.onClosed = () {
-    print("VM debugger connection closed");
-    quitShell();
-  };
+  Socket.connect("127.0.0.1", 5858).then((s) {
+    vmSock = s;
+    Stream<String> stringStream = vmSock.transform(new StringDecoder());
+    streamSubscription = stringStream.listen(
+        (String data) {
+          processVmData(data);
+        },
+        onDone: () {
+          print("VM debugger connection closed");
+          quitShell();
+        },
+        onError: (err) {
+          print("Error in debug connection: $err");
+          quitShell();
+        });
+    stdin.transform(new StringDecoder())
+        .transform(new LineTransformer())
+        .listen((String line) => processCommand(line));
+  });
 }
 
 void main() {
   Options options = new Options();
   List<String> arguments = options.arguments;
   if (arguments.length > 0) {
     arguments = <String>['--debug', '--verbose_debug']..addAll(arguments);
     Process.start(options.executable, arguments).then((Process process) {
-      process.onExit = (int exitCode) {
+      process.stdin.close();
+      process.exitCode.then((int exitCode) {
         print('${arguments.join(" ")} exited with $exitCode');
-      };
-      process.stdin.close();
-      // Redirecting both stdout and stderr of the child process to
-      // stdout.  This should help users keep track of which errors
-      // are coming from the debugger, and which errors are coming
-      // from the process being debugged.
-      process.stderr.pipe(stdout);
-      process.stdout.pipe(stdout);
+      });
       debuggerMain();
     });
   } else {
     debuggerMain();
   }
 }