| Index: packages/barback/lib/src/graph/transformer_classifier.dart
|
| diff --git a/packages/barback/lib/src/graph/transformer_classifier.dart b/packages/barback/lib/src/graph/transformer_classifier.dart
|
| index a095e8d0411724938abd471dbf4f89aa6fd6990f..d57f80a02c406dbc61369cfb765dbe1055a746e4 100644
|
| --- a/packages/barback/lib/src/graph/transformer_classifier.dart
|
| +++ b/packages/barback/lib/src/graph/transformer_classifier.dart
|
| @@ -12,7 +12,6 @@ import '../errors.dart';
|
| import '../log.dart';
|
| import '../transformer/aggregate_transformer.dart';
|
| import '../transformer/wrapping_aggregate_transformer.dart';
|
| -import '../utils.dart';
|
| import 'node_status.dart';
|
| import 'node_streams.dart';
|
| import 'phase.dart';
|
| @@ -74,8 +73,8 @@ class TransformerClassifier {
|
| /// Adds a new asset as an input for this transformer.
|
| void addInput(AssetNode input) {
|
| _activeClassifications++;
|
| - syncFuture(() => transformer.classifyPrimary(input.id)).catchError(
|
| - (error, stackTrace) {
|
| + new Future.sync(() => transformer.classifyPrimary(input.id))
|
| + .catchError((error, stackTrace) {
|
| if (input.state.isRemoved) return null;
|
|
|
| // Catch all transformer errors and pipe them to the results stream. This
|
|
|