anchor.diff:  /// Writes [stream] to a new file at path [file]. Will replace any file already
   /// at that path. Completes when the file is done being written.
   Future<String> createFileFromStream(Stream<List<int>> stream, String file) {
  -  log.io("Creating $file from stream.");
  +  // TODO(nweiz): remove extra logging when we figure out the windows bot issue.
  +  log.io("Creating $file from stream (is the stream broadcast? "
  +      "${stream.isBroadcast}).");
  +
  +  var pair = tee(stream);
  +  pair.first.listen(
  +      (data) => log.io("stream emitted ${data.length} bytes"),
  +      onError: (error, st) => log.io("stream emitted $error\n$st"),
  +      onDone: () => log.io("stream is done"));
   
     return _descriptorPool.withResource(() {
  -    return stream.pipe(new File(file).openWrite()).then((_) {
  +    return pair.last.pipe(new File(file).openWrite()).then((_) {
         log.fine("Created $file from stream.");
         return file;
       });
  
positive.code:       throw new Exception("Failed to extract .tar.gz stream to $destination "
            "(exit code $exitCode).");
      }
      log.fine("Extracted .tar.gz stream to $destination. Exit code "
          "$exitCode.");
    });
  }
  
  
negative.code:     // Write the archive to a temp file.
      var dataFile = path.join(tempDir, 'data.tar.gz');
      return createFileFromStream(stream, dataFile).then((_) {
        // TODO(nweiz): remove this when we're finished debugging the windows
        // bots.
        log.io("Does $dataFile exist? ${fileExists(dataFile)}");
        try {
          readBinaryFile(dataFile);
  