Big merge from experimental to bleeding edge.

Review URL: https://codereview.chromium.org//11783009

git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge/dart@16687 260f80e4-7a28-3924-810f-c04153c831b5

Author: floitschG

pkg/args/lib/args.dart

@@ -353,7 +353,7 @@ class ArgParser {
   _setOption(Map results, _Option option, value) {
     // See if it's one of the allowed values.
     if (option.allowed != null) {
-      _validate(option.allowed.some((allow) => allow == value),
+      _validate(option.allowed.any((allow) => allow == value),
           '"$value" is not an allowed value for option "${option.name}".');
     }
 
@@ -544,7 +544,7 @@ class ArgResults {
   }
 
   /** Get the names of the options as a [Collection]. */
-  Collection<String> get options => _options.keys;
+  Collection<String> get options => _options.keys.toList();
 }
 
 class _Option {
@@ -630,8 +630,8 @@ class _Usage {
       if (option.help != null) write(2, option.help);
 
       if (option.allowedHelp != null) {
-        var allowedNames = option.allowedHelp.keys;
-        allowedNames.sort((a, b) => a.compareTo(b));
+        var allowedNames = option.allowedHelp.keys.toList();
+        allowedNames.sort();
         newline();
         for (var name in allowedNames) {
           write(1, getAllowedTitle(name));

pkg/args/test/args_test.dart

@@ -450,8 +450,8 @@ main() {
         parser.addOption('meow', defaultsTo: 'kitty');
         var args = parser.parse([]);
         expect(args.options, hasLength(2));
-        expect(args.options.some((o) => o == 'woof'), isTrue);
-        expect(args.options.some((o) => o == 'meow'), isTrue);
+        expect(args.options.any((o) => o == 'woof'), isTrue);
+        expect(args.options.any((o) => o == 'meow'), isTrue);
       });
     });
 

pkg/fixnum/lib/src/int32.dart

@@ -338,7 +338,7 @@ class int32 implements intx {
   int numberOfTrailingZeros() => _numberOfTrailingZeros(_i);
 
   List<int> toBytes() {
-    List<int> result = new List<int>(4);
+    List<int> result = new List<int>.fixedLength(4);
     result[0] = _i & 0xff;
     result[1] = (_i >> 8) & 0xff;
     result[2] = (_i >> 16) & 0xff;

pkg/fixnum/lib/src/int64.dart

@@ -625,7 +625,7 @@ class int64 implements intx {
   }
 
   List<int> toBytes() {
-    List<int> result = new List<int>(8);
+    List<int> result = new List<int>.fixedLength(8);
     result[0] = _l & 0xff;
     result[1] = (_l >> 8) & 0xff;
     result[2] = ((_m << 6) & 0xfc) | ((_l >> 16) & 0x3f);

pkg/fixnum/test/int_64_vm_test.dart

@@ -174,7 +174,7 @@ class int64VMTest {
       testSet.add(new int64.fromInt(pow));
     }
 
-    TEST_VALUES = new List<int64>(testSet.length);
+    TEST_VALUES = new List<int64>.fixedLength(testSet.length);
     int index = 0;
     for (int64 val in testSet) {
       TEST_VALUES[index++] = val;

pkg/http/lib/http.dart

@@ -27,7 +27,7 @@
 ///         "http://example.com/whatsit/create",
 ///         fields: {"name": "doodle", "color": "blue"})
 ///       .chain((response) => client.get(response.bodyFields['uri']))
-///       .transform((response) => print(response.body))
+///       .then((response) => print(response.body))
 ///       .onComplete((_) => client.close());
 ///
 /// You can also exert more fine-grained control over your requests and
@@ -53,6 +53,7 @@
 
 library http;
 
+import 'dart:async';
 import 'dart:scalarlist';
 import 'dart:uri';
 
@@ -168,6 +169,6 @@ Future<Uint8List> readBytes(url, {Map<String, String> headers}) =>
 Future _withClient(Future fn(Client)) {
   var client = new Client();
   var future = fn(client);
-  future.onComplete((_) => client.close());
+  future.catchError((_) {}).then((_) => client.close());
   return future;
 }

pkg/http/lib/src/base_client.dart

@@ -4,6 +4,7 @@
 
 library base_client;
 
+import 'dart:async';
 import 'dart:io';
 import 'dart:scalarlist';
 import 'dart:uri';
@@ -72,7 +73,7 @@ abstract class BaseClient implements Client {
   /// For more fine-grained control over the request and response, use [send] or
   /// [get] instead.
   Future<String> read(url, {Map<String, String> headers}) {
-    return get(url, headers: headers).transform((response) {
+    return get(url, headers: headers).then((response) {
       _checkResponseSuccess(url, response);
       return response.body;
     });
@@ -88,7 +89,7 @@ abstract class BaseClient implements Client {
   /// For more fine-grained control over the request and response, use [send] or
   /// [get] instead.
   Future<Uint8List> readBytes(url, {Map<String, String> headers}) {
-    return get(url, headers: headers).transform((response) {
+    return get(url, headers: headers).then((response) {
       _checkResponseSuccess(url, response);
       return response.bodyBytes;
     });
@@ -108,15 +109,15 @@ abstract class BaseClient implements Client {
       [Map<String, String> fields]) {
     // Wrap everything in a Future block so that synchronous validation errors
     // are passed asynchronously through the Future chain.
-    return async.chain((_) {
+    return async.then((_) {
       if (url is String) url = new Uri.fromString(url);
       var request = new Request(method, url);
 
       if (headers != null) mapAddAll(request.headers, headers);
       if (fields != null && !fields.isEmpty) request.bodyFields = fields;
 
       return send(request);
-    }).chain(Response.fromStream);
+    }).then(Response.fromStream);
   }
 
   /// Throws an error if [response] is not successful.

pkg/http/lib/src/base_request.dart

@@ -4,6 +4,7 @@
 
 library base_request;
 
+import 'dart:async';
 import 'dart:io';
 import 'dart:isolate';
 import 'dart:uri';
@@ -105,7 +106,7 @@ abstract class BaseRequest {
   /// requests.
   Future<StreamedResponse> send() {
     var client = new Client();
-    return client.send(this).transform((response) {
+    return client.send(this).then((response) {
       // TODO(nweiz): This makes me sick to my stomach, but it's currently the
       // best way to listen for the response stream being closed. Kill it with
       // fire once issue 4202 is fixed.
@@ -117,7 +118,7 @@ abstract class BaseRequest {
       });
 
       return response;
-    });
+    }).catchError((_) { client.close(); });
   }
 
   /// Throws an error if this request has been finalized.

pkg/http/lib/src/client.dart

@@ -4,6 +4,7 @@
 
 library client;
 
+import 'dart:async';
 import 'dart:io';
 import 'dart:scalarlist';
 

pkg/http/lib/src/io_client.dart

@@ -4,6 +4,7 @@
 
 library io_client;
 
+import 'dart:async';
 import 'dart:io';
 
 import 'base_client.dart';
@@ -25,6 +26,7 @@ class IOClient extends BaseClient {
 
     var completer = new Completer<StreamedResponse>();
     var connection = _inner.openUrl(request.method, request.url);
+    bool completed = false;
     connection.followRedirects = request.followRedirects;
     connection.maxRedirects = request.maxRedirects;
     connection.onError = (e) {
@@ -33,9 +35,10 @@ class IOClient extends BaseClient {
         // onRequest or onResponse callbacks get passed to onError. If the
         // completer has already fired, we want to re-throw those exceptions
         // to the top level so that they aren't silently ignored.
-        if (completer.future.isComplete) throw e;
+        if (completed) throw e;
 
-        completer.completeException(e);
+        completed = true;
+        completer.completeError(e);
       });
     };
 
@@ -57,6 +60,9 @@ class IOClient extends BaseClient {
       var headers = <String>{};
       response.headers.forEach((key, value) => headers[key] = value);
 
+      if (completed) return;
+
+      completed = true;
       completer.complete(new StreamedResponse(
           response.inputStream,
           response.statusCode,