SDK fixes

test/dart_codegen/expect/async/broadcast_stream_controller.dart

 part of dart.async;
  class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_StreamControllerLifecycle controller) : super(DEVC$RT.cast(controller, DEVC$RT.type((_StreamControllerLifecycle<dynamic> _) {
   }
 ), DEVC$RT.type((_StreamControllerLifecycle<T> _) {
   }
 ), "CompositeCast", """line 8, column 67 of dart:async/broadcast_stream_controller.dart: """, controller is _StreamControllerLifecycle<T>, false));
  bool get isBroadcast => true;
 }
  abstract class _BroadcastSubscriptionLink {_BroadcastSubscriptionLink _next;
  _BroadcastSubscriptionLink _previous;
 }
  class _BroadcastSubscription<T> extends _ControllerSubscription<T> implements _BroadcastSubscriptionLink {static const int _STATE_EVENT_ID = 1;
  static const int _STATE_FIRING = 2;
  static const int _STATE_REMOVE_AFTER_FIRING = 4;
  int _eventState;
  _BroadcastSubscriptionLink _next;
  _BroadcastSubscriptionLink _previous;
  _BroadcastSubscription(_StreamControllerLifecycle controller, void onData(T data), Function onError, void onDone(), bool cancelOnError) : super(DEVC$RT.cast(controller, DEVC$RT.type((_StreamControllerLifecycle<dynamic> _) {
 }
 ), DEVC$RT.type((_StreamControllerLifecycle<T> _) {
 }
 ), "CompositeCast", """line 36, column 15 of dart:async/broadcast_stream_controller.dart: """, controller is _StreamControllerLifecycle<T>, false), onData, onError, onDone, cancelOnError) {
 _next = _previous = this;
 }
- _BroadcastStreamController get _controller => ((__x2) => DEVC$RT.cast(__x2, DEVC$RT.type((_StreamControllerLifecycle<T> _) {
+ _BroadcastStreamController<T> get _controller => ((__x2) => DEVC$RT.cast(__x2, DEVC$RT.type((_StreamControllerLifecycle<T> _) {
 }
-), DEVC$RT.type((_BroadcastStreamController<dynamic> _) {
+), DEVC$RT.type((_BroadcastStreamController<T> _) {
 }
-), "ImplicitCast", """line 40, column 49 of dart:async/broadcast_stream_controller.dart: """, __x2 is _BroadcastStreamController<dynamic>, true))(super._controller);
+), "CompositeCast", """line 40, column 52 of dart:async/broadcast_stream_controller.dart: """, __x2 is _BroadcastStreamController<T>, false))(super._controller);
  bool _expectsEvent(int eventId) => (_eventState & _STATE_EVENT_ID) == eventId;
  void _toggleEventId() {
 _eventState ^= _STATE_EVENT_ID;
 }
  bool get _isFiring => (_eventState & _STATE_FIRING) != 0;
  void _setRemoveAfterFiring() {
 assert (_isFiring); _eventState |= _STATE_REMOVE_AFTER_FIRING;
 }
  bool get _removeAfterFiring => (_eventState & _STATE_REMOVE_AFTER_FIRING) != 0;
  void _onPause() {
@@ skipping 59 matching lines @@
 ), "CompositeCast", """line 196, column 18 of dart:async/broadcast_stream_controller.dart: """, subscription is _BroadcastSubscription<T>, false));
  if (identical(_next, _previous)) {
 _runGuarded(_onListen);
 }
  return DEVC$RT.cast(subscription, DEVC$RT.type((StreamSubscription<dynamic> _) {
 }
 ), DEVC$RT.type((StreamSubscription<T> _) {
 }
 ), "CompositeCast", """line 201, column 12 of dart:async/broadcast_stream_controller.dart: """, subscription is StreamSubscription<T>, false);
 }
- Future _recordCancel(_BroadcastSubscription<T> subscription) {
+ Future _recordCancel(StreamSubscription<T> subscription) {
 if (identical(subscription._next, subscription)) return null;
  assert (!identical(subscription._next, subscription)); if (subscription._isFiring) {
 subscription._setRemoveAfterFiring();
 }
  else {
-assert (!identical(subscription._next, subscription)); _removeListener(subscription);
+assert (!identical(subscription._next, subscription)); _removeListener(DEVC$RT.cast(subscription, DEVC$RT.type((StreamSubscription<T> _) {
+}
+), DEVC$RT.type((_BroadcastSubscription<T> _) {
+}
+), "CompositeCast", """line 212, column 23 of dart:async/broadcast_stream_controller.dart: """, subscription is _BroadcastSubscription<T>, false));
  if (!_isFiring && _isEmpty) {
 _callOnCancel();
 }
 }
  return null;
 }
  void _recordPause(StreamSubscription<T> subscription) {
 }
  void _recordResume(StreamSubscription<T> subscription) {
 }
@@ skipping 219 matching lines @@
 if (_pauseCount > 0) _pauseCount--;
 }
  Future cancel() {
 return new _Future.immediate(null);
 }
  bool get isPaused => _pauseCount > 0;
  Future asFuture([Object value]) => new _Future();
 }
  typedef void __CastType3<T>(_BufferingStreamSubscription<T> __u4);
  typedef dynamic __CastType5<T>(_BroadcastSubscription<T> __u6);