Exit stdio-based analysis server when stdin closed.

pkg/analysis_server/test/channel_test.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 test.channel;
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
 
@@ skipping 10 matching lines @@
     test('invalidJsonToClient', WebSocketChannelTest.invalidJsonToClient);
     test('invalidJsonToServer', WebSocketChannelTest.invalidJsonToServer);
     test('notification', WebSocketChannelTest.notification);
     test('notificationAndResponse', WebSocketChannelTest.notificationAndResponse);
     test('request', WebSocketChannelTest.request);
     test('requestResponse', WebSocketChannelTest.requestResponse);
     test('response', WebSocketChannelTest.response);
   });
   group('ByteStreamServerChannel', () {
     setUp(ByteStreamServerChannelTest.setUp);
+    test('closed', ByteStreamServerChannelTest.closed);
     test('listen_wellFormedRequest',
         ByteStreamServerChannelTest.listen_wellFormedRequest);
     test('listen_invalidRequest',
         ByteStreamServerChannelTest.listen_invalidRequest);
     test('listen_invalidJson', ByteStreamServerChannelTest.listen_invalidJson);
     test('listen_streamError', ByteStreamServerChannelTest.listen_streamError);
     test('listen_streamDone', ByteStreamServerChannelTest.listen_streamDone);
     test('sendNotification', ByteStreamServerChannelTest.sendNotification);
     test('sendResponse', ByteStreamServerChannelTest.sendResponse);
   });
@@ skipping 178 matching lines @@
     doneFuture = doneCompleter.future;
     channel.listen((Request request) {
       requestStreamController.add(request);
     }, onError: (error) {
       errorStreamController.add(error);
     }, onDone: () {
       doneCompleter.complete();
     });
   }
 
+  static Future closed() {
+    return inputSink.close().then((_) => channel.closed.timeout(new Duration(
+        seconds: 1)));
+  }
+
   static Future listen_wellFormedRequest() {
     inputSink.writeln('{"id":"0","method":"server.version"}');
     return inputSink.flush().then((_) => requestStream.first.timeout(
         new Duration(seconds: 1))).then((Request request) {
       expect(request.id, equals("0"));
       expect(request.method, equals("server.version"));
     });
   }
 
   static Future listen_invalidRequest() {
@@ skipping 47 matching lines @@
     channel.sendResponse(new Response('foo'));
     return outputLineStream.first.timeout(new Duration(seconds: 1)).then((String
         response) {
       var jsonResponse = new JsonCodec().decode(response);
       expect(jsonResponse, isMap);
       expect(jsonResponse, contains('id'));
       expect(jsonResponse['id'], equals('foo'));
     });
   }
 }