Big merge from experimental to bleeding edge.

utils/archive/entry.dart

 // Copyright (c) 2012, 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 entry;
 
 import 'dart:io';
 import 'archive.dart' as archive;
 import 'entry_request.dart';
 import 'read_request.dart' as read;
@@ skipping 32 matching lines @@
    * For internal use only.
    */
   Future inputComplete;
 
   ArchiveEntry.internal(this._properties, this._archiveId) {
     attachFinalizer(this, (id) => call(FREE, id), _id);
   }
 
   /** Create a new [ArchiveEntry] with default values for all of its fields. */
   static Future<ArchiveEntry> create() {
-    return call(NEW).transform((properties) {
+    return call(NEW).then((properties) {
       return new archive.ArchiveEntry.internal(properties, null);
     });
   }
 
   /** The id of the underlying archive entry. */
   int get _id => _properties[0];
 
   /** If this entry is a hardlink, this is the destination. Otherwise, null. */
   String get hardlink => _properties[1];
   set hardlink(String value) => _set(SET_HARDLINK, 1, value);
@@ skipping 144 matching lines @@
   Future<CompleteArchiveEntry> readAll() {
     var stream = openInputStream();
     var buffer = <int>[];
     var completer = new Completer<List<int>>();
 
     stream.onData = () => buffer.addAll(stream.read());
     stream.onError = completer.completeException;
     stream.onClosed = () => completer.complete(buffer);
 
     return Futures.wait([call(CLONE, _id), completer.future])
-      .transform((list) => new CompleteArchiveEntry._(list[0], list[1]));
+      .then((list) => new CompleteArchiveEntry._(list[0], list[1]));
   }
 
   /**
    * Set a property value with index [value] on the local representation of the
    * archive entry and on the native representation.
    */
   void _set(int requestType, int index, value) {
     _properties[index] = value;
     // Since the native code processes messages in order, the SET_* messages
     // will be received and processed before any further messages.
@@ skipping 41 matching lines @@
     var inputCompleter = new Completer();
     inputComplete = inputCompleter.future;
 
     _input = new ListInputStream();
     // TODO(nweiz): Report errors once issue 3657 is fixed
     var future = _consumeInput().chain((_) {
       if (!_input.closed) _input.markEndOfStream();
       // Asynchronously complete to give the InputStream callbacks a chance to
       // fire.
       return async();
-    }).transform((_) => inputCompleter.complete(null));
+    }).then((_) => inputCompleter.complete(null));
 
     future.handleException((e) {
       print(e);
       print(future.stackTrace);
     });
     return _input;
   }
 
   /**
    * Close this entry so that its input stream no longer produces data.
@@ skipping 37 matching lines @@
 class CompleteArchiveEntry extends ArchiveEntry {
   /** The contents of the entry as bytes. */
   final List<int> contentBytes;
 
   /** The contents of the entry as a string. */
   String get contents => new String.fromCharCodes(contentBytes);
 
   CompleteArchiveEntry._(List properties, this.contentBytes)
     : super.internal(properties, null);
 }