OLD | NEW |
1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 library domain.analysis; | 5 library domain.analysis; |
6 | 6 |
7 import 'dart:async'; | 7 import 'dart:async'; |
8 import 'dart:core' hide Resource; | 8 import 'dart:core' hide Resource; |
9 | 9 |
10 import 'package:analysis_server/plugin/analysis/analysis_domain.dart'; | 10 import 'package:analysis_server/plugin/analysis/analysis_domain.dart'; |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
103 } | 103 } |
104 } | 104 } |
105 // send response | 105 // send response |
106 return new AnalysisGetHoverResult(hovers).toResponse(request.id); | 106 return new AnalysisGetHoverResult(hovers).toResponse(request.id); |
107 } | 107 } |
108 | 108 |
109 /// Implement the `analysis.getLibraryDependencies` request. | 109 /// Implement the `analysis.getLibraryDependencies` request. |
110 Response getLibraryDependencies(Request request) { | 110 Response getLibraryDependencies(Request request) { |
111 server.onAnalysisComplete.then((_) { | 111 server.onAnalysisComplete.then((_) { |
112 LibraryDependencyCollector collector = | 112 LibraryDependencyCollector collector = |
113 new LibraryDependencyCollector(server.getAnalysisContexts()); | 113 new LibraryDependencyCollector(server.analysisContexts); |
114 Set<String> libraries = collector.collectLibraryDependencies(); | 114 Set<String> libraries = collector.collectLibraryDependencies(); |
115 Map<String, Map<String, List<String>>> packageMap = | 115 Map<String, Map<String, List<String>>> packageMap = |
116 collector.calculatePackageMap(server.folderMap); | 116 collector.calculatePackageMap(server.folderMap); |
117 server.sendResponse(new AnalysisGetLibraryDependenciesResult( | 117 server.sendResponse(new AnalysisGetLibraryDependenciesResult( |
118 libraries.toList(growable: false), packageMap) | 118 libraries.toList(growable: false), packageMap) |
119 .toResponse(request.id)); | 119 .toResponse(request.id)); |
120 }); | 120 }); |
121 // delay response | 121 // delay response |
122 return Response.DELAYED_RESPONSE; | 122 return Response.DELAYED_RESPONSE; |
123 } | 123 } |
(...skipping 247 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
371 event.added.forEach(_subscribeForContext); | 371 event.added.forEach(_subscribeForContext); |
372 }); | 372 }); |
373 } | 373 } |
374 | 374 |
375 @override | 375 @override |
376 Stream<engine.ComputedResult> onResultComputed(ResultDescriptor descriptor) { | 376 Stream<engine.ComputedResult> onResultComputed(ResultDescriptor descriptor) { |
377 Stream<engine.ComputedResult> stream = controllers | 377 Stream<engine.ComputedResult> stream = controllers |
378 .putIfAbsent(descriptor, | 378 .putIfAbsent(descriptor, |
379 () => new StreamController<engine.ComputedResult>.broadcast()) | 379 () => new StreamController<engine.ComputedResult>.broadcast()) |
380 .stream; | 380 .stream; |
381 server.getAnalysisContexts().forEach(_subscribeForContext); | 381 server.analysisContexts.forEach(_subscribeForContext); |
382 return stream; | 382 return stream; |
383 } | 383 } |
384 | 384 |
385 @override | 385 @override |
386 void scheduleNotification( | 386 void scheduleNotification( |
387 engine.AnalysisContext context, Source source, AnalysisService service) { | 387 engine.AnalysisContext context, Source source, AnalysisService service) { |
388 String file = source.fullName; | 388 String file = source.fullName; |
389 if (server.hasAnalysisSubscription(service, file)) { | 389 if (server.hasAnalysisSubscription(service, file)) { |
390 if (service == AnalysisService.NAVIGATION) { | 390 if (service == AnalysisService.NAVIGATION) { |
391 server.scheduleOperation(new NavigationOperation(context, source)); | 391 server.scheduleOperation(new NavigationOperation(context, source)); |
392 } | 392 } |
393 if (service == AnalysisService.OCCURRENCES) { | 393 if (service == AnalysisService.OCCURRENCES) { |
394 server.scheduleOperation(new OccurrencesOperation(context, source)); | 394 server.scheduleOperation(new OccurrencesOperation(context, source)); |
395 } | 395 } |
396 } | 396 } |
397 } | 397 } |
398 | 398 |
399 void _subscribeForContext(engine.AnalysisContext context) { | 399 void _subscribeForContext(engine.AnalysisContext context) { |
400 for (ResultDescriptor descriptor in controllers.keys) { | 400 for (ResultDescriptor descriptor in controllers.keys) { |
401 context.onResultComputed(descriptor).listen((result) { | 401 context.onResultComputed(descriptor).listen((result) { |
402 StreamController<engine.ComputedResult> controller = | 402 StreamController<engine.ComputedResult> controller = |
403 controllers[result.descriptor]; | 403 controllers[result.descriptor]; |
404 if (controller != null) { | 404 if (controller != null) { |
405 controller.add(result); | 405 controller.add(result); |
406 } | 406 } |
407 }); | 407 }); |
408 } | 408 } |
409 } | 409 } |
410 } | 410 } |
OLD | NEW |