Index: test/subscription_stream_test.dart |
diff --git a/test/subscription_stream_test.dart b/test/subscription_stream_test.dart |
index 0d1870b2cf52cbbb87d749e62f75b22f5e8419f2..699babeea0375638aa49668e8948068e24a72a80 100644 |
--- a/test/subscription_stream_test.dart |
+++ b/test/subscription_stream_test.dart |
@@ -22,7 +22,7 @@ main() { |
var stream = createStream(); |
var skips = 0; |
var completer = new Completer(); |
- var subscription; |
+ StreamSubscription<int> subscription; |
subscription = stream.listen((value) { |
++skips; |
expect(value, skips); |
@@ -168,7 +168,7 @@ Stream<int> createErrorStream([Completer onCancel]) async* { |
await flushMicrotasks(); |
yield 2; |
await flushMicrotasks(); |
- yield* new Future.error("To err is divine!").asStream(); |
+ yield* new Future<int>.error("To err is divine!").asStream(); |
await flushMicrotasks(); |
yield 4; |
await flushMicrotasks(); |