Improve barback/pub logging.

pkg/barback/lib/src/phase.dart

 // Copyright (c) 2013, 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.phase;
 
 import 'dart:async';
 import 'dart:collection';
 
 import 'asset_cascade.dart';
 import 'asset_id.dart';
 import 'asset_node.dart';
 import 'asset_set.dart';
+import 'barback_logger.dart';
 import 'group_runner.dart';
 import 'errors.dart';
 import 'phase_forwarder.dart';
 import 'phase_input.dart';
 import 'phase_output.dart';
 import 'stream_pool.dart';
 import 'transformer.dart';
 import 'transformer_group.dart';
 import 'utils.dart';
 
@@ skipping 61 matching lines @@
 
   /// A controller whose stream feeds into [_onDirtyPool].
   ///
   /// This is used whenever an input is added or transforms are changed.
   final _onDirtyController = new StreamController.broadcast(sync: true);
 
   /// Whether this phase is dirty and needs to be run.
   bool get isDirty => _inputs.values.any((input) => input.isDirty) ||
       _groups.values.any((group) => group.isDirty);
 
+  /// A stream that emits an event whenever any transforms in this phase log an

[nweiz, 2013/10/16 19:41:27]

"log" -> "logs"

[Bob Nystrom, 2013/10/28 23:45:56]

Done.

+  /// entry.
+  Stream<LogEntry> get onLog => _onLogPool.stream;
+  final _onLogPool = new StreamPool<LogEntry>.broadcast();
+
   /// The phase after this one.
   ///
   /// Outputs from this phase will be passed to it.
   Phase get next => _next;
   Phase _next;
 
   /// Returns all currently-available output assets for this phase.
   Set<AssetNode> get availableOutputs {
     return _outputs.values
         .map((output) => output.output)
@@ skipping 39 matching lines @@
     });
 
     var input = new PhaseInput(this, node, _transformers);
     _inputs[node.id] = input;
     input.input.whenRemoved.then((_) {
       _inputs.remove(node.id);
       _forwarders.remove(node.id).remove();
     });
     _onDirtyPool.add(input.onDirty);
     _onDirtyController.add(null);
+    _onLogPool.add(input.onLog);
 
     for (var group in _groups.values) {
       group.addInput(node);
     }
   }
 
   /// Gets the asset node for an input [id].
   ///
   /// If an input with that ID cannot be found, returns null.
   Future<AssetNode> getInput(AssetId id) {
@@ skipping 67 matching lines @@
   /// This will remove all the phase's outputs and all following phases.
   void remove() {
     removeFollowing();
     for (var input in _inputs.values.toList()) {
       input.remove();
     }
     for (var group in _groups.values) {
       group.remove();
     }
     _onDirtyPool.close();
+    _onLogPool.close();
   }
 
   /// Remove all phases after this one.
   void removeFollowing() {
     if (_next == null) return;
     _next.remove();
     _next = null;
   }
 
   /// Processes this phase.
@@ skipping 48 matching lines @@
       _outputs[asset.id].add(asset);
     } else {
       _outputs[asset.id] = new PhaseOutput(this, asset);
       _outputs[asset.id].onAsset.listen((output) {
         if (_next != null) _next.addInput(output);
       }, onDone: () => _outputs.remove(asset.id));
       if (_next != null) _next.addInput(_outputs[asset.id].output);
     }
   }
 }