| 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.server.set.subscriptions; | 5 library test.integration.server.set.subscriptions; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 | 8 |
| 9 import '../../reflective_tests.dart'; | 9 import 'package:analysis_server/src/protocol.dart'; |
| 10 import 'package:unittest/unittest.dart'; | 10 import 'package:unittest/unittest.dart'; |
| 11 | 11 |
| 12 import '../../reflective_tests.dart'; |
| 12 import '../integration_tests.dart'; | 13 import '../integration_tests.dart'; |
| 13 | 14 |
| 14 @ReflectiveTestCase() | 15 @ReflectiveTestCase() |
| 15 class Test extends AbstractAnalysisServerIntegrationTest { | 16 class Test extends AbstractAnalysisServerIntegrationTest { |
| 16 test_setSubscriptions() { | 17 test_setSubscriptions() { |
| 17 bool statusReceived = false; | 18 bool statusReceived = false; |
| 18 Completer analysisBegun = new Completer(); | 19 Completer analysisBegun = new Completer(); |
| 19 onServerStatus.listen((_) { | 20 onServerStatus.listen((_) { |
| 20 statusReceived = true; | 21 statusReceived = true; |
| 21 }); | 22 }); |
| 22 onAnalysisErrors.listen((_) { | 23 onAnalysisErrors.listen((_) { |
| 23 if (!analysisBegun.isCompleted) { | 24 if (!analysisBegun.isCompleted) { |
| 24 analysisBegun.complete(); | 25 analysisBegun.complete(); |
| 25 } | 26 } |
| 26 }); | 27 }); |
| 27 return sendServerSetSubscriptions([]).then((_) { | 28 return sendServerSetSubscriptions([]).then((_) { |
| 28 String pathname = sourcePath('test.dart'); | 29 String pathname = sourcePath('test.dart'); |
| 29 writeFile(pathname, ''' | 30 writeFile(pathname, ''' |
| 30 main() { | 31 main() { |
| 31 var x; | 32 var x; |
| 32 }'''); | 33 }'''); |
| 33 standardAnalysisSetup(subscribeStatus: false); | 34 standardAnalysisSetup(subscribeStatus: false); |
| 34 // Analysis should begin, but no server.status notification should be | 35 // Analysis should begin, but no server.status notification should be |
| 35 // received. | 36 // received. |
| 36 return analysisBegun.future.then((_) { | 37 return analysisBegun.future.then((_) { |
| 37 expect(statusReceived, isFalse); | 38 expect(statusReceived, isFalse); |
| 38 return sendServerSetSubscriptions(['STATUS']).then((_) { | 39 return sendServerSetSubscriptions([ServerService.STATUS]).then((_) { |
| 39 // Tickle test.dart just in case analysis has already completed. | 40 // Tickle test.dart just in case analysis has already completed. |
| 40 writeFile(pathname, ''' | 41 writeFile(pathname, ''' |
| 41 main() { | 42 main() { |
| 42 var y; | 43 var y; |
| 43 }'''); | 44 }'''); |
| 44 // Analysis should eventually complete, and we should be notified | 45 // Analysis should eventually complete, and we should be notified |
| 45 // about it. | 46 // about it. |
| 46 return analysisFinished; | 47 return analysisFinished; |
| 47 }); | 48 }); |
| 48 }); | 49 }); |
| 49 }); | 50 }); |
| 50 } | 51 } |
| 51 } | 52 } |
| 52 | 53 |
| 53 main() { | 54 main() { |
| 54 runReflectiveTests(Test); | 55 runReflectiveTests(Test); |
| 55 } | 56 } |
| OLD | NEW |