Index: lib/src/graph/transform_node.dart |
diff --git a/lib/src/graph/transform_node.dart b/lib/src/graph/transform_node.dart |
index 61bab3f258943d925ef0be951fec42fe2f1156e5..72f79680a52aa3dd993bbc79f7f1caa21f239cad 100644 |
--- a/lib/src/graph/transform_node.dart |
+++ b/lib/src/graph/transform_node.dart |
@@ -6,6 +6,8 @@ library barback.graph.transform_node; |
import 'dart:async'; |
+import 'package:async/async.dart'; |
+ |
import '../asset/asset.dart'; |
import '../asset/asset_id.dart'; |
import '../asset/asset_node.dart'; |
@@ -437,7 +439,7 @@ class TransformNode { |
} |
_maybeFinishDeclareController(); |
- syncFuture(() { |
+ new Future.sync(() { |
return (transformer as DeclaringAggregateTransformer) |
.declareOutputs(controller.transform); |
}).whenComplete(() { |
@@ -628,7 +630,7 @@ class TransformNode { |
} |
_maybeFinishApplyController(); |
- return syncFuture(() { |
+ return DelegatingFuture.typed(new Future.sync(() { |
_timeInTransformer.reset(); |
_timeAwaitingInputs.reset(); |
_timeInTransformer.start(); |
@@ -688,7 +690,7 @@ class TransformNode { |
// is so a broken transformer doesn't take down the whole graph. |
phase.cascade.reportError(_wrapException(error, stackTrace)); |
return true; |
- }); |
+ })); |
} |
/// Handle the results of running [Transformer.apply]. |