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 2aac0009c550dbdb416582369fd259923d1dc37d..9356064f1157c5292cad4be04870b443bb537ec2 100644 |
--- a/tests/lib/async/stream_state_nonzero_timer_test.dart |
+++ b/tests/lib/async/stream_state_nonzero_timer_test.dart |
@@ -22,81 +22,104 @@ main() { |
test("$p-sub-data/pause/resume/pause/resume-done", () { |
var t = new StreamProtocolTest(); |
- t..expectListen() |
- ..expectData(42, () { |
- t.pause(); |
- }) |
- ..expectPause(() { t.resume(); }) |
- ..expectResume(() { t.pause(); }) |
- ..expectPause(() { t.resume(); }) |
- ..expectResume(() { t.close(); }) |
- ..expectCancel() |
- ..expectDone(t.terminate); |
- t..listen()..add(42); |
+ t |
+ ..expectListen() |
+ ..expectData(42, () { |
+ t.pause(); |
+ }) |
+ ..expectPause(() { |
+ t.resume(); |
+ }) |
+ ..expectResume(() { |
+ t.pause(); |
+ }) |
+ ..expectPause(() { |
+ t.resume(); |
+ }) |
+ ..expectResume(() { |
+ t.close(); |
+ }) |
+ ..expectCancel() |
+ ..expectDone(t.terminate); |
+ t |
+ ..listen() |
+ ..add(42); |
}); |
test("$p-sub-data/pause-done", () { |
var t = new StreamProtocolTest(); |
- t..expectListen() |
- ..expectData(42, () { |
- t.pause(new Future.delayed(ms5, () => null)); |
- }) |
- ..expectPause() |
- ..expectCancel() |
- ..expectDone(t.terminate); |
- // We are calling "close" while the controller is actually paused, |
- // and it will stay paused until the pending events are sent. |
- t..listen()..add(42)..close(); |
+ t |
+ ..expectListen() |
+ ..expectData(42, () { |
+ t.pause(new Future.delayed(ms5, () => null)); |
+ }) |
+ ..expectPause() |
+ ..expectCancel() |
+ ..expectDone(t.terminate); |
+ // We are calling "close" while the controller is actually paused, |
+ // and it will stay paused until the pending events are sent. |
+ t |
+ ..listen() |
+ ..add(42) |
+ ..close(); |
}); |
test("$p-sub-data/pause-resume/done", () { |
var t = new StreamProtocolTest(); |
- t..expectListen() |
- ..expectData(42, () { |
- t.pause(new Future.delayed(ms5, () => null)); |
- }) |
- ..expectPause() |
- ..expectResume(t.close) |
- ..expectCancel() |
- ..expectDone(t.terminate); |
- t..listen()..add(42); |
+ t |
+ ..expectListen() |
+ ..expectData(42, () { |
+ t.pause(new Future.delayed(ms5, () => null)); |
+ }) |
+ ..expectPause() |
+ ..expectResume(t.close) |
+ ..expectCancel() |
+ ..expectDone(t.terminate); |
+ t |
+ ..listen() |
+ ..add(42); |
}); |
test("$p-sub-data/data+pause-data-resume-done", () { |
var t = new StreamProtocolTest(); |
- t..expectListen() |
- ..expectData(42, () { |
- t.add(43); |
- t.pause(new Future.delayed(ms5, () => null)); |
- // Should now be paused until the future finishes. |
- // After that, the controller stays paused until the pending queue |
- // is empty. |
- }) |
- ..expectPause() |
- ..expectData(43) |
- ..expectResume(t.close) |
- ..expectCancel() |
- ..expectDone(t.terminate); |
- t..listen()..add(42); |
+ t |
+ ..expectListen() |
+ ..expectData(42, () { |
+ t.add(43); |
+ t.pause(new Future.delayed(ms5, () => null)); |
+ // Should now be paused until the future finishes. |
+ // After that, the controller stays paused until the pending queue |
+ // is empty. |
+ }) |
+ ..expectPause() |
+ ..expectData(43) |
+ ..expectResume(t.close) |
+ ..expectCancel() |
+ ..expectDone(t.terminate); |
+ t |
+ ..listen() |
+ ..add(42); |
}); |
test("$p-pause-during-callback", () { |
var t = new StreamProtocolTest(); |
- t..expectListen() |
- ..expectData(42, () { |
- t.pause(); |
- }) |
- ..expectPause(() { |
- t.resume(); |
- }) |
- ..expectResume(() { |
- t.pause(); |
- t.resume(); |
- t.close(); |
- }) |
- ..expectCancel() |
- ..expectDone(t.terminate); |
- t..listen() |
- ..add(42); |
+ t |
+ ..expectListen() |
+ ..expectData(42, () { |
+ t.pause(); |
+ }) |
+ ..expectPause(() { |
+ t.resume(); |
+ }) |
+ ..expectResume(() { |
+ t.pause(); |
+ t.resume(); |
+ t.close(); |
+ }) |
+ ..expectCancel() |
+ ..expectDone(t.terminate); |
+ t |
+ ..listen() |
+ ..add(42); |
}); |
} |