Index: pkg/analysis_server/lib/src/domain_analysis.dart |
diff --git a/pkg/analysis_server/lib/src/domain_analysis.dart b/pkg/analysis_server/lib/src/domain_analysis.dart |
index 7bfb354da317db0d990d6a035c6117f66f987fed..df316821b33041bbaffe13d7c4e67aa72caa4d62 100644 |
--- a/pkg/analysis_server/lib/src/domain_analysis.dart |
+++ b/pkg/analysis_server/lib/src/domain_analysis.dart |
@@ -362,9 +362,9 @@ class AnalysisDomainHandler implements RequestHandler { |
class AnalysisDomainImpl implements AnalysisDomain { |
final AnalysisServer server; |
- final Map<ResultDescriptor, StreamController<engine.ComputedResult>> |
+ final Map<ResultDescriptor, StreamController<engine.ResultChangedEvent>> |
controllers = |
- <ResultDescriptor, StreamController<engine.ComputedResult>>{}; |
+ <ResultDescriptor, StreamController<engine.ResultChangedEvent>>{}; |
AnalysisDomainImpl(this.server) { |
server.onContextsChanged.listen((ContextsChangedEvent event) { |
@@ -373,11 +373,12 @@ class AnalysisDomainImpl implements AnalysisDomain { |
} |
@override |
- Stream<engine.ComputedResult> onResultComputed(ResultDescriptor descriptor) { |
- Stream<engine.ComputedResult> stream = controllers |
- .putIfAbsent(descriptor, |
- () => new StreamController<engine.ComputedResult>.broadcast()) |
- .stream; |
+ Stream<engine.ResultChangedEvent> onResultChanged( |
+ ResultDescriptor descriptor) { |
+ Stream<engine.ResultChangedEvent> stream = |
+ controllers.putIfAbsent(descriptor, () { |
+ return new StreamController<engine.ResultChangedEvent>.broadcast(); |
+ }).stream; |
server.analysisContexts.forEach(_subscribeForContext); |
return stream; |
} |
@@ -398,8 +399,8 @@ class AnalysisDomainImpl implements AnalysisDomain { |
void _subscribeForContext(engine.AnalysisContext context) { |
for (ResultDescriptor descriptor in controllers.keys) { |
- context.onResultComputed(descriptor).listen((result) { |
- StreamController<engine.ComputedResult> controller = |
+ context.onResultChanged(descriptor).listen((result) { |
+ StreamController<engine.ResultChangedEvent> controller = |
controllers[result.descriptor]; |
if (controller != null) { |
controller.add(result); |