Index: pkg/analyzer/lib/src/task/driver.dart |
diff --git a/pkg/analyzer/lib/src/task/driver.dart b/pkg/analyzer/lib/src/task/driver.dart |
index c172ce2e1188162edc4ec2ceb04e9edfcac8b189..b729a2b95e56f39811e1d00fee46b583a8eee2ff 100644 |
--- a/pkg/analyzer/lib/src/task/driver.dart |
+++ b/pkg/analyzer/lib/src/task/driver.dart |
@@ -44,11 +44,11 @@ class AnalysisDriver { |
final InternalAnalysisContext context; |
/** |
- * The map of [ComputedResult] controllers. |
+ * The map of [ResultChangedEvent] controllers. |
*/ |
- final Map<ResultDescriptor, StreamController<ComputedResult>> |
+ final Map<ResultDescriptor, StreamController<ResultChangedEvent>> |
resultComputedControllers = |
- <ResultDescriptor, StreamController<ComputedResult>>{}; |
+ <ResultDescriptor, StreamController<ResultChangedEvent>>{}; |
/** |
* The work order that was previously computed but that has not yet been |
@@ -208,11 +208,10 @@ class AnalysisDriver { |
* Return the stream that is notified when a new value for the given |
* [descriptor] is computed. |
*/ |
- Stream<ComputedResult> onResultComputed(ResultDescriptor descriptor) { |
- return resultComputedControllers |
- .putIfAbsent(descriptor, |
- () => new StreamController<ComputedResult>.broadcast(sync: true)) |
- .stream; |
+ Stream<ResultChangedEvent> onResultComputed(ResultDescriptor descriptor) { |
+ return resultComputedControllers.putIfAbsent(descriptor, () { |
+ return new StreamController<ResultChangedEvent>.broadcast(sync: true); |
+ }).stream; |
} |
/** |
@@ -284,11 +283,11 @@ class AnalysisDriver { |
entry.setValue(result, outputs[result], dependedOn); |
} |
outputs.forEach((ResultDescriptor descriptor, value) { |
- StreamController<ComputedResult> controller = |
+ StreamController<ResultChangedEvent> controller = |
resultComputedControllers[descriptor]; |
if (controller != null) { |
- ComputedResult event = |
- new ComputedResult(context, descriptor, target, value); |
+ ResultChangedEvent event = new ResultChangedEvent( |
+ context, target, descriptor, value, true); |
controller.add(event); |
} |
}); |