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 |