Downward inference

test/dart_codegen/expect/async/stream_transformers.dart

 part of dart.async;
  class _EventSinkWrapper<T> implements EventSink<T> {_EventSink _sink;
  _EventSinkWrapper(this._sink);
  void add(T data) {
   _sink._add(data);
   }
  void addError(error, [StackTrace stackTrace]) {
   _sink._addError(error, stackTrace);
   }
  void close() {
@@ skipping 77 matching lines @@
  Stream<T> bind(Stream<S> stream) => new _BoundSinkStream<S, T>(stream, _sinkMapper);
 }
  class _BoundSinkStream<S, T> extends Stream<T> {final _SinkMapper<S, T> _sinkMapper;
  final Stream<S> _stream;
  bool get isBroadcast => _stream.isBroadcast;
  _BoundSinkStream(this._stream, this._sinkMapper);
  StreamSubscription<T> listen(void onData(T event), {
 Function onError, void onDone(), bool cancelOnError}
 ) {
 cancelOnError = identical(true, cancelOnError);
- StreamSubscription<T> subscription = ((__x105) => DEVC$RT.cast(__x105, DEVC$RT.type((_SinkTransformerStreamSubscription<dynamic, dynamic> _) {
+ StreamSubscription<T> subscription = ((__x96) => DEVC$RT.cast(__x96, DEVC$RT.type((_SinkTransformerStreamSubscription<dynamic, dynamic> _) {
 }
 ), DEVC$RT.type((StreamSubscription<T> _) {
 }
-), "InferableAllocation", """line 186, column 42 of dart:async/stream_transformers.dart: """, __x105 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscription(_stream, DEVC$RT.wrap((EventSink<S> f(EventSink<T> __u106)) {
+), "InferableAllocation", """line 186, column 42 of dart:async/stream_transformers.dart: """, __x96 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscription(_stream, DEVC$RT.wrap((EventSink<S> f(EventSink<T> __u97)) {
 EventSink<S> c(EventSink<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((EventSink<dynamic> _) {
 }
 ), DEVC$RT.type((EventSink<T> _) {
 }
 ), "CastParam", """line 187, column 18 of dart:async/stream_transformers.dart: """, x0 is EventSink<T>, false));
  return f == null ? null : c;
 }
-, _sinkMapper, DEVC$RT.type((__t109<T, S> _) {
+, _sinkMapper, DEVC$RT.type((__t100<T, S> _) {
 }
-), __t107, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart: """, _sinkMapper is __t107), onData, onError, onDone, cancelOnError));
+), __t98, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart: """, _sinkMapper is __t98), onData, onError, onDone, cancelOnError));
  return subscription;
 }
 }
  typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink);
  typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, EventSink<T> sink);
  typedef void _TransformDoneHandler<T>(EventSink<T> sink);
  class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHandler<S, T> _handleData;
  final _TransformErrorHandler<T> _handleError;
  final _TransformDoneHandler<T> _handleDone;
  final EventSink<T> _sink;
  _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._sink);
  void add(S data) => _handleData(data, _sink);
  void addError(Object error, [StackTrace stackTrace]) => _handleError(error, stackTrace, _sink);
  void close() => _handleDone(_sink);
 }
  class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_StreamHandlerTransformer({
 void handleData(S data, EventSink<T> sink), void handleError(Object error, StackTrace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)}
-) : super(((__x117) => DEVC$RT.wrap((dynamic f(EventSink<T> __u112)) {
-dynamic c(EventSink<T> x0) => ((__x111) => DEVC$RT.cast(__x111, dynamic, DEVC$RT.type((EventSink<S> _) {
+) : super(((__x108) => DEVC$RT.wrap((dynamic f(EventSink<T> __u103)) {
+dynamic c(EventSink<T> x0) => ((__x102) => DEVC$RT.cast(__x102, dynamic, DEVC$RT.type((EventSink<S> _) {
 }
-), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x111 is EventSink<S>, false))(f(x0));
+), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x102 is EventSink<S>, false))(f(x0));
  return f == null ? null : c;
 }
-, __x117, DEVC$RT.type((__t115<T> _) {
+, __x108, DEVC$RT.type((__t106<T> _) {
 }
-), DEVC$RT.type((__t113<T, S> _) {
+), DEVC$RT.type((__t104<T, S> _) {
 }
-), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x117 is __t113<T, S>))((EventSink<T> outputSink) {
-if (handleData == null) handleData = DEVC$RT.wrap((void f(dynamic __u118, EventSink<dynamic> __u119)) {
+), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x108 is __t104<T, S>))((EventSink<T> outputSink) {
+if (handleData == null) handleData = DEVC$RT.wrap((void f(dynamic __u109, EventSink<dynamic> __u110)) {
 void c(dynamic x0, EventSink<dynamic> x1) => f(x0, x1);
  return f == null ? null : c;
 }
-, _defaultHandleData, __t123, DEVC$RT.type((__t120<S, T> _) {
+, _defaultHandleData, __t114, DEVC$RT.type((__t111<S, T> _) {
 }
-), "Wrap", """line 234, column 48 of dart:async/stream_transformers.dart: """, _defaultHandleData is __t120<S, T>);
- if (handleError == null) handleError = DEVC$RT.wrap((void f(dynamic __u126, StackTrace __u127, EventSink<dynamic> __u128)) {
+), "Wrap", """line 234, column 48 of dart:async/stream_transformers.dart: """, _defaultHandleData is __t111<S, T>);
+ if (handleError == null) handleError = DEVC$RT.wrap((void f(dynamic __u117, StackTrace __u118, EventSink<dynamic> __u119)) {
 void c(dynamic x0, StackTrace x1, EventSink<dynamic> x2) => f(x0, x1, x2);
  return f == null ? null : c;
 }
-, _defaultHandleError, __t133, DEVC$RT.type((__t129<T> _) {
+, _defaultHandleError, __t124, DEVC$RT.type((__t120<T> _) {
 }
-), "Wrap", """line 235, column 50 of dart:async/stream_transformers.dart: """, _defaultHandleError is __t129<T>);
+), "Wrap", """line 235, column 50 of dart:async/stream_transformers.dart: """, _defaultHandleError is __t120<T>);
  if (handleDone == null) handleDone = _defaultHandleDone;
  return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputSink);
 }
 ));
  Stream<T> bind(Stream<S> stream) {
 return super.bind(stream);
 }
  static void _defaultHandleData(var data, EventSink sink) {
 sink.add(data);
 }
@@ skipping 16 matching lines @@
 Function onError, void onDone(), bool cancelOnError}
 ) {
 cancelOnError = identical(true, cancelOnError);
  StreamSubscription<T> result = _transformer(_stream, cancelOnError);
  result.onData(onData);
  result.onError(onError);
  result.onDone(onDone);
  return result;
 }
 }
- typedef EventSink<dynamic> __t107(EventSink<dynamic> __u108);
- typedef EventSink<S> __t109<T, S>(EventSink<T> __u110);
- typedef EventSink<S> __t113<T, S>(EventSink<T> __u114);
- typedef dynamic __t115<T>(EventSink<T> __u116);
- typedef void __t120<S, T>(S __u121, EventSink<T> __u122);
- typedef void __t123(dynamic __u124, EventSink<dynamic> __u125);
- typedef void __t129<T>(Object __u130, StackTrace __u131, EventSink<T> __u132);
- typedef void __t133(dynamic __u134, StackTrace __u135, EventSink<dynamic> __u136);
+ typedef EventSink<dynamic> __t98(EventSink<dynamic> __u99);
+ typedef EventSink<S> __t100<T, S>(EventSink<T> __u101);
+ typedef EventSink<S> __t104<T, S>(EventSink<T> __u105);
+ typedef dynamic __t106<T>(EventSink<T> __u107);
+ typedef void __t111<S, T>(S __u112, EventSink<T> __u113);
+ typedef void __t114(dynamic __u115, EventSink<dynamic> __u116);
+ typedef void __t120<T>(Object __u121, StackTrace __u122, EventSink<T> __u123);
+ typedef void __t124(dynamic __u125, StackTrace __u126, EventSink<dynamic> __u127);