dart-lang/async: Fix types in typed_wrapper/stream_test.dart

test/typed_wrapper/stream_test.dart

 // Copyright (c) 2016, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 import 'dart:async';
 
 import "package:async/src/typed/stream.dart";
 import "package:test/test.dart";
 
 import '../utils.dart';
 
 void main() {
   group("with valid types, forwards", () {
     var controller;
     var wrapper;
     var emptyWrapper;
     var singleWrapper;
     var errorWrapper;
     setUp(() {
-      controller = new StreamController<Object>()
+      controller = new StreamController<int>()
         ..add(1)
         ..add(2)
         ..add(3)
         ..add(4)
         ..add(5)
         ..close();
 
       // TODO(nweiz): Use public methods when test#414 is fixed and we can run
       // this on DDC.
       wrapper = new TypeSafeStream<int>(controller.stream);
       emptyWrapper = new TypeSafeStream<int>(new Stream<Object>.empty());
       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", () {
       expect(wrapper.first, completion(equals(1)));
       expect(emptyWrapper.first, throwsStateError);
     });
 
     test("last", () {
       expect(wrapper.last, completion(equals(5)));
       expect(emptyWrapper.last, throwsStateError);
@@ skipping 62 matching lines @@
           completion(equals([2, 4, 6, 8, 10])));
     });
 
     group("distinct()", () {
       test("without equals", () {
         expect(
             wrapper.distinct().toList(), completion(equals([1, 2, 3, 4, 5])));
 
         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])));
       });
 
       test("with equals", () {
         expect(wrapper.distinct((i1, i2) => (i1 ~/ 2 == i2 ~/ 2)).toList(),
             completion(equals([1, 2, 4])));
       });
     });
@@ skipping 143 matching lines @@
 
     test("takeWhile()", () {
       expect(
           wrapper.takeWhile((i) => i < 3).toList(), completion(equals([1, 2])));
     });
 
     test("toSet()", () {
       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])));
     });
 
     test("transform()", () {
       var transformer = new StreamTransformer<int, String>.fromHandlers(
           handleData: (data, sink) {
         sink.add(data.toString());
       });
 
       expect(wrapper.transform(transformer).toList(),
@@ skipping 306 matching lines @@
           expect(wrapper.join(" "), completion(equals("foo bar baz")));
         });
       });
 
       test("toString()", () {
         expect(wrapper.toString(), contains("Stream"));
       });
     });
   });
 }