Typecheck constructor initializers properly

test/dart_codegen/expect/async/stream_controller.dart

 part of dart.async;
  abstract class StreamController<T> implements StreamSink<T> {Stream<T> get stream;
  factory StreamController({
   void onListen(), void onPause(), void onResume(), onCancel(), bool sync : false}
 ) {
   if (onListen == null && onPause == null && onResume == null && onCancel == null) {
-    return ((__x90) => DDC$RT.cast(__x90, DDC$RT.type((_StreamController<dynamic> _) {
+    return ((__x117) => DDC$RT.cast(__x117, DDC$RT.type((_StreamController<dynamic> _) {
       }
     ), DDC$RT.type((StreamController<T> _) {
       }
-    ), "CastDynamic", """line 83, column 14 of dart:async/stream_controller.dart: """, __x90 is StreamController<T>, false))(sync ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController());
+    ), "CastDynamic", """line 83, column 14 of dart:async/stream_controller.dart: """, __x117 is StreamController<T>, false))(sync ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController());
     }
    return sync ? new _SyncStreamController<T>(onListen, onPause, onResume, onCancel) : new _AsyncStreamController<T>(onListen, onPause, onResume, onCancel);
   }
  factory StreamController.broadcast({
   void onListen(), void onCancel(), bool sync : false}
 ) {
   return sync ? new _SyncBroadcastStreamController<T>(onListen, onCancel) : new _AsyncBroadcastStreamController<T>(onListen, onCancel);
   }
  StreamSink<T> get sink;
  bool get isClosed;
@@ skipping 18 matching lines @@
  static const int _STATE_CLOSED = 4;
  static const int _STATE_ADDSTREAM = 8;
  var _varData;
  int _state = _STATE_INITIAL;
  _Future _doneFuture;
  _StreamController();
  _NotificationHandler get _onListen;
  _NotificationHandler get _onPause;
  _NotificationHandler get _onResume;
  _NotificationHandler get _onCancel;
- Stream<T> get stream => ((__x91) => DDC$RT.cast(__x91, DDC$RT.type((_ControllerStream<dynamic> _) {
+ Stream<T> get stream => ((__x118) => DDC$RT.cast(__x118, DDC$RT.type((_ControllerStream<dynamic> _) {
 }
 ), DDC$RT.type((Stream<T> _) {
 }
-), "CastExact", """line 293, column 27 of dart:async/stream_controller.dart: """, __x91 is Stream<T>, false))(new _ControllerStream(this));
+), "CastExact", """line 293, column 27 of dart:async/stream_controller.dart: """, __x118 is Stream<T>, false))(new _ControllerStream(this));
  StreamSink<T> get sink => new _StreamSinkWrapper<T>(this);
  bool get _isCanceled => (_state & _STATE_CANCELED) != 0;
  bool get hasListener => (_state & _STATE_SUBSCRIBED) != 0;
  bool get _isInitialState => (_state & _STATE_SUBSCRIPTION_MASK) == _STATE_INITIAL;
  bool get isClosed => (_state & _STATE_CLOSED) != 0;
  bool get isPaused => hasListener ? _subscription._isInputPaused : !_isCanceled;
  bool get _isAddingStream => (_state & _STATE_ADDSTREAM) != 0;
  bool get _mayAddEvent => (_state < _STATE_CLOSED);
  _PendingEvents get _pendingEvents {
 assert (_isInitialState); if (!_isAddingStream) {
@@ skipping 103 matching lines @@
 }
 ), "CastGeneral", """line 482, column 48 of dart:async/stream_controller.dart: """, _varData is _StreamControllerAddStreamState<dynamic>, true);
  _varData = addState.varData;
  _state &= ~_STATE_ADDSTREAM;
  addState.complete();
 }
  StreamSubscription<T> _subscribe(void onData(T data), Function onError, void onDone(), bool cancelOnError) {
 if (!_isInitialState) {
 throw new StateError("Stream has already been listened to.");
 }
- _ControllerSubscription subscription = new _ControllerSubscription(this, onData, onError, onDone, cancelOnError);
+ _ControllerSubscription subscription = new _ControllerSubscription(this, DDC$RT.wrap((void f(T __u119)) {
+void c(T x0) => f(DDC$RT.cast(x0, dynamic, T, "CastParam", """line 499, column 43 of dart:async/stream_controller.dart: """, x0 is T, false));
+ return f == null ? null : c;
+}
+, onData, DDC$RT.type((__t122<T> _) {
+}
+), __t120, "Wrap", """line 499, column 43 of dart:async/stream_controller.dart: """, onData is __t120), onError, onDone, cancelOnError);
  _PendingEvents pendingEvents = _pendingEvents;
  _state |= _STATE_SUBSCRIBED;
  if (_isAddingStream) {
 _StreamControllerAddStreamState addState = DDC$RT.cast(_varData, dynamic, DDC$RT.type((_StreamControllerAddStreamState<dynamic> _) {
   }
 ), "CastGeneral", """line 505, column 50 of dart:async/stream_controller.dart: """, _varData is _StreamControllerAddStreamState<dynamic>, true);
  addState.varData = subscription;
  addState.resume();
 }
  else {
@@ skipping 16 matching lines @@
 _StreamControllerAddStreamState addState = DDC$RT.cast(_varData, dynamic, DDC$RT.type((_StreamControllerAddStreamState<dynamic> _) {
   }
 ), "CastGeneral", """line 530, column 50 of dart:async/stream_controller.dart: """, _varData is _StreamControllerAddStreamState<dynamic>, true);
  result = addState.cancel();
 }
  _varData = null;
  _state = (_state & ~(_STATE_SUBSCRIBED | _STATE_ADDSTREAM)) | _STATE_CANCELED;
  if (_onCancel != null) {
 if (result == null) {
   try {
-    result = ((__x92) => DDC$RT.cast(__x92, dynamic, DDC$RT.type((Future<dynamic> _) {
+    result = ((__x124) => DDC$RT.cast(__x124, dynamic, DDC$RT.type((Future<dynamic> _) {
       }
-    ), "CastGeneral", """line 542, column 20 of dart:async/stream_controller.dart: """, __x92 is Future<dynamic>, true))(_onCancel());
+    ), "CastGeneral", """line 542, column 20 of dart:async/stream_controller.dart: """, __x124 is Future<dynamic>, true))(_onCancel());
     }
    catch (e, s) {
     result = new _Future().._asyncCompleteError(e, s);
     }
   }
  else {
   result = result.whenComplete(_onCancel);
   }
 }
  void complete() {
@@ skipping 115 matching lines @@
 _target.addError(error, stackTrace);
 }
  Future close() => _target.close();
  Future addStream(Stream<T> source, {
 bool cancelOnError : true}
 ) => _target.addStream(source, cancelOnError: cancelOnError);
  Future get done => _target.done;
 }
  class _AddStreamState<T> {final _Future addStreamFuture;
  final StreamSubscription addSubscription;
- _AddStreamState(_EventSink<T> controller, Stream source, bool cancelOnError) : addStreamFuture = new _Future(), addSubscription = source.listen(DDC$RT.wrap((void f(T __u93)) {
+ _AddStreamState(_EventSink<T> controller, Stream source, bool cancelOnError) : addStreamFuture = new _Future(), addSubscription = source.listen(DDC$RT.wrap((void f(T __u125)) {
 void c(T x0) => f(DDC$RT.cast(x0, dynamic, T, "CastParam", """line 745, column 41 of dart:async/stream_controller.dart: """, x0 is T, false));
  return f == null ? null : c;
 }
-, controller._add, DDC$RT.type((__t96<T> _) {
+, controller._add, DDC$RT.type((__t126<T> _) {
 }
-), __t94, "Wrap", """line 745, column 41 of dart:async/stream_controller.dart: """, controller._add is __t94), onError: ((__x98) => DDC$RT.cast(__x98, dynamic, Function, "CastGeneral", """line 746, column 50 of dart:async/stream_controller.dart: """, __x98 is Function, true))(cancelOnError ? makeErrorHandler(controller) : controller._addError), onDone: controller._close, cancelOnError: cancelOnError);
+), __t120, "Wrap", """line 745, column 41 of dart:async/stream_controller.dart: """, controller._add is __t120), onError: ((__x128) => DDC$RT.cast(__x128, dynamic, Function, "CastGeneral", """line 746, column 50 of dart:async/stream_controller.dart: """, __x128 is Function, true))(cancelOnError ? makeErrorHandler(controller) : controller._addError), onDone: controller._close, cancelOnError: cancelOnError);
  static makeErrorHandler(_EventSink controller) => (e, StackTrace s) {
 controller._addError(e, s);
  controller._close();
 }
 ;
  void pause() {
 addSubscription.pause();
 }
  void resume() {
 addSubscription.resume();
@@ skipping 17 matching lines @@
  _StreamControllerAddStreamState(_StreamController controller, this.varData, Stream source, bool cancelOnError) : super(DDC$RT.cast(controller, DDC$RT.type((_StreamController<dynamic> _) {
 }
 ), DDC$RT.type((_EventSink<T> _) {
 }
 ), "CastDynamic", """line 798, column 15 of dart:async/stream_controller.dart: """, controller is _EventSink<T>, false), source, cancelOnError) {
 if (controller.isPaused) {
 addSubscription.pause();
 }
 }
 }
- typedef void __t94(dynamic __u95);
- typedef void __t96<T>(T __u97);
+ typedef void __t120(dynamic __u121);
+ typedef void __t122<T>(T __u123);
+ typedef void __t126<T>(T __u127);