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

Side by Side Diff: packages/quiver/lib/io.dart

Issue 2989763002: Update charted to 0.4.8 and roll (Closed)
Patch Set: Removed Cutch from list of reviewers Created 3 years, 4 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 unified diff | Download patch
« no previous file with comments | « packages/quiver/lib/core.dart ('k') | packages/quiver/lib/mirrors.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2013 Google Inc. All Rights Reserved. 1 // Copyright 2013 Google Inc. All Rights Reserved.
2 // 2 //
3 // Licensed under the Apache License, Version 2.0 (the "License"); 3 // Licensed under the Apache License, Version 2.0 (the "License");
4 // you may not use this file except in compliance with the License. 4 // you may not use this file except in compliance with the License.
5 // You may obtain a copy of the License at 5 // You may obtain a copy of the License at
6 // 6 //
7 // http://www.apache.org/licenses/LICENSE-2.0 7 // http://www.apache.org/licenses/LICENSE-2.0
8 // 8 //
9 // Unless required by applicable law or agreed to in writing, software 9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS, 10 // distributed under the License is distributed on an "AS IS" BASIS,
11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 // See the License for the specific language governing permissions and 12 // See the License for the specific language governing permissions and
13 // limitations under the License. 13 // limitations under the License.
14 14
15 library quiver.io; 15 library quiver.io;
16 16
17 import 'dart:async'; 17 import 'dart:async';
18 import 'dart:convert'; 18 import 'dart:convert';
19 import 'dart:io'; 19 import 'dart:io';
20 20
21 import 'package:quiver/async.dart'; 21 import 'package:quiver/async.dart';
22 22
23 /** 23 /// Converts a [Stream] of byte lists to a [String].
24 * Converts a [Stream] of byte lists to a [String].
25 */
26 Future<String> byteStreamToString(Stream<List<int>> stream, 24 Future<String> byteStreamToString(Stream<List<int>> stream,
27 {Encoding encoding: UTF8}) { 25 {Encoding encoding: UTF8}) {
28 return stream.transform(encoding.decoder).join(); 26 return stream.transform(encoding.decoder).join();
29 } 27 }
30 28
31 /** 29 /// Gets the full path of [path] by using [File.fullPathSync].
32 * Gets the full path of [path] by using [File.fullPathSync].
33 */
34 String getFullPath(path) => new File(path).resolveSymbolicLinksSync(); 30 String getFullPath(path) => new File(path).resolveSymbolicLinksSync();
35 31
36 /** 32 /// Lists the sub-directories and files of this Directory, optionally recursing
37 * Lists the sub-directories and files of this Directory, optionally recursing 33 /// into sub-directories based on the return value of [visit].
38 * into sub-directories based on the return value of [visit]. 34 ///
39 * 35 /// [visit] is called with a [File], [Directory] or [Link] to a directory,
40 * [visit] is called with a [File], [Directory] or [Link] to a directory, 36 /// never a Symlink to a File. If [visit] returns true, then it's argument is
41 * never a Symlink to a File. If [visit] returns true, then it's argument is 37 /// listed recursively.
42 * listed recursively.
43 */
44 Future visitDirectory(Directory dir, Future<bool> visit(FileSystemEntity f)) { 38 Future visitDirectory(Directory dir, Future<bool> visit(FileSystemEntity f)) {
45 var futureGroup = new FutureGroup(); 39 var futureGroup = new FutureGroup();
46 40
47 void _list(Directory dir) { 41 void _list(Directory dir) {
48 var completer = new Completer(); 42 var completer = new Completer();
49 futureGroup.add(completer.future); 43 futureGroup.add(completer.future);
50 dir.list(followLinks: false).listen((FileSystemEntity entity) { 44 dir.list(followLinks: false).listen((FileSystemEntity entity) {
51 var future = visit(entity); 45 var future = visit(entity);
52 if (future != null) { 46 if (future != null) {
53 futureGroup.add(future.then((bool recurse) { 47 futureGroup.add(future.then((bool recurse) {
(...skipping 11 matching lines...) Expand all
65 } else { 59 } else {
66 _list(entity); 60 _list(entity);
67 } 61 }
68 } 62 }
69 })); 63 }));
70 } 64 }
71 }, onDone: () { 65 }, onDone: () {
72 completer.complete(null); 66 completer.complete(null);
73 }, cancelOnError: true); 67 }, cancelOnError: true);
74 } 68 }
69
75 _list(dir); 70 _list(dir);
76 71
77 return futureGroup.future; 72 return futureGroup.future;
78 } 73 }
OLDNEW
« no previous file with comments | « packages/quiver/lib/core.dart ('k') | packages/quiver/lib/mirrors.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698