Rationalize coercions

test/dart_codegen/expect/async/stream.dart

 part of dart.async;
  abstract class Stream<T> {Stream();
  factory Stream.fromFuture(Future<T> future) {
   _StreamController<T> controller = ((__x29) => DEVC$RT.cast(__x29, DEVC$RT.type((StreamController<T> _) {
     }
   ), DEVC$RT.type((_StreamController<T> _) {
     }
-  ), "CastExact", """line 87, column 39 of dart:async/stream.dart: """, __x29 is _StreamController<T>, false))(new StreamController<T>(sync: true));
+  ), "InferableAllocation", """line 87, column 39 of dart:async/stream.dart: """, __x29 is _StreamController<T>, false))(new StreamController<T>(sync: true));
    future.then(((__x35) => DEVC$RT.wrap((dynamic f(dynamic __u30)) {
     dynamic c(dynamic x0) => f(x0);
      return f == null ? null : c;
     }
   , __x35, __t33, DEVC$RT.type((__t31<T> _) {
     }
   ), "WrapLiteral", """line 88, column 17 of dart:async/stream.dart: """, __x35 is __t31<T>))((value) {
-    controller._add(DEVC$RT.cast(value, dynamic, T, "CastGeneral", """line 89, column 25 of dart:async/stream.dart: """, value is T, false));
+    controller._add(DEVC$RT.cast(value, dynamic, T, "CompositeCast", """line 89, column 25 of dart:async/stream.dart: """, value is T, false));
      controller._closeUnchecked();
     }
   ), onError: (error, stackTrace) {
-    controller._addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace, "CastGeneral", """line 93, column 37 of dart:async/stream.dart: """, stackTrace is StackTrace, true));
+    controller._addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace, "DynamicCast", """line 93, column 37 of dart:async/stream.dart: """, stackTrace is StackTrace, true));
      controller._closeUnchecked();
     }
   );
    return controller.stream;
   }
  factory Stream.fromIterable(Iterable<T> data) {
   return new _GeneratedStreamImpl<T>(() => new _IterablePendingEvents<T>(data));
   }
  factory Stream.periodic(Duration period, [T computation(int computationCount)]) {
   if (computation == null) computation = ((__x41) => DEVC$RT.wrap((dynamic f(dynamic __u36)) {
@@ skipping 42 matching lines @@
      timer = null;
     }
   );
    return controller.stream;
   }
  factory Stream.eventTransformed(Stream source, EventSink mapSink(EventSink<T> sink)) {
   return ((__x42) => DEVC$RT.cast(__x42, DEVC$RT.type((_BoundSinkStream<dynamic, dynamic> _) {
     }
   ), DEVC$RT.type((Stream<T> _) {
     }
-  ), "CastExact", """line 216, column 12 of dart:async/stream.dart: """, __x42 is Stream<T>, false))(new _BoundSinkStream(source, DEVC$RT.wrap((EventSink<dynamic> f(EventSink<T> __u43)) {
+  ), "InferableAllocation", """line 216, column 12 of dart:async/stream.dart: """, __x42 is Stream<T>, false))(new _BoundSinkStream(source, DEVC$RT.wrap((EventSink<dynamic> f(EventSink<T> __u43)) {
     EventSink<dynamic> c(EventSink<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((EventSink<dynamic> _) {
       }
     ), DEVC$RT.type((EventSink<T> _) {
       }
     ), "CastParam", """line 216, column 41 of dart:async/stream.dart: """, x0 is EventSink<T>, false));
      return f == null ? null : c;
     }
   , mapSink, DEVC$RT.type((__t46<T> _) {
     }
   ), __t44, "Wrap", """line 216, column 41 of dart:async/stream.dart: """, mapSink is __t44)));
@@ skipping 49 matching lines @@
         controller.addError(e, s);
          return;}
        if (newValue is Future) {
         subscription.pause();
          newValue.then(add, onError: addError).whenComplete(subscription.resume);
         }
        else {
         controller.add(newValue);
         }
       }
-    , onError: DEVC$RT.cast(addError, dynamic, Function, "CastGeneral", """line 338, column 20 of dart:async/stream.dart: """, addError is Function, true), onDone: controller.close);
+    , onError: DEVC$RT.cast(addError, dynamic, Function, "DynamicCast", """line 338, column 20 of dart:async/stream.dart: """, addError is Function, true), onDone: controller.close);
     }
    if (this.isBroadcast) {
     controller = new StreamController.broadcast(onListen: onListen, onCancel: () {
       subscription.cancel();
       }
     , sync: true);
     }
    else {
     controller = new StreamController(onListen: onListen, onPause: () {
       subscription.pause();
@@ skipping 19 matching lines @@
         newStream = convert(event);
         }
        catch (e, s) {
         controller.addError(e, s);
          return;}
        if (newStream != null) {
         subscription.pause();
          controller.addStream(newStream).whenComplete(subscription.resume);
         }
       }
-    , onError: DEVC$RT.cast(eventSink._addError, dynamic, Function, "CastGeneral", """line 395, column 20 of dart:async/stream.dart: """, eventSink._addError is Function, true), onDone: controller.close);
+    , onError: DEVC$RT.cast(eventSink._addError, dynamic, Function, "DynamicCast", """line 395, column 20 of dart:async/stream.dart: """, eventSink._addError is Function, true), onDone: controller.close);
     }
    if (this.isBroadcast) {
     controller = new StreamController.broadcast(onListen: onListen, onCancel: () {
       subscription.cancel();
       }
     , sync: true);
     }
    else {
     controller = new StreamController(onListen: onListen, onPause: () {
       subscription.pause();
@@ skipping 25 matching lines @@
  Future<T> reduce(T combine(T previous, T element)) {
   _Future<T> result = new _Future<T>();
    bool seenFirst = false;
    T value;
    StreamSubscription subscription;
    subscription = this.listen((T element) {
     if (seenFirst) {
       _runUserCode(() => combine(value, element), (T newValue) {
         value = newValue;
         }
-      , ((__x57) => DEVC$RT.cast(__x57, dynamic, __t54, "CastGeneral", """line 501, column 24 of dart:async/stream.dart: """, __x57 is __t54, false))(_cancelAndErrorClosure(subscription, result)));
+      , ((__x57) => DEVC$RT.cast(__x57, dynamic, __t54, "CompositeCast", """line 501, column 24 of dart:async/stream.dart: """, __x57 is __t54, false))(_cancelAndErrorClosure(subscription, result)));
       }
      else {
       value = element;
        seenFirst = true;
       }
     }
   , onError: result._completeError, onDone: () {
     if (!seenFirst) {
       try {
         throw IterableElementError.noElement();
@@ skipping 10 matching lines @@
    return result;
   }
  Future fold(var initialValue, combine(var previous, T element)) {
   _Future result = new _Future();
    var value = initialValue;
    StreamSubscription subscription;
    subscription = this.listen((T element) {
     _runUserCode(() => combine(value, element), (newValue) {
       value = newValue;
       }
-    , ((__x58) => DEVC$RT.cast(__x58, dynamic, __t54, "CastGeneral", """line 534, column 11 of dart:async/stream.dart: """, __x58 is __t54, false))(_cancelAndErrorClosure(subscription, result)));
+    , ((__x58) => DEVC$RT.cast(__x58, dynamic, __t54, "CompositeCast", """line 534, column 11 of dart:async/stream.dart: """, __x58 is __t54, false))(_cancelAndErrorClosure(subscription, result)));
     }
   , onError: (e, st) {
-    result._completeError(e, DEVC$RT.cast(st, dynamic, StackTrace, "CastGeneral", """line 538, column 34 of dart:async/stream.dart: """, st is StackTrace, true));
+    result._completeError(e, DEVC$RT.cast(st, dynamic, StackTrace, "DynamicCast", """line 538, column 34 of dart:async/stream.dart: """, st is StackTrace, true));
     }
   , onDone: () {
     result._complete(value);
     }
   , cancelOnError: true);
    return result;
   }
  Future<String> join([String separator = ""]) {
   _Future<String> result = new _Future<String>();
    StringBuffer buffer = new StringBuffer();
@@ skipping 22 matching lines @@
   }
  Future<bool> contains(Object needle) {
   _Future<bool> future = new _Future<bool>();
    StreamSubscription subscription;
    subscription = this.listen((T element) {
     _runUserCode(() => (element == needle), (bool isMatch) {
       if (isMatch) {
         _cancelAndValue(subscription, future, true);
         }
       }
-    , ((__x59) => DEVC$RT.cast(__x59, dynamic, __t54, "CastGeneral", """line 602, column 13 of dart:async/stream.dart: """, __x59 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
+    , ((__x59) => DEVC$RT.cast(__x59, dynamic, __t54, "CompositeCast", """line 602, column 13 of dart:async/stream.dart: """, __x59 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
     }
   , onError: future._completeError, onDone: () {
     future._complete(false);
     }
   , cancelOnError: true);
    return future;
   }
  Future forEach(void action(T element)) {
   _Future future = new _Future();
    StreamSubscription subscription;
    subscription = this.listen((T element) {
     _runUserCode(() => action(element), (_) {
       }
-    , ((__x60) => DEVC$RT.cast(__x60, dynamic, __t54, "CastGeneral", """line 628, column 13 of dart:async/stream.dart: """, __x60 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
+    , ((__x60) => DEVC$RT.cast(__x60, dynamic, __t54, "CompositeCast", """line 628, column 13 of dart:async/stream.dart: """, __x60 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
     }
   , onError: future._completeError, onDone: () {
     future._complete(null);
     }
   , cancelOnError: true);
    return future;
   }
  Future<bool> every(bool test(T element)) {
   _Future<bool> future = new _Future<bool>();
    StreamSubscription subscription;
    subscription = this.listen((T element) {
     _runUserCode(() => test(element), (bool isMatch) {
       if (!isMatch) {
         _cancelAndValue(subscription, future, false);
         }
       }
-    , ((__x61) => DEVC$RT.cast(__x61, dynamic, __t54, "CastGeneral", """line 657, column 13 of dart:async/stream.dart: """, __x61 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
+    , ((__x61) => DEVC$RT.cast(__x61, dynamic, __t54, "CompositeCast", """line 657, column 13 of dart:async/stream.dart: """, __x61 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
     }
   , onError: future._completeError, onDone: () {
     future._complete(true);
     }
   , cancelOnError: true);
    return future;
   }
  Future<bool> any(bool test(T element)) {
   _Future<bool> future = new _Future<bool>();
    StreamSubscription subscription;
    subscription = this.listen((T element) {
     _runUserCode(() => test(element), (bool isMatch) {
       if (isMatch) {
         _cancelAndValue(subscription, future, true);
         }
       }
-    , ((__x62) => DEVC$RT.cast(__x62, dynamic, __t54, "CastGeneral", """line 694, column 13 of dart:async/stream.dart: """, __x62 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
+    , ((__x62) => DEVC$RT.cast(__x62, dynamic, __t54, "CompositeCast", """line 694, column 13 of dart:async/stream.dart: """, __x62 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
     }
   , onError: future._completeError, onDone: () {
     future._complete(false);
     }
   , cancelOnError: true);
    return future;
   }
  Future<int> get length {
   _Future<int> future = new _Future<int>();
    int count = 0;
@@ skipping 53 matching lines @@
     }
   , cancelOnError: true);
    return future;
   }
  Future drain([var futureValue]) => listen(null, cancelOnError: true).asFuture(futureValue);
  Stream<T> take(int count) {
   return ((__x69) => DEVC$RT.cast(__x69, DEVC$RT.type((_TakeStream<dynamic> _) {
     }
   ), DEVC$RT.type((Stream<T> _) {
     }
-  ), "CastExact", """line 819, column 12 of dart:async/stream.dart: """, __x69 is Stream<T>, false))(new _TakeStream(this, count));
+  ), "InferableAllocation", """line 819, column 12 of dart:async/stream.dart: """, __x69 is Stream<T>, false))(new _TakeStream(this, count));
   }
  Stream<T> takeWhile(bool test(T element)) {
   return ((__x70) => DEVC$RT.cast(__x70, DEVC$RT.type((_TakeWhileStream<dynamic> _) {
     }
   ), DEVC$RT.type((Stream<T> _) {
     }
-  ), "CastExact", """line 841, column 12 of dart:async/stream.dart: """, __x70 is Stream<T>, false))(new _TakeWhileStream(this, test));
+  ), "InferableAllocation", """line 841, column 12 of dart:async/stream.dart: """, __x70 is Stream<T>, false))(new _TakeWhileStream(this, test));
   }
  Stream<T> skip(int count) {
   return ((__x71) => DEVC$RT.cast(__x71, DEVC$RT.type((_SkipStream<dynamic> _) {
     }
   ), DEVC$RT.type((Stream<T> _) {
     }
-  ), "CastExact", """line 852, column 12 of dart:async/stream.dart: """, __x71 is Stream<T>, false))(new _SkipStream(this, count));
+  ), "InferableAllocation", """line 852, column 12 of dart:async/stream.dart: """, __x71 is Stream<T>, false))(new _SkipStream(this, count));
   }
  Stream<T> skipWhile(bool test(T element)) {
   return ((__x72) => DEVC$RT.cast(__x72, DEVC$RT.type((_SkipWhileStream<dynamic> _) {
     }
   ), DEVC$RT.type((Stream<T> _) {
     }
-  ), "CastExact", """line 868, column 12 of dart:async/stream.dart: """, __x72 is Stream<T>, false))(new _SkipWhileStream(this, test));
+  ), "InferableAllocation", """line 868, column 12 of dart:async/stream.dart: """, __x72 is Stream<T>, false))(new _SkipWhileStream(this, test));
   }
  Stream<T> distinct([bool equals(T previous, T next)]) {
   return ((__x73) => DEVC$RT.cast(__x73, DEVC$RT.type((_DistinctStream<dynamic> _) {
     }
   ), DEVC$RT.type((Stream<T> _) {
     }
-  ), "CastExact", """line 885, column 12 of dart:async/stream.dart: """, __x73 is Stream<T>, false))(new _DistinctStream(this, equals));
+  ), "InferableAllocation", """line 885, column 12 of dart:async/stream.dart: """, __x73 is Stream<T>, false))(new _DistinctStream(this, equals));
   }
  Future<T> get first {
   _Future<T> future = new _Future<T>();
    StreamSubscription subscription;
    subscription = this.listen((T value) {
     _cancelAndValue(subscription, future, value);
     }
   , onError: future._completeError, onDone: () {
     try {
       throw IterableElementError.noElement();
@@ skipping 63 matching lines @@
   Object defaultValue()}
 ) {
   _Future<dynamic> future = new _Future();
    StreamSubscription subscription;
    subscription = this.listen((T value) {
     _runUserCode(() => test(value), (bool isMatch) {
       if (isMatch) {
         _cancelAndValue(subscription, future, value);
         }
       }
-    , ((__x74) => DEVC$RT.cast(__x74, dynamic, __t54, "CastGeneral", """line 1036, column 11 of dart:async/stream.dart: """, __x74 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
+    , ((__x74) => DEVC$RT.cast(__x74, dynamic, __t54, "CompositeCast", """line 1036, column 11 of dart:async/stream.dart: """, __x74 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
     }
   , onError: future._completeError, onDone: () {
     if (defaultValue != null) {
       _runUserCode(defaultValue, future._complete, future._completeError);
        return;}
      try {
       throw IterableElementError.noElement();
       }
      catch (e, s) {
       _completeWithErrorCallback(future, e, s);
       }
     }
   , cancelOnError: true);
    return future;
   }
  Future<dynamic> lastWhere(bool test(T element), {
   Object defaultValue()}
 ) {
   _Future<dynamic> future = new _Future();
    T result = null;
    bool foundResult = false;
    StreamSubscription subscription;
    subscription = this.listen((T value) {
     _runUserCode(() => true == test(value), (bool isMatch) {
       if (isMatch) {
         foundResult = true;
          result = value;
         }
       }
-    , ((__x75) => DEVC$RT.cast(__x75, dynamic, __t54, "CastGeneral", """line 1077, column 11 of dart:async/stream.dart: """, __x75 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
+    , ((__x75) => DEVC$RT.cast(__x75, dynamic, __t54, "CompositeCast", """line 1077, column 11 of dart:async/stream.dart: """, __x75 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
     }
   , onError: future._completeError, onDone: () {
     if (foundResult) {
       future._complete(result);
        return;}
      if (defaultValue != null) {
       _runUserCode(defaultValue, future._complete, future._completeError);
        return;}
      try {
       throw IterableElementError.noElement();
@@ skipping 18 matching lines @@
             throw IterableElementError.tooMany();
             }
            catch (e, s) {
             _cancelAndErrorWithReplacement(subscription, future, e, s);
             }
            return;}
          foundResult = true;
          result = value;
         }
       }
-    , ((__x76) => DEVC$RT.cast(__x76, dynamic, __t54, "CastGeneral", """line 1129, column 11 of dart:async/stream.dart: """, __x76 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
+    , ((__x76) => DEVC$RT.cast(__x76, dynamic, __t54, "CompositeCast", """line 1129, column 11 of dart:async/stream.dart: """, __x76 is __t54, false))(_cancelAndErrorClosure(subscription, future)));
     }
   , onError: future._completeError, onDone: () {
     if (foundResult) {
       future._complete(result);
        return;}
      try {
       throw IterableElementError.noElement();
       }
      catch (e, s) {
       _completeWithErrorCallback(future, e, s);
@@ skipping 23 matching lines @@
   void onTimeout(EventSink sink)}
 ) {
   StreamController controller;
    StreamSubscription<T> subscription;
    Timer timer;
    Zone zone;
    Function timeout;
    void onData(T event) {
     timer.cancel();
      controller.add(event);
-     timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t77, "CastGeneral", """line 1219, column 43 of dart:async/stream.dart: """, timeout is __t77, false));
+     timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t77, "CompositeCast", """line 1219, column 43 of dart:async/stream.dart: """, timeout is __t77, false));
     }
    void onError(error, StackTrace stackTrace) {
     timer.cancel();
      assert (controller is _StreamController || controller is _BroadcastStreamController); var eventSink = controller;
      eventSink._addError(error, stackTrace);
-     timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t77, "CastGeneral", """line 1227, column 43 of dart:async/stream.dart: """, timeout is __t77, false));
+     timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t77, "CompositeCast", """line 1227, column 43 of dart:async/stream.dart: """, timeout is __t77, false));
     }
    void onDone() {
     timer.cancel();
      controller.close();
     }
    void onListen() {
     zone = Zone.current;
      if (onTimeout == null) {
       timeout = () {
         controller.addError(new TimeoutException("No stream event", timeLimit), null);
         }
       ;
       }
      else {
       onTimeout = ((__x81) => DEVC$RT.wrap((dynamic f(dynamic __u78)) {
         dynamic c(dynamic x0) => f(x0);
          return f == null ? null : c;
         }
       , __x81, __t33, __t79, "Wrap", """line 1245, column 21 of dart:async/stream.dart: """, __x81 is __t79))(zone.registerUnaryCallback(onTimeout));
        _ControllerEventSinkWrapper wrapper = new _ControllerEventSinkWrapper(null);
        timeout = () {
         wrapper._sink = controller;
          zone.runUnaryGuarded(onTimeout, wrapper);
          wrapper._sink = null;
         }
       ;
       }
      subscription = this.listen(onData, onError: onError, onDone: onDone);
-     timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t77, "CastGeneral", """line 1256, column 43 of dart:async/stream.dart: """, timeout is __t77, false));
+     timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t77, "CompositeCast", """line 1256, column 43 of dart:async/stream.dart: """, timeout is __t77, false));
     }
    Future onCancel() {
     timer.cancel();
      Future result = subscription.cancel();
      subscription = null;
      return result;
     }
    controller = isBroadcast ? new _SyncBroadcastStreamController(onListen, onCancel) : new _SyncStreamController(onListen, () {
     timer.cancel();
      subscription.pause();
     }
   , () {
     subscription.resume();
-     timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t77, "CastGeneral", """line 1275, column 53 of dart:async/stream.dart: """, timeout is __t77, false));
+     timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t77, "CompositeCast", """line 1275, column 53 of dart:async/stream.dart: """, timeout is __t77, false));
     }
   , onCancel);
    return controller.stream;
   }
 }
  abstract class StreamSubscription<T> {Future cancel();
  void onData(void handleData(T data));
  void onError(Function handleError);
  void onDone(void handleDone());
  void pause([Future resumeSignal]);
@@ skipping 51 matching lines @@
  typedef T __t37<T>(int __u38);
  typedef dynamic __t39(dynamic __u40);
  typedef EventSink<dynamic> __t44(EventSink<dynamic> __u45);
  typedef EventSink<dynamic> __t46<T>(EventSink<T> __u47);
  typedef void __t49(StreamSubscription<dynamic> __u50);
  typedef void __t51<T>(StreamSubscription<T> __u52);
  typedef dynamic __t54(dynamic __u55, StackTrace __u56);
  typedef void __t64<T>(T __u65);
  typedef void __t77();
  typedef void __t79(EventSink<dynamic> __u80);