added readAsString to pool

pkg/barback/test/too_many_open_files_test.dart

+// Copyright (c) 2013, 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 barback.test.too_many_open_files_test;
+
+import 'dart:async';
+import 'dart:io';
+
+import 'package:barback/barback.dart';
+import 'package:path/path.dart' as pathos;
+import 'package:unittest/unittest.dart';
+
+import 'utils.dart';
+
+main() {
+  initConfig();
+
+  test("handles a large number of simultaneous asset reads", () {
+    // Make a 1MB binary file in a temp directory.
+    var tempDir = Directory.systemTemp.createTempSync("barback").path;
+    var filePath = pathos.join(tempDir, "out.bin");
+    var bytes = new Iterable.generate(1024 * 1024, (i) => i % 255).toList();
+    new File(filePath).writeAsBytesSync(bytes);
+
+    var id = new AssetId("myapp", "out.bin");
+
+    // Create a large number of assets, larger than the file descriptor limit
+    // of most machines and start reading from all of them.
+    var futures = [];
+    for (var i = 0; i < 1000; i++) {
+      var completer = new Completer();
+      var asset = new Asset.fromPath(id, filePath);
+      var stream = asset.read();
+
+      stream.listen((data) {
+        // Do nothing.
+      }, onError: (error) {
+        completer.completeError(error);
+      }, onDone: () {
+        if (!completer.isCompleted) completer.complete();
+      });
+
+      futures.add(completer.future);
+    }
+
+    expect(Future.wait(futures).whenComplete(() {
+      new Directory(tempDir).delete(recursive: true);
+    }), completes);
+  });
+}