| OLD | NEW |
| 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2011, 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 // Test the basic StreamController and StreamController.singleSubscription. | 5 // Test the basic StreamController and StreamController.singleSubscription. |
| 6 library stream_controller_test; | 6 library stream_controller_test; |
| 7 | 7 |
| 8 import "package:expect/expect.dart"; | 8 import "package:expect/expect.dart"; |
| 9 import "package:async_helper/async_helper.dart"; | 9 import "package:async_helper/async_helper.dart"; |
| 10 import 'dart:async'; | 10 import 'dart:async'; |
| (...skipping 463 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 474 asyncEnd(); | 474 asyncEnd(); |
| 475 }); | 475 }); |
| 476 } | 476 } |
| 477 | 477 |
| 478 void testStreamEquals() { | 478 void testStreamEquals() { |
| 479 StreamController c; | 479 StreamController c; |
| 480 c = new StreamController(sync: false); | 480 c = new StreamController(sync: false); |
| 481 Expect.equals(c.stream, c.stream); | 481 Expect.equals(c.stream, c.stream); |
| 482 c = new StreamController(sync: true); | 482 c = new StreamController(sync: true); |
| 483 Expect.equals(c.stream, c.stream); | 483 Expect.equals(c.stream, c.stream); |
| 484 c = new StreamController(sync: false, onListen:(){}); | 484 c = new StreamController(sync: false, onListen: () {}); |
| 485 Expect.equals(c.stream, c.stream); | 485 Expect.equals(c.stream, c.stream); |
| 486 c = new StreamController(sync: true, onListen:(){}); | 486 c = new StreamController(sync: true, onListen: () {}); |
| 487 Expect.equals(c.stream, c.stream); | 487 Expect.equals(c.stream, c.stream); |
| 488 c = new StreamController.broadcast(sync: false); | 488 c = new StreamController.broadcast(sync: false); |
| 489 Expect.equals(c.stream, c.stream); | 489 Expect.equals(c.stream, c.stream); |
| 490 c = new StreamController.broadcast(sync: true); | 490 c = new StreamController.broadcast(sync: true); |
| 491 Expect.equals(c.stream, c.stream); | 491 Expect.equals(c.stream, c.stream); |
| 492 c = new StreamController.broadcast(sync: false, onListen:(){}); | 492 c = new StreamController.broadcast(sync: false, onListen: () {}); |
| 493 Expect.equals(c.stream, c.stream); | 493 Expect.equals(c.stream, c.stream); |
| 494 c = new StreamController.broadcast(sync: true, onListen:(){}); | 494 c = new StreamController.broadcast(sync: true, onListen: () {}); |
| 495 Expect.equals(c.stream, c.stream); | 495 Expect.equals(c.stream, c.stream); |
| 496 } | 496 } |
| 497 | 497 |
| 498 void testCancelThrow() { | 498 void testCancelThrow() { |
| 499 asyncStart(); | 499 asyncStart(); |
| 500 asyncStart(); | 500 asyncStart(); |
| 501 asyncStart(); | 501 asyncStart(); |
| 502 StreamController c = new StreamController(onCancel: () { | 502 StreamController c = new StreamController(onCancel: () { |
| 503 asyncEnd(); | 503 asyncEnd(); |
| 504 throw "ERROR"; | 504 throw "ERROR"; |
| (...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 804 | 804 |
| 805 void testBroadcastSettingCallbacks() { | 805 void testBroadcastSettingCallbacks() { |
| 806 const int initial = 0; | 806 const int initial = 0; |
| 807 const int running = 1; | 807 const int running = 1; |
| 808 const int canceled = 2; | 808 const int canceled = 2; |
| 809 | 809 |
| 810 var controller = new StreamController.broadcast(); | 810 var controller = new StreamController.broadcast(); |
| 811 var stream = controller.stream; | 811 var stream = controller.stream; |
| 812 var state = initial; | 812 var state = initial; |
| 813 | 813 |
| 814 Expect.throws(() { controller.onPause = (){}; }, | 814 Expect.throws(() { controller.onPause = () {}; }, |
| 815 (e) => e is UnsupportedError); | 815 (e) => e is UnsupportedError); |
| 816 Expect.throws(() { controller.onResume = (){}; }, | 816 Expect.throws(() { controller.onResume = () {}; }, |
| 817 (e) => e is UnsupportedError); | 817 (e) => e is UnsupportedError); |
| 818 | 818 |
| 819 controller..onListen = () { state = running; } | 819 controller..onListen = () { state = running; } |
| 820 ..onCancel = () { state = canceled; }; | 820 ..onCancel = () { state = canceled; }; |
| 821 | 821 |
| 822 Expect.equals(initial, state); | 822 Expect.equals(initial, state); |
| 823 var sub = stream.listen(null); | 823 var sub = stream.listen(null); |
| 824 Expect.equals(running, state); | 824 Expect.equals(running, state); |
| 825 sub.cancel(); | 825 sub.cancel(); |
| 826 Expect.equals(canceled, state); | 826 Expect.equals(canceled, state); |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 875 testAsBroadcastListenAfterClose(); | 875 testAsBroadcastListenAfterClose(); |
| 876 testAsBroadcastListenAfterClosePaused(); | 876 testAsBroadcastListenAfterClosePaused(); |
| 877 testEventInListen(); | 877 testEventInListen(); |
| 878 testSyncControllerNotReentrant(); | 878 testSyncControllerNotReentrant(); |
| 879 testSettingCallbacks(); | 879 testSettingCallbacks(); |
| 880 testSettingNullCallbacks(); | 880 testSettingNullCallbacks(); |
| 881 testBroadcastSettingCallbacks(); | 881 testBroadcastSettingCallbacks(); |
| 882 testBroadcastSettingNullCallbacks(); | 882 testBroadcastSettingNullCallbacks(); |
| 883 asyncEnd(); | 883 asyncEnd(); |
| 884 } | 884 } |
| OLD | NEW |