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 |