| Index: pkg/barback/lib/src/transformer/declaring_aggregate_transform.dart
|
| diff --git a/pkg/barback/lib/src/transformer/declaring_aggregate_transform.dart b/pkg/barback/lib/src/transformer/declaring_aggregate_transform.dart
|
| deleted file mode 100644
|
| index cfcb782b5d41a16b28c44e1de7f1b572477fbcfb..0000000000000000000000000000000000000000
|
| --- a/pkg/barback/lib/src/transformer/declaring_aggregate_transform.dart
|
| +++ /dev/null
|
| @@ -1,105 +0,0 @@
|
| -// Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file
|
| -// for details. All rights reserved. Use of this source code is governed by a
|
| -// BSD-style license that can be found in the LICENSE file.
|
| -
|
| -library barback.transformer.declaring_aggregate_transform;
|
| -
|
| -import 'dart:async';
|
| -
|
| -import '../asset/asset_id.dart';
|
| -import '../graph/transform_node.dart';
|
| -import '../utils.dart';
|
| -import 'base_transform.dart';
|
| -
|
| -/// A transform for [DeclaringAggregateTransformer]s that allows them to declare
|
| -/// the ids of the outputs they'll generate without generating the concrete
|
| -/// bodies of those outputs.
|
| -class DeclaringAggregateTransform extends BaseTransform {
|
| - /// The set of output ids declared by the transformer.
|
| - final _outputIds = new Set<AssetId>();
|
| -
|
| - /// The transform key.
|
| - ///
|
| - /// This is the key returned by [AggregateTransformer.classifyPrimary] for all
|
| - /// the assets in this transform.
|
| - final String key;
|
| -
|
| - /// The package in which this transform is running.
|
| - final String package;
|
| -
|
| - /// The stream of primary input ids that have been aggregated for this
|
| - /// transform.
|
| - ///
|
| - /// This is exposed as a stream so that the transformer can start working
|
| - /// before all its input ids are available. The stream is closed not just when
|
| - /// all inputs are provided, but when barback is confident no more inputs will
|
| - /// be forthcoming.
|
| - ///
|
| - /// A transformer may complete its `declareOutputs` method before this stream
|
| - /// is closed. For example, it may know that each key will only have two
|
| - /// inputs associated with it, and so use `transform.primaryIds.take(2)` to
|
| - /// access only those inputs' ids.
|
| - Stream<AssetId> get primaryIds => _primaryIds;
|
| - Stream<AssetId> _primaryIds;
|
| -
|
| - /// The controller for [primaryIds].
|
| - ///
|
| - /// This is a broadcast controller so that the transform can keep
|
| - /// [_emittedPrimaryIds] up to date.
|
| - final _idController = new StreamController<AssetId>.broadcast();
|
| -
|
| - /// The set of all primary input ids that have been emitted by [primaryIds].
|
| - final _emittedPrimaryIds = new Set<AssetId>();
|
| -
|
| - DeclaringAggregateTransform._(TransformNode node)
|
| - : key = node.key,
|
| - package = node.phase.cascade.package,
|
| - super(node) {
|
| - _idController.stream.listen(_emittedPrimaryIds.add);
|
| - // [primaryIds] should be a non-broadcast stream.
|
| - _primaryIds = broadcastToSingleSubscription(_idController.stream);
|
| - }
|
| -
|
| - /// Stores [id] as the id of an output that will be created by this
|
| - /// transformation when it's run.
|
| - ///
|
| - /// A transformation can declare as many assets as it wants. If
|
| - /// [DeclaringTransformer.declareOutputs] declares a given asset id for a
|
| - /// given input, [Transformer.apply] should emit the corresponding asset as
|
| - /// well.
|
| - void declareOutput(AssetId id) {
|
| - // TODO(nweiz): This should immediately throw if an output with that ID
|
| - // has already been declared by this transformer.
|
| - _outputIds.add(id);
|
| - }
|
| -
|
| - void consumePrimary(AssetId id) {
|
| - if (!_emittedPrimaryIds.contains(id)) {
|
| - throw new StateError(
|
| - "$id can't be consumed because it's not a primary input.");
|
| - }
|
| -
|
| - super.consumePrimary(id);
|
| - }
|
| -}
|
| -
|
| -/// The controller for [DeclaringAggregateTransform].
|
| -class DeclaringAggregateTransformController extends BaseTransformController {
|
| - DeclaringAggregateTransform get transform => super.transform;
|
| -
|
| - /// The set of ids that the transformer declares it will emit.
|
| - Set<AssetId> get outputIds => transform._outputIds;
|
| -
|
| - bool get isDone => transform._idController.isClosed;
|
| -
|
| - DeclaringAggregateTransformController(TransformNode node)
|
| - : super(new DeclaringAggregateTransform._(node));
|
| -
|
| - /// Adds a primary input id to the [DeclaringAggregateTransform.primaryIds]
|
| - /// stream.
|
| - void addId(AssetId id) => transform._idController.add(id);
|
| -
|
| - void done() {
|
| - transform._idController.close();
|
| - }
|
| -}
|
|
|