close the input stream in build_mode tests so they dont hang

pkg/analyzer_cli/test/build_mode_test.dart

 // Copyright (c) 2016, 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 analyzer_cli.test.built_mode;
 
 import 'package:analyzer_cli/src/build_mode.dart';
 import 'package:analyzer_cli/src/driver.dart';
 import 'package:analyzer_cli/src/options.dart';
 import 'package:bazel_worker/bazel_worker.dart';
@@ skipping 31 matching lines @@
 
   test_run() {
     var request = new WorkRequest();
     request.arguments.addAll([
       '--build-summary-input=/tmp/1.sum',
       '--build-summary-input=/tmp/2.sum',
       'package:foo/foo.dart|/inputs/foo/lib/foo.dart',
       'package:foo/bar.dart|/inputs/foo/lib/bar.dart',
     ]);
     stdinStream.addInputBytes(_serializeProto(request));
+    stdinStream.close();
 
     new TestAnalyzerWorkerLoop(connection, (CommandLineOptions options) {
       expect(options.buildSummaryInputs,
           unorderedEquals(['/tmp/1.sum', '/tmp/2.sum']));
       expect(
           options.sourceFiles,
           unorderedEquals([
             'package:foo/foo.dart|/inputs/foo/lib/foo.dart',
             'package:foo/bar.dart|/inputs/foo/lib/bar.dart'
           ]));
@@ skipping 13 matching lines @@
 
     // Check that a serialized version was written to std out.
     expect(stdoutStream.writes, hasLength(1));
     expect(stdoutStream.writes[0], _serializeProto(response));
   }
 
   test_run_invalidOptions() {
     var request = new WorkRequest();
     request.arguments.addAll(['--unknown-option', '/foo.dart', '/bar.dart']);
     stdinStream.addInputBytes(_serializeProto(request));
+    stdinStream.close();
     new TestAnalyzerWorkerLoop(connection).run();
     expect(connection.responses, hasLength(1));
 
     var response = connection.responses[0];
     expect(response.exitCode, EXIT_CODE_ERROR);
     expect(response.output, anything);
   }
 
   test_run_invalidRequest_noArgumentsInputs() {
     stdinStream.addInputBytes(_serializeProto(new WorkRequest()));
+    stdinStream.close();
 
     new TestAnalyzerWorkerLoop(connection).run();
     expect(connection.responses, hasLength(1));
 
     var response = connection.responses[0];
     expect(response.exitCode, EXIT_CODE_ERROR);
     expect(response.output, anything);
   }
 
   test_run_invalidRequest_randomBytes() {
     stdinStream.addInputBytes([1, 2, 3]);
+    stdinStream.close();
     new TestAnalyzerWorkerLoop(connection).run();
     expect(connection.responses, hasLength(1));
 
     var response = connection.responses[0];
     expect(response.exitCode, EXIT_CODE_ERROR);
     expect(response.output, anything);
   }
 
   test_run_stopAtEOF() {
-    stdinStream.addInputBytes([-1]);
+    stdinStream.close();
     new TestAnalyzerWorkerLoop(connection).run();
   }
 }
 
 typedef void _TestWorkerLoopAnalyze(CommandLineOptions options);
 
 /**
  * [AnalyzerWorkerLoop] for testing.
  */
 class TestAnalyzerWorkerLoop extends AnalyzerWorkerLoop {
   final _TestWorkerLoopAnalyze _analyze;
 
   TestAnalyzerWorkerLoop(SyncWorkerConnection connection, [this._analyze])
       : super(connection);
 
   @override
   void analyze(CommandLineOptions options) {
     if (_analyze != null) {
       _analyze(options);
     }
   }
 }