| 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.execution; | 5 library domain.execution; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:collection'; | 8 import 'dart:collection'; |
| 9 import 'dart:core'; | 9 import 'dart:core'; |
| 10 | 10 |
| (...skipping 146 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 157 | 157 |
| 158 /** | 158 /** |
| 159 * Implement the 'execution.setSubscriptions' request. | 159 * Implement the 'execution.setSubscriptions' request. |
| 160 */ | 160 */ |
| 161 Response setSubscriptions(Request request) { | 161 Response setSubscriptions(Request request) { |
| 162 if (server.options.enableNewAnalysisDriver) { | 162 if (server.options.enableNewAnalysisDriver) { |
| 163 // Under the analysis driver, setSubscriptions() becomes a no-op. | 163 // Under the analysis driver, setSubscriptions() becomes a no-op. |
| 164 return new ExecutionSetSubscriptionsResult().toResponse(request.id); | 164 return new ExecutionSetSubscriptionsResult().toResponse(request.id); |
| 165 } else { | 165 } else { |
| 166 List<ExecutionService> subscriptions = | 166 List<ExecutionService> subscriptions = |
| 167 new ExecutionSetSubscriptionsParams.fromRequest(request).subscriptions
; | 167 new ExecutionSetSubscriptionsParams.fromRequest(request) |
| 168 .subscriptions; |
| 168 if (subscriptions.contains(ExecutionService.LAUNCH_DATA)) { | 169 if (subscriptions.contains(ExecutionService.LAUNCH_DATA)) { |
| 169 if (onFileAnalyzed == null) { | 170 if (onFileAnalyzed == null) { |
| 170 onFileAnalyzed = server.onFileAnalyzed.listen(_fileAnalyzed); | 171 onFileAnalyzed = server.onFileAnalyzed.listen(_fileAnalyzed); |
| 171 _reportCurrentFileStatus(); | 172 _reportCurrentFileStatus(); |
| 172 } | 173 } |
| 173 } else { | 174 } else { |
| 174 if (onFileAnalyzed != null) { | 175 if (onFileAnalyzed != null) { |
| 175 onFileAnalyzed.cancel(); | 176 onFileAnalyzed.cancel(); |
| 176 onFileAnalyzed = null; | 177 onFileAnalyzed = null; |
| 177 } | 178 } |
| (...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 260 if (_isInAnalysisRoot(filePath)) { | 261 if (_isInAnalysisRoot(filePath)) { |
| 261 server.sendNotification( | 262 server.sendNotification( |
| 262 new ExecutionLaunchDataParams(filePath, kind: kind).toNotification()); | 263 new ExecutionLaunchDataParams(filePath, kind: kind).toNotification()); |
| 263 } | 264 } |
| 264 } | 265 } |
| 265 | 266 |
| 266 static List<String> _getFullNames(List<Source> sources) { | 267 static List<String> _getFullNames(List<Source> sources) { |
| 267 return sources.map((Source source) => source.fullName).toList(); | 268 return sources.map((Source source) => source.fullName).toList(); |
| 268 } | 269 } |
| 269 } | 270 } |
| OLD | NEW |