| 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 test.integration.analysis; | 5 library test.integration.analysis; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:collection'; | 8 import 'dart:collection'; |
| 9 import 'dart:convert'; | 9 import 'dart:convert'; |
| 10 import 'dart:io'; | 10 import 'dart:io'; |
| (...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 113 */ | 113 */ |
| 114 Future get analysisFinished { | 114 Future get analysisFinished { |
| 115 Completer completer = new Completer(); | 115 Completer completer = new Completer(); |
| 116 StreamSubscription subscription; | 116 StreamSubscription subscription; |
| 117 // This will only work if the caller has already subscribed to | 117 // This will only work if the caller has already subscribed to |
| 118 // SERVER_STATUS (e.g. using sendServerSetSubscriptions(['STATUS'])) | 118 // SERVER_STATUS (e.g. using sendServerSetSubscriptions(['STATUS'])) |
| 119 expect(_subscribedToServerStatus, isTrue); | 119 expect(_subscribedToServerStatus, isTrue); |
| 120 subscription = onServerStatus.listen((params) { | 120 subscription = onServerStatus.listen((params) { |
| 121 bool analysisComplete = false; | 121 bool analysisComplete = false; |
| 122 try { | 122 try { |
| 123 analysisComplete = !params['analysis']['analyzing']; | 123 analysisComplete = !params['analysis']['isAnalyzing']; |
| 124 } catch (_) { | 124 } catch (_) { |
| 125 // Status message was mal-formed or missing optional parameters. That's | 125 // Status message was mal-formed or missing optional parameters. That's |
| 126 // fine, since we'll detect a mal-formed status message below. | 126 // fine, since we'll detect a mal-formed status message below. |
| 127 } | 127 } |
| 128 if (analysisComplete) { | 128 if (analysisComplete) { |
| 129 completer.complete(params); | 129 completer.complete(params); |
| 130 subscription.cancel(); | 130 subscription.cancel(); |
| 131 } | 131 } |
| 132 expect(params, isServerStatusParams); | 132 expect(params, isServerStatusParams); |
| 133 }); | 133 }); |
| (...skipping 695 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 829 */ | 829 */ |
| 830 void _recordStdio(String line) { | 830 void _recordStdio(String line) { |
| 831 double elapsedTime = _time.elapsedTicks / _time.frequency; | 831 double elapsedTime = _time.elapsedTicks / _time.frequency; |
| 832 line = "$elapsedTime: $line"; | 832 line = "$elapsedTime: $line"; |
| 833 if (_debuggingStdio) { | 833 if (_debuggingStdio) { |
| 834 print(line); | 834 print(line); |
| 835 } | 835 } |
| 836 _recordedStdio.add(line); | 836 _recordedStdio.add(line); |
| 837 } | 837 } |
| 838 } | 838 } |
| OLD | NEW |