Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(592)

Side by Side Diff: tests/lib/async/stream_state_test.dart

Issue 14136004: Remove StreamController.broadcast. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2013, 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 event/callback protocol of the stream implementations. 5 // Test the event/callback protocol of the stream implementations.
6 library stream_state_test; 6 library stream_state_test;
7 7
8 import "../../../pkg/unittest/lib/unittest.dart"; 8 import "../../../pkg/unittest/lib/unittest.dart";
9 import "stream_state_helper.dart"; 9 import "stream_state_helper.dart";
10 10
11 const ms5 = const Duration(milliseconds: 5); 11 const ms5 = const Duration(milliseconds: 5);
12 12
13 main() { 13 main() {
14 mainTest(false); 14 mainTest(false);
15 mainTest(true); 15 // TODO(floitsch): reenable?
16 // mainTest(true);
16 } 17 }
17 18
18 mainTest(bool broadcast) { 19 mainTest(bool broadcast) {
19 var p = broadcast ? "BC" : "SC"; 20 var p = broadcast ? "BC" : "SC";
20 test("$p-sub-data-done", () { 21 test("$p-sub-data-done", () {
21 var t = new StreamProtocolTest(broadcast); 22 var t = new StreamProtocolTest(broadcast);
22 t..expectSubscription(true, false) 23 t..expectSubscription(true, false)
23 ..expectData(42) 24 ..expectData(42)
24 ..expectDone() 25 ..expectDone()
25 ..expectSubscription(false, false); 26 ..expectSubscription(false, false);
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after
134 var t = new StreamProtocolTest(broadcast); 135 var t = new StreamProtocolTest(broadcast);
135 t..expectSubscription(true, false) 136 t..expectSubscription(true, false)
136 ..expectDone() 137 ..expectDone()
137 ..expectSubscription(false, false) 138 ..expectSubscription(false, false)
138 ..expectDone(); 139 ..expectDone();
139 t..subscribe() 140 t..subscribe()
140 ..close() 141 ..close()
141 ..subscribe(); // Subscribe after done does not cause callbacks at all. 142 ..subscribe(); // Subscribe after done does not cause callbacks at all.
142 }); 143 });
143 } 144 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698