| Index: test/typed_wrapper/stream_test.dart
|
| diff --git a/test/typed_wrapper/stream_test.dart b/test/typed_wrapper/stream_test.dart
|
| index 88fbee65cfc884d51476c5749fdaa80d6d49e03c..d6bb96ee84dd157cb6ccca30b1ac278645e23068 100644
|
| --- a/test/typed_wrapper/stream_test.dart
|
| +++ b/test/typed_wrapper/stream_test.dart
|
| @@ -17,7 +17,7 @@ void main() {
|
| var singleWrapper;
|
| var errorWrapper;
|
| setUp(() {
|
| - controller = new StreamController<Object>()
|
| + controller = new StreamController<int>()
|
| ..add(1)
|
| ..add(2)
|
| ..add(3)
|
| @@ -32,7 +32,7 @@ void main() {
|
| singleWrapper =
|
| new TypeSafeStream<int>(new Stream<Object>.fromIterable([1]));
|
| errorWrapper = new TypeSafeStream<int>(
|
| - new Stream<Object>.fromFuture(new Future.error("oh no")));
|
| + new Stream<int>.fromFuture(new Future.error("oh no")));
|
| });
|
|
|
| test("first", () {
|
| @@ -115,7 +115,7 @@ void main() {
|
|
|
| expect(
|
| new TypeSafeStream<int>(
|
| - new Stream<Object>.fromIterable([1, 1, 2, 2, 3, 3]))
|
| + new Stream<int>.fromIterable([1, 1, 2, 2, 3, 3]))
|
| .distinct()
|
| .toList(),
|
| completion(equals([1, 2, 3])));
|
| @@ -279,7 +279,7 @@ void main() {
|
| expect(wrapper.toSet(), completion(unorderedEquals([1, 2, 3, 4, 5])));
|
| expect(
|
| new TypeSafeStream<int>(
|
| - new Stream<Object>.fromIterable([1, 1, 2, 2, 3, 3])).toSet(),
|
| + new Stream<int>.fromIterable([1, 1, 2, 2, 3, 3])).toSet(),
|
| completion(unorderedEquals([1, 2, 3])));
|
| });
|
|
|
|
|