restructure client api to use streams

pkg/analysis_server/lib/src/analysis_manager.dart

 // Copyright (c) 2014, 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.
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
+
 import 'package:analysis_server/src/channel.dart';
 import 'package:analysis_server/src/domain_server.dart';
 import 'package:analysis_server/src/protocol.dart';
 
 /**
  * [AnalysisManager] is used to launch and manage an analysis server
  * running in a separate process using either the [start] or [connect] methods.
  */
 class AnalysisManager {
   // TODO dynamically allocate port and/or allow client to specify port
@@ skipping 92 matching lines @@
 
   /**
    * Stop the analysis server.
    *
    * Returns `true` if the signal is successfully sent and process terminates.
    * Otherwise there was no attached process or the signal could not be sent,
    * usually meaning that the process is already dead.
    */
   Future<bool> stop() {
     if (process == null) {
-      return new Future.value(false);
+      return channel.close().then((_) => false);
     }
-    var request = new Request('0', ServerDomainHandler.SHUTDOWN_METHOD);
-    channel.sendRequest(request);
-    return process.exitCode
-        .timeout(new Duration(seconds: 10))
-        .catchError((error) {
+    return channel
+        .sendRequest(new Request('0', ServerDomainHandler.SHUTDOWN_METHOD))
+        .timeout(new Duration(seconds: 2), onTimeout: () {
+          print('Expected shutdown response');
+        })
+        .then((Response response) {
+          channel.close();
+          return process.exitCode;
+        })
+        .timeout(new Duration(seconds: 2), onTimeout: () {
+          print('Expected server to shutdown');
           process.kill();
-          throw 'Expected server to shutdown';
         })
-        .then((result) {
-          if (result != 0) {
+        .then((int result) {
+          if (result != null && result != 0) {
             exitCode = result;
           }
           return true;
         });
   }
-
 }