Exit stdio-based analysis server when stdin closed.

pkg/analysis_server/lib/http_server.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.
 
 library http.server;
 
+import 'dart:async';
 import 'dart:io';
 
 import 'package:analysis_server/src/channel.dart';
 import 'package:analysis_server/src/get_handler.dart';
 import 'package:analysis_server/src/socket_server.dart';
 
 /**
  * Instances of the class [HttpServer] implement a simple HTTP server. The
  * primary responsibility of this server is to listen for an UPGRADE request and
  * to start an analysis server.
  */
 class HttpAnalysisServer {
   /**
    * An object that can handle either a WebSocket connection or a connection
    * to the client over stdio.
    */
   SocketServer socketServer;
 
   /**
    * An object that can handle GET requests.
    */
   GetHandler getHandler;
 
   /**
    * Initialize a newly created HTTP server.
    */
   HttpAnalysisServer(this.socketServer);
 
   /**
+   * Future that is completed with the HTTP server once it is running.
+   */
+  Future<HttpServer> _server;
+
+  /**
    * Attach a listener to a newly created HTTP server.
    */
   void _handleServer(HttpServer httServer) {
     httServer.listen((HttpRequest request) {
       List<String> updateValues = request.headers[HttpHeaders.UPGRADE];
       if (updateValues != null && updateValues.indexOf('websocket') >= 0) {
         WebSocketTransformer.upgrade(request).then((WebSocket websocket) {
           _handleWebSocket(websocket);
         });
       } else if (request.method == 'GET') {
@@ skipping 31 matching lines @@
     response.statusCode = HttpStatus.NOT_FOUND;
     response.headers.add(HttpHeaders.CONTENT_TYPE, "text/plain");
     response.write('Not found');
     response.close();
   }
 
   /**
    * Begin serving HTTP requests over the given port.
    */
   void serveHttp(int port) {
-    HttpServer.bind(InternetAddress.LOOPBACK_IP_V4, port).then(_handleServer);
+    _server = HttpServer.bind(InternetAddress.LOOPBACK_IP_V4, port);
+    _server.then(_handleServer);
+  }
+
+  void close() {
+    _server.then((HttpServer server) {
+      server.close();
+    });
   }
 }