Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(808)

Unified Diff: lib/src/io.dart

Issue 1387163002: Add Resource package. (Closed) Base URL: https://github.com/dart-lang/resource.git@master
Patch Set: Created 5 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: lib/src/io.dart
diff --git a/lib/src/io.dart b/lib/src/io.dart
index 8237c0160f1493fb74e905797e4e8a3c5add4280..c48c5ab2244c66931c1d2a4da8264702a80b2b49 100644
--- a/lib/src/io.dart
+++ b/lib/src/io.dart
@@ -1,59 +1,66 @@
-// Copyright (c) 2015, 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.
-
-// dart:io based strategy for loading resources.
-
-import "dart:io" show File, HttpClient, HttpClientRequest, HttpClientResponse;
-import "dart:async" show Future, Stream;
-import "dart:convert" show Encoding, UTF8;
-import "package:typed_data/typed_buffers.dart" show Uint8Buffer;
-
-Stream<List<int>> readAsStream(Uri uri) async* {
- if (uri.scheme == "file") {
- yield* new File.fromUri(uri).openRead();
- return;
- }
- if (uri.scheme == "http" || uri.scheme == "https") {
- HttpClientResponse response = await _httpGet(uri);
- yield* response;
- return;
- }
- throw new UnsupportedError("Unsupported scheme: $uri");
-}
-
-Future<List<int>> readAsBytes(Uri uri) async {
- if (uri.scheme == "file") {
- return new File.fromUri(uri).readAsBytes();
- }
- if (uri.scheme == "http" || uri.scheme == "https") {
- HttpClientResponse response = await _httpGet(uri);
- Uint8Buffer buffer = new Uint8Buffer();
- await for (var bytes in response) {
- buffer.addAll(bytes);
- }
- return buffer.toList();
- }
- throw new UnsupportedError("Unsupported scheme: $uri");
-}
-
-Future<String> readAsString(Uri uri, Encoding encoding) async {
- if (encoding == null) encoding = UTF8;
- if (uri.scheme == "file") {
- return new File.fromUri(uri).readAsString(encoding: encoding);
- }
- if (uri.scheme == "http" || uri.scheme == "https") {
- HttpClientResponse response = await _httpGet(uri);
- Uint8Buffer buffer = new Uint8Buffer();
- await for (var bytes in response) {
- buffer.addAll(bytes);
- }
- new String.fromCharCodes(buffer.toList());
- }
- throw new UnsupportedError("Unsupported scheme: $uri");
-}
-
-Future<HttpClientResponse> _httpGet(Uri uri) async {
- HttpClientRequest request = await new HttpClient().getUrl(uri);
- return await request.close();
-}
+// Copyright (c) 2015, 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.
+
+// dart:io based strategy for loading resources.
+
+import "dart:io" show File, HttpClient, HttpClientRequest, HttpClientResponse;
+import "dart:async" show Future, Stream;
+import "dart:convert" show Encoding, UTF8;
+import "package:typed_data/typed_buffers.dart" show Uint8Buffer;
+
+// TODO(lrn): Add support for "data:" URIs.
+
+/// Read the bytes of a URI as a stream of bytes.
+Stream<List<int>> readAsStream(Uri uri) async* {
+ if (uri.scheme == "file") {
+ yield* new File.fromUri(uri).openRead();
+ return;
+ }
+ if (uri.scheme == "http" || uri.scheme == "https") {
+ HttpClientResponse response = await _httpGet(uri);
+ yield* response;
+ return;
+ }
+ throw new UnsupportedError("Unsupported scheme: $uri");
+}
+
+/// Read the bytes of a URI as a list of bytes.
+Future<List<int>> readAsBytes(Uri uri) async {
+ if (uri.scheme == "file") {
+ return new File.fromUri(uri).readAsBytes();
+ }
+ if (uri.scheme == "http" || uri.scheme == "https") {
+ HttpClientResponse response = await _httpGet(uri);
+ Uint8Buffer buffer = new Uint8Buffer();
+ await for (var bytes in response) {
+ buffer.addAll(bytes);
+ }
+ return buffer.toList();
+ }
+ throw new UnsupportedError("Unsupported scheme: $uri");
+}
+
+/// Read the bytes of a URI as a string.
+///
+/// Encoding defaults to UTF-8.
+Future<String> readAsString(Uri uri, Encoding encoding) async {
+ if (encoding == null) encoding = UTF8;
+ if (uri.scheme == "file") {
+ return new File.fromUri(uri).readAsString(encoding: encoding);
+ }
+ if (uri.scheme == "http" || uri.scheme == "https") {
+ HttpClientResponse response = await _httpGet(uri);
+ Uint8Buffer buffer = new Uint8Buffer();
+ await for (var bytes in response) {
+ buffer.addAll(bytes);
+ }
+ new String.fromCharCodes(buffer.toList());
+ }
+ throw new UnsupportedError("Unsupported scheme: $uri");
+}
+
+Future<HttpClientResponse> _httpGet(Uri uri) async {
+ HttpClientRequest request = await new HttpClient().getUrl(uri);
+ return await request.close();
+}

Powered by Google App Engine
This is Rietveld 408576698