| 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 import 'dart:async'; | 5 import 'dart:async'; |
| 6 import 'dart:core'; | 6 import 'dart:core'; |
| 7 | 7 |
| 8 import 'package:analysis_server/plugin/analysis/analysis_domain.dart'; | 8 import 'package:analysis_server/plugin/analysis/analysis_domain.dart'; |
| 9 import 'package:analysis_server/src/analysis_server.dart'; | 9 import 'package:analysis_server/src/analysis_server.dart'; |
| 10 import 'package:analysis_server/src/computer/computer_hover.dart'; | 10 import 'package:analysis_server/src/computer/computer_hover.dart'; |
| 11 import 'package:analysis_server/src/constants.dart'; | 11 import 'package:analysis_server/src/constants.dart'; |
| 12 import 'package:analysis_server/src/context_manager.dart'; | |
| 13 import 'package:analysis_server/src/domain_abstract.dart'; | 12 import 'package:analysis_server/src/domain_abstract.dart'; |
| 14 import 'package:analysis_server/src/domains/analysis/navigation.dart'; | 13 import 'package:analysis_server/src/domains/analysis/navigation.dart'; |
| 15 import 'package:analysis_server/src/domains/analysis/navigation_dart.dart'; | 14 import 'package:analysis_server/src/domains/analysis/navigation_dart.dart'; |
| 16 import 'package:analysis_server/src/operation/operation_analysis.dart' | 15 import 'package:analysis_server/src/operation/operation_analysis.dart' |
| 17 show NavigationOperation, OccurrencesOperation; | 16 show NavigationOperation, OccurrencesOperation; |
| 18 import 'package:analysis_server/src/plugin/plugin_manager.dart'; | 17 import 'package:analysis_server/src/plugin/plugin_manager.dart'; |
| 19 import 'package:analysis_server/src/plugin/request_converter.dart'; | 18 import 'package:analysis_server/src/plugin/request_converter.dart'; |
| 20 import 'package:analysis_server/src/plugin/result_merger.dart'; | 19 import 'package:analysis_server/src/plugin/result_merger.dart'; |
| 21 import 'package:analysis_server/src/protocol/protocol_internal.dart'; | 20 import 'package:analysis_server/src/protocol/protocol_internal.dart'; |
| 22 import 'package:analysis_server/src/protocol_server.dart'; | 21 import 'package:analysis_server/src/protocol_server.dart'; |
| (...skipping 423 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 446 String file = source.fullName; | 445 String file = source.fullName; |
| 447 if (server.hasAnalysisSubscription(service, file)) { | 446 if (server.hasAnalysisSubscription(service, file)) { |
| 448 if (service == AnalysisService.NAVIGATION) { | 447 if (service == AnalysisService.NAVIGATION) { |
| 449 server.scheduleOperation(new NavigationOperation(context, source)); | 448 server.scheduleOperation(new NavigationOperation(context, source)); |
| 450 } | 449 } |
| 451 if (service == AnalysisService.OCCURRENCES) { | 450 if (service == AnalysisService.OCCURRENCES) { |
| 452 server.scheduleOperation(new OccurrencesOperation(context, source)); | 451 server.scheduleOperation(new OccurrencesOperation(context, source)); |
| 453 } | 452 } |
| 454 } | 453 } |
| 455 } | 454 } |
| 456 | |
| 457 void _subscribeForContext(engine.AnalysisContext context) { | |
| 458 for (ResultDescriptor descriptor in controllers.keys) { | |
| 459 context.onResultChanged(descriptor).listen((result) { | |
| 460 StreamController<engine.ResultChangedEvent> controller = | |
| 461 controllers[result.descriptor]; | |
| 462 if (controller != null) { | |
| 463 controller.add(result); | |
| 464 } | |
| 465 }); | |
| 466 } | |
| 467 } | |
| 468 } | 455 } |
| OLD | NEW |