Add ArchiveInputStream.readAll.

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", prefix: "archive");
 #import("entry_request.dart");
 #import("read_request.dart", prefix: 'read');
@@ skipping 183 matching lines @@
   /** Whether [openInputStream] has been called. */
   bool get isInputOpen() => _input != null;
 
   /** Create a deep copy of this [ArchiveEntry]. */
   Future<ArchiveEntry> clone() {
     return call(CLONE, _id).
       transform((array) => new archive.ArchiveEntry.internal(array, null));
   }
 
   /**
+   * Consumes the entire contents of this entry at once and returns it wrapped
+   * in a [CompleteArchiveEntry]. All metadata fields in the returned entry are
+   * copies of the fields in this entry.
+   *
+   * This may not be called [openInputStream] is called, and vice versa.

[Bob Nystrom, 2012/08/06 23:44:28]

Missing some word here.

[nweiz, 2012/08/07 00:57:12]

Done.

+   */
+  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]));
+  }
+
+  /**
    * 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.
     call(requestType, _id, [value]).then((_) {});
   }
 
@@ skipping 81 matching lines @@
       return async();
     }).chain((_) {
       if (_input.closed || _archiveId == null || data == null) {
         return new Future.immediate(null);
       }
       _input.write(data);
       return _consumeInput();
     });
   }
 }
+
+/**
+ * An [ArchiveEntry] that contains the complete decompressed contents of the
+ * file.
+ */
+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);
+}