Index: test/stream_zip_test.dart |
diff --git a/test/stream_zip_test.dart b/test/stream_zip_test.dart |
index 9606b924029f6c642e4873043cce0c2ae8d40c38..35ace7d12815529052e394d699aa7c3a3117407a 100644 |
--- a/test/stream_zip_test.dart |
+++ b/test/stream_zip_test.dart |
@@ -155,8 +155,6 @@ main() { |
}); |
test("Pause/Resume", () { |
- var done = expectAsync((){}); // Call to complete test. |
- |
int sc1p = 0; |
StreamController c1 = new StreamController( |
onPause: () { |
@@ -174,6 +172,12 @@ main() { |
onResume: () { |
sc2p--; |
}); |
+ |
+ var done = expectAsync((){ |
+ expect(sc1p, equals(1)); |
+ expect(sc2p, equals(0)); |
+ }); // Call to complete test. |
nweiz
2015/07/01 00:47:24
Why are these expects added?
|
+ |
Stream zip = new StreamZip([c1.stream, c2.stream]); |
const ms25 = const Duration(milliseconds: 25); |