Add Windows support.

lib/src/util/io.dart

 // Copyright (c) 2015, 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.util.io;
 
 import 'dart:async';
 import 'dart:io';
 import 'dart:mirrors';
 
 import 'package:path/path.dart' as p;
 import 'package:pub_semver/pub_semver.dart';
 
 import '../backend/operating_system.dart';
 import '../runner/application_exception.dart';
 
+/// The ASCII code for a newline character.
+const _newline = 0xA;
+
+/// The ASCII code for a carriage return character.
+const _carriageReturn = 0xD;
+
 /// The root directory of the Dart SDK.
 final String sdkDir =
     p.dirname(p.dirname(Platform.executable));
 
 /// The version of the Dart SDK currently in use.
 final Version _sdkVersion = new Version.parse(
     new File(p.join(sdkDir, 'version'))
         .readAsStringSync().trim());
 
 /// Returns the current operating system.
@@ skipping 61 matching lines @@
 /// Returns a future that completes to the value that the future returned from
 /// [fn] completes to.
 Future withTempDir(Future fn(String path)) {
   return new Future.sync(() {
     var tempDir = createTempDir();
     return new Future.sync(() => fn(tempDir))
         .whenComplete(() => new Directory(tempDir).deleteSync(recursive: true));
   });
 }
 
+/// Return a transformation of [input] with all null bytes removed.
+///
+/// This works around the combination of issue 23295 and 22667 by removing null
+/// bytes. This workaround can be removed when either of those are fixed in the
+/// oldest supported SDK.
+///
+/// It also somewhat works around issue 23303 by removing any carriage returns
+/// that are followed by newlines, to ensure that carriage returns aren't
+/// doubled up in the output. This can be removed when the issue is fixed in the
+/// oldest supported SDk.
+Stream<List<int>> santizeForWindows(Stream<List<int>> input) {
+  if (!Platform.isWindows) return input;
+
+  return input.map((list) {
+    var previous;
+    return list.reversed.where((byte) {
+      if (byte == 0) return false;
+      if (byte == _carriageReturn && previous == _newline) return false;
+      previous = byte;
+      return true;
+    }).toList().reversed.toList();
+  });
+}
+
 /// Creates a URL string for [address]:[port].
 ///
 /// Handles properly formatting IPv6 addresses.
 Uri baseUrlForAddress(InternetAddress address, int port) {
   if (address.isLoopback) {
     return new Uri(scheme: "http", host: "localhost", port: port);
   }
 
   // IPv6 addresses in URLs need to be enclosed in square brackets to avoid
   // URL ambiguity with the ":" in the address.
@@ skipping 24 matching lines @@
 /// returned.
 String libraryPath(Symbol libraryName, {String packageRoot}) {
   var lib = currentMirrorSystem().findLibrary(libraryName);
   if (lib.uri.scheme != 'package') return p.fromUri(lib.uri);
 
   // TODO(nweiz): is there a way to avoid assuming this is being run next to a
   // packages directory?.
   if (packageRoot == null) packageRoot = p.absolute('packages');
   return p.join(packageRoot, p.fromUri(lib.uri.path));
 }