| 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].
|
|
|