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

Unified Diff: packages/barback/lib/src/graph/static_asset_cascade.dart

Issue 2989763002: Update charted to 0.4.8 and roll (Closed)
Patch Set: Removed Cutch from list of reviewers Created 3 years, 5 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
« no previous file with comments | « packages/barback/lib/src/graph/phase.dart ('k') | packages/barback/lib/src/graph/transform_node.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: packages/barback/lib/src/graph/static_asset_cascade.dart
diff --git a/packages/barback/lib/src/graph/static_asset_cascade.dart b/packages/barback/lib/src/graph/static_asset_cascade.dart
index 7eeda966f549b52509924ce05b9d90b1d1f39068..4effda57c48e6ebeb00db35e56f72b9fb7ead85c 100644
--- a/packages/barback/lib/src/graph/static_asset_cascade.dart
+++ b/packages/barback/lib/src/graph/static_asset_cascade.dart
@@ -6,6 +6,9 @@ library barback.graph.static_asset_cascade;
import 'dart:async';
+import 'package:async/async.dart';
+import 'package:collection/collection.dart';
+
import '../asset/asset_id.dart';
import '../asset/asset_node.dart';
import '../asset/asset_set.dart';
@@ -38,18 +41,18 @@ class StaticAssetCascade implements AssetCascade {
final status = NodeStatus.IDLE;
final onLog = new StreamController<LogEntry>.broadcast().stream;
- final onStatusChange = new StreamController<LogEntry>.broadcast().stream;
+ final onStatusChange = new StreamController<NodeStatus>.broadcast().stream;
final onAsset = new StreamController<AssetNode>.broadcast().stream;
Future<AssetSet> get availableOutputs {
var provider = graph.provider as StaticPackageProvider;
return provider.getAllAssetIds(package).asyncMap(provider.getAsset).toList()
- .then((assets) => new AssetSet.from(assets));
+ .then((assets) => new AssetSet.from(DelegatingList.typed(assets)));
}
Future<AssetNode> getAssetNode(AssetId id) {
return _sources.putIfAbsent(id, () {
- return graph.provider.getAsset(id).then((asset) {
+ return DelegatingFuture.typed(graph.provider.getAsset(id).then((asset) {
return new AssetNodeController.available(asset).node;
}).catchError((error, stackTrace) {
if (error is! AssetNotFoundException) {
@@ -58,7 +61,7 @@ class StaticAssetCascade implements AssetCascade {
// TODO(nweiz): propagate error information through asset nodes.
return null;
- });
+ }));
});
}
« no previous file with comments | « packages/barback/lib/src/graph/phase.dart ('k') | packages/barback/lib/src/graph/transform_node.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698