Inference through conditional expressions

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 ((__x46) => DEVC$RT.cast(__x46, DEVC$RT.type((_StreamController<dynamic> _) {
       }
     ), DEVC$RT.type((StreamController<T> _) {
       }
@@ skipping 328 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(controller._add, onError: ((__x48) => DEVC$RT.cast(__x48, dynamic, Function, "DynamicCast", """line 746, column 50 of dart:async/stream_controller.dart: """, __x48 is Function, true))(cancelOnError ? makeErrorHandler(controller) : controller._addError), onDone: controller._close, cancelOnError: cancelOnError);
+ _AddStreamState(_EventSink<T> controller, Stream source, bool cancelOnError) : addStreamFuture = new _Future(), addSubscription = source.listen(controller._add, onError: cancelOnError ? ((__x48) => DEVC$RT.cast(__x48, dynamic, Function, "DynamicCast", """line 747, column 48 of dart:async/stream_controller.dart: """, __x48 is Function, true))(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(DEVC$RT.cast(controller, DEVC$RT.type((_StreamController<dynamic> _) {
 }
 ), DEVC$RT.type((_EventSink<T> _) {
 }
 ), "CompositeCast", """line 798, column 15 of dart:async/stream_controller.dart: """, controller is _EventSink<T>, false), source, cancelOnError) {
 if (controller.isPaused) {
 addSubscription.pause();
 }
 }
 }