| Index: pkg/barback/lib/src/transform_node.dart
|
| diff --git a/pkg/barback/lib/src/transform_node.dart b/pkg/barback/lib/src/transform_node.dart
|
| index 56605c2617e63e8f9a877d96beb40cbace5d3eb5..6df431540abf424db33bf94c2efa608a75a01b7e 100644
|
| --- a/pkg/barback/lib/src/transform_node.dart
|
| +++ b/pkg/barback/lib/src/transform_node.dart
|
| @@ -55,8 +55,12 @@ class TransformNode {
|
| final _onDirtyController = new StreamController.broadcast(sync: true);
|
|
|
| /// A stream that emits an event whenever this transform logs an entry.
|
| + ///
|
| + /// This is synchronous because error logs can cause the transform to fail, so
|
| + /// we need to ensure that their processing isn't delayed until after the
|
| + /// transform or build has finished.
|
| Stream<LogEntry> get onLog => _onLogController.stream;
|
| - final _onLogController = new StreamController<LogEntry>.broadcast();
|
| + final _onLogController = new StreamController<LogEntry>.broadcast(sync: true);
|
|
|
| TransformNode(this.phase, this.transformer, this.primary) {
|
| _primarySubscription = primary.onStateChange.listen((state) {
|
|
|