| 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();
|
|
|