Exit stdio-based analysis server when stdin closed.

pkg/analysis_server/lib/src/channel.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 channel;
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
 
@@ skipping 160 matching lines @@
 
 /**
  * Instances of the class [ByteStreamServerChannel] implement a
  * [ClientCommunicationChannel] that uses a stream and a sink (typically,
  * standard input and standard output) to communicate with servers.
  */
 class ByteStreamServerChannel implements ServerCommunicationChannel {
   final Stream input;
   final IOSink output;
 
+  /**
+   * Completer that will be signalled when the input stream is closed.
+   */
+  final Completer _closed = new Completer();
+
   ByteStreamServerChannel(this.input, this.output);
 
+  /**
+   * Future that will be completed when the input stream is closed.
+   */
+  Future get closed {
+    return _closed.future;
+  }
+
   @override
   void listen(void onRequest(Request request), {Function onError, void
       onDone()}) {
     input.transform((new Utf8Codec()).decoder).transform(new LineSplitter()
         ).listen((String data) => _readRequest(data, onRequest), onError: onError,
-        onDone: onDone);
+        onDone: () {
+      _closed.complete();

[Brian Wilkerson, 2014/04/16 17:23:43]

Out of curiosity, why not just add this line to onDone()?

[Paul Berry, 2014/04/16 17:28:40]

Because onDone() isn't a local function.  It's passed in by AnalysisServer when
it calls listen(), and it doesn't make sense to give AnalysisServer access to
_closed.

+      onDone();
+    });
   }
 
   @override
   void sendNotification(Notification notification) {
     output.writeln(JSON.encode(notification.toJson()));
   }
 
   @override
   void sendResponse(Response response) {
     output.writeln(JSON.encode(response.toJson()));
@@ skipping 88 matching lines @@
       }
     }
   }
 
   @override
   void close() {
     closed = true;
     sink.close();
   }
 }