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

Unified Diff: tests/lib/async/stream_state_nonzero_timer_test.dart

Issue 16125005: Make new StreamController be async by default. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 7 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 side-by-side diff with in-line comments
Download patch
Index: tests/lib/async/stream_state_nonzero_timer_test.dart
diff --git a/tests/lib/async/stream_state_nonzero_timer_test.dart b/tests/lib/async/stream_state_nonzero_timer_test.dart
index 0beff6f37de315853bbef0e726763e6a379bf100..38c14a6790454a3c57ef4b79f7cd5fc8af4af6aa 100644
--- a/tests/lib/async/stream_state_nonzero_timer_test.dart
+++ b/tests/lib/async/stream_state_nonzero_timer_test.dart
@@ -23,8 +23,8 @@ mainTest(bool broadcast) {
var p = broadcast ? "BC" : "SC";
test("$p-sub-data/pause/resume/pause/resume-done", () {
- var t = new StreamProtocolTest(broadcast);
- t..expectSubscription()
+ var t = new StreamProtocolTest(broadcast: broadcast);
+ t..expectListen()
..expectData(42, () {
t.pause();
})
@@ -34,12 +34,12 @@ mainTest(bool broadcast) {
..expectResume(() { t.close(); })
..expectDone()
..expectCancel();
- t..subscribe()..add(42);
+ t..listen()..add(42);
});
test("$p-sub-data/pause-done", () {
- var t = new StreamProtocolTest(broadcast);
- t..expectSubscription()
+ var t = new StreamProtocolTest(broadcast: broadcast);
+ t..expectListen()
..expectData(42, () {
t.pause(new Future.delayed(ms5, () => null));
})
@@ -48,12 +48,12 @@ mainTest(bool broadcast) {
..expectCancel();
// We are calling "close" while the controller is actually paused,
// and it will stay paused until the pending events are sent.
- t..subscribe()..add(42)..close();
+ t..listen()..add(42)..close();
});
test("$p-sub-data/pause-resume/done", () {
- var t = new StreamProtocolTest(broadcast);
- t..expectSubscription()
+ var t = new StreamProtocolTest(broadcast: broadcast);
+ t..expectListen()
..expectData(42, () {
t.pause(new Future.delayed(ms5, () => null));
})
@@ -61,12 +61,12 @@ mainTest(bool broadcast) {
..expectResume(t.close)
..expectDone()
..expectCancel();
- t..subscribe()..add(42);
+ t..listen()..add(42);
});
test("$p-sub-data/data+pause-data-resume-done", () {
- var t = new StreamProtocolTest(broadcast);
- t..expectSubscription()
+ var t = new StreamProtocolTest(broadcast: broadcast);
+ t..expectListen()
..expectData(42, () {
t.add(43);
t.pause(new Future.delayed(ms5, () => null));
@@ -79,12 +79,12 @@ mainTest(bool broadcast) {
..expectResume(t.close)
..expectDone()
..expectCancel();
- t..subscribe()..add(42);
+ t..listen()..add(42);
});
-return;
+
test("$p-pause-during-callback", () {
- var t = new StreamProtocolTest(broadcast);
- t..expectSubscription()
+ var t = new StreamProtocolTest(broadcast: broadcast);
+ t..expectListen()
..expectData(42, () {
t.pause();
})
@@ -98,7 +98,7 @@ return;
})
..expectDone()
..expectCancel();
- t..subscribe()
+ t..listen()
..add(42);
});
}

Powered by Google App Engine
This is Rietveld 408576698