More fixes for failures on the Windows bot

pkg/analysis_server/test/channel/byte_stream_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.byte_stream;
 
 import 'dart:async';
 import 'dart:convert';
 import 'dart:io';
 
 import 'package:analysis_server/src/channel/byte_stream_channel.dart';
 import 'package:analysis_server/src/protocol.dart';
 import 'package:analyzer/instrumentation/instrumentation.dart';
 import 'package:unittest/unittest.dart';
 
 import '../mocks.dart';
+import '../utils.dart';
 
 main() {
+  initializeTestEnvironment();
   group('ByteStreamClientChannel', () {
     setUp(ByteStreamClientChannelTest.setUp);
     test('close', ByteStreamClientChannelTest.close);
     test(
         'listen_notification', ByteStreamClientChannelTest.listen_notification);
     test('listen_response', ByteStreamClientChannelTest.listen_response);
     test('sendRequest', ByteStreamClientChannelTest.sendRequest);
   });
   group('ByteStreamServerChannel', () {
     setUp(ByteStreamServerChannelTest.setUp);
@@ skipping 179 matching lines @@
         .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 sendNotification() {
     channel.sendNotification(new Notification('foo'));
-    return outputLineStream.first.timeout(new Duration(seconds: 1)).then(
-        (String notification) {
+    return outputLineStream.first
+        .timeout(new Duration(seconds: 1))
+        .then((String notification) {
       var jsonNotification = new JsonCodec().decode(notification);
       expect(jsonNotification, isMap);
       expect(jsonNotification, contains('event'));
       expect(jsonNotification['event'], equals('foo'));
     });
   }
 
   static Future sendResponse() {
     channel.sendResponse(new Response('foo'));
-    return outputLineStream.first.timeout(new Duration(seconds: 1)).then(
-        (String response) {
+    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'));
     });
   }
 
   static void setUp() {
     StreamController<List<int>> inputStream = new StreamController<List<int>>();
     inputSink = new IOSink(inputStream);
@@ skipping 14 matching lines @@
     doneFuture = doneCompleter.future;
     channel.listen((Request request) {
       requestStreamController.add(request);
     }, onError: (error) {
       errorStreamController.add(error);
     }, onDone: () {
       doneCompleter.complete();
     });
   }
 }