| Index: test/dart_codegen/expect/async/stream_controller.dart
|
| diff --git a/test/dart_codegen/expect/async/stream_controller.dart b/test/dart_codegen/expect/async/stream_controller.dart
|
| index e042542574ec5a83c5abd82f2027450948f76692..a9cd3a04b2c30062bbf3add2508d792c9a372946 100644
|
| --- a/test/dart_codegen/expect/async/stream_controller.dart
|
| +++ b/test/dart_codegen/expect/async/stream_controller.dart
|
| @@ -4,11 +4,11 @@ part of dart.async;
|
| void onListen(), void onPause(), void onResume(), onCancel(), bool sync : false}
|
| ) {
|
| if (onListen == null && onPause == null && onResume == null && onCancel == null) {
|
| - return ((__x71) => DEVC$RT.cast(__x71, DEVC$RT.type((_StreamController<dynamic> _) {
|
| + return ((__x59) => DEVC$RT.cast(__x59, DEVC$RT.type((_StreamController<dynamic> _) {
|
| }
|
| ), DEVC$RT.type((StreamController<T> _) {
|
| }
|
| - ), "CompositeCast", """line 83, column 14 of dart:async/stream_controller.dart: """, __x71 is StreamController<T>, false))(sync ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController());
|
| + ), "CompositeCast", """line 83, column 14 of dart:async/stream_controller.dart: """, __x59 is StreamController<T>, false))(sync ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController());
|
| }
|
| return sync ? new _SyncStreamController<T>(onListen, onPause, onResume, onCancel) : new _AsyncStreamController<T>(onListen, onPause, onResume, onCancel);
|
| }
|
| @@ -208,9 +208,9 @@ _StreamControllerAddStreamState addState = DEVC$RT.cast(_varData, dynamic, DEVC$
|
| if (_onCancel != null) {
|
| if (result == null) {
|
| try {
|
| - result = ((__x72) => DEVC$RT.cast(__x72, dynamic, DEVC$RT.type((Future<dynamic> _) {
|
| + result = ((__x60) => DEVC$RT.cast(__x60, dynamic, DEVC$RT.type((Future<dynamic> _) {
|
| }
|
| - ), "DynamicCast", """line 542, column 20 of dart:async/stream_controller.dart: """, __x72 is Future<dynamic>, true))(_onCancel());
|
| + ), "DynamicCast", """line 542, column 20 of dart:async/stream_controller.dart: """, __x60 is Future<dynamic>, true))(_onCancel());
|
| }
|
| catch (e, s) {
|
| result = new _Future().._asyncCompleteError(e, s);
|
| @@ -346,7 +346,7 @@ bool cancelOnError : true}
|
| }
|
| 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: ((__x73) => DEVC$RT.cast(__x73, dynamic, Function, "DynamicCast", """line 746, column 50 of dart:async/stream_controller.dart: """, __x73 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: ((__x61) => DEVC$RT.cast(__x61, dynamic, Function, "DynamicCast", """line 746, column 50 of dart:async/stream_controller.dart: """, __x61 is Function, true))(cancelOnError ? makeErrorHandler(controller) : controller._addError), onDone: controller._close, cancelOnError: cancelOnError);
|
| static makeErrorHandler(_EventSink controller) => (e, StackTrace s) {
|
| controller._addError(e, s);
|
| controller._close();
|
|
|