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

Unified Diff: pkg/barback/lib/src/transformer/declaring_aggregate_transform.dart

Issue 808713003: Remove barback from the repo. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 6 years 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
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();
- }
-}

Powered by Google App Engine
This is Rietveld 408576698