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