Downward inference

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;
@@ skipping 141 matching lines @@
  Future doneFuture = _ensureDoneFuture();
  _sendDone();
  return doneFuture;
 }
  Future get done => _ensureDoneFuture();
  Future addStream(Stream<T> stream, {
 bool cancelOnError : true}
 ) {
 if (!_mayAddEvent) throw _addEventError();
  _state |= _STATE_ADDSTREAM;
- _addStreamState = ((__x3) => DEVC$RT.cast(__x3, DEVC$RT.type((_AddStreamState<dynamic> _) {
-}
-), DEVC$RT.type((_AddStreamState<T> _) {
-}
-), "InferableAllocation", """line 268, column 23 of dart:async/broadcast_stream_controller.dart: """, __x3 is _AddStreamState<T>, false))(new _AddStreamState(this, stream, cancelOnError));
+ _addStreamState = new _AddStreamState<T>(this, stream, cancelOnError);
  return _addStreamState.addStreamFuture;
 }
  void _add(T data) {
 _sendData(data);
 }
  void _addError(Object error, StackTrace stackTrace) {
 _sendError(error, stackTrace);
 }
  void _close() {
 assert (_isAddingStream); _AddStreamState addState = _addStreamState;
@@ skipping 57 matching lines @@
 );
 }
  void _sendError(Object error, StackTrace stackTrace) {
 if (_isEmpty) return; _forEachListener((_BufferingStreamSubscription<T> subscription) {
 subscription._addError(error, stackTrace);
 }
 );
 }
  void _sendDone() {
 if (!_isEmpty) {
-_forEachListener(((__x9) => DEVC$RT.wrap((dynamic f(_BroadcastSubscription<T> __u4)) {
+_forEachListener(((__x8) => DEVC$RT.wrap((dynamic f(_BroadcastSubscription<T> __u3)) {
 dynamic c(_BroadcastSubscription<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((_BufferingStreamSubscription<T> _) {
 }
 ), DEVC$RT.type((_BroadcastSubscription<T> _) {
 }
 ), "CastParam", """line 372, column 24 of dart:async/broadcast_stream_controller.dart: """, x0 is _BroadcastSubscription<T>, false));
  return f == null ? null : c;
 }
-, __x9, DEVC$RT.type((__t7<T> _) {
+, __x8, DEVC$RT.type((__t6<T> _) {
 }
-), DEVC$RT.type((__t5<T> _) {
+), DEVC$RT.type((__t4<T> _) {
 }
-), "WrapLiteral", """line 372, column 24 of dart:async/broadcast_stream_controller.dart: """, __x9 is __t5<T>))((_BroadcastSubscription<T> subscription) {
+), "WrapLiteral", """line 372, column 24 of dart:async/broadcast_stream_controller.dart: """, __x8 is __t4<T>))((_BroadcastSubscription<T> subscription) {
 subscription._close();
 }
 ));
 }
  else {
 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._asyncComplete(null);
 }
 }
 }
  class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onListen, onCancel);
@@ skipping 88 matching lines @@
 }
  void _resume(_) {
 if (_pauseCount > 0) _pauseCount--;
 }
  Future cancel() {
 return new _Future.immediate(null);
 }
  bool get isPaused => _pauseCount > 0;
  Future asFuture([Object value]) => new _Future();
 }
- typedef void __t5<T>(_BufferingStreamSubscription<T> __u6);
- typedef dynamic __t7<T>(_BroadcastSubscription<T> __u8);
+ typedef void __t4<T>(_BufferingStreamSubscription<T> __u5);
+ typedef dynamic __t6<T>(_BroadcastSubscription<T> __u7);