Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1007)

Side by Side Diff: test/dart_codegen/expect/async/broadcast_stream_controller.dart

Issue 1052383003: Disable closure wrapping by default (Closed) Base URL: https://github.com/dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 part of dart.async; 1 part of dart.async;
2 class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_Strea mControllerLifecycle controller) : super(DEVC$RT.cast(controller, DEVC$RT.type(( _StreamControllerLifecycle<dynamic> _) { 2 class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_Strea mControllerLifecycle controller) : super(DEVC$RT.cast(controller, DEVC$RT.type(( _StreamControllerLifecycle<dynamic> _) {
3 } 3 }
4 ), DEVC$RT.type((_StreamControllerLifecycle<T> _) { 4 ), DEVC$RT.type((_StreamControllerLifecycle<T> _) {
5 } 5 }
6 ), "CompositeCast", """line 8, column 67 of dart:async/broadcast_stream_controll er.dart: """, controller is _StreamControllerLifecycle<T>, false)); 6 ), "CompositeCast", """line 8, column 67 of dart:async/broadcast_stream_controll er.dart: """, controller is _StreamControllerLifecycle<T>, false));
7 bool get isBroadcast => true; 7 bool get isBroadcast => true;
8 } 8 }
9 abstract class _BroadcastSubscriptionLink {_BroadcastSubscriptionLink _next; 9 abstract class _BroadcastSubscriptionLink {_BroadcastSubscriptionLink _next;
10 _BroadcastSubscriptionLink _previous; 10 _BroadcastSubscriptionLink _previous;
(...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after
230 ); 230 );
231 } 231 }
232 void _sendError(Object error, StackTrace stackTrace) { 232 void _sendError(Object error, StackTrace stackTrace) {
233 if (_isEmpty) return; _forEachListener((_BufferingStreamSubscription<T> subscrip tion) { 233 if (_isEmpty) return; _forEachListener((_BufferingStreamSubscription<T> subscrip tion) {
234 subscription._addError(error, stackTrace); 234 subscription._addError(error, stackTrace);
235 } 235 }
236 ); 236 );
237 } 237 }
238 void _sendDone() { 238 void _sendDone() {
239 if (!_isEmpty) { 239 if (!_isEmpty) {
240 _forEachListener(((__x8) => DEVC$RT.wrap((dynamic f(_BroadcastSubscription<T> __ u3)) { 240 _forEachListener(((__x7) => DEVC$RT.cast(__x7, DEVC$RT.type((__t5<T> _) {
241 dynamic c(_BroadcastSubscription<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((_Buf feringStreamSubscription<T> _) {
242 } 241 }
243 ), DEVC$RT.type((_BroadcastSubscription<T> _) { 242 ), DEVC$RT.type((__t3<T> _) {
244 } 243 }
245 ), "CastParam", """line 372, column 24 of dart:async/broadcast_stream_controller .dart: """, x0 is _BroadcastSubscription<T>, false)); 244 ), "InferableClosure", """line 372, column 24 of dart:async/broadcast_stream_con troller.dart: """, __x7 is __t3<T>, false))((_BroadcastSubscription<T> subscript ion) {
246 return f == null ? null : c;
247 }
248 , __x8, DEVC$RT.type((__t6<T> _) {
249 }
250 ), DEVC$RT.type((__t4<T> _) {
251 }
252 ), "WrapLiteral", """line 372, column 24 of dart:async/broadcast_stream_controll er.dart: """, __x8 is __t4<T>))((_BroadcastSubscription<T> subscription) {
253 subscription._close(); 245 subscription._close();
254 } 246 }
255 )); 247 ));
256 } 248 }
257 else { 249 else {
258 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as yncComplete(null); 250 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as yncComplete(null);
259 } 251 }
260 } 252 }
261 } 253 }
262 class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onLis ten, onCancel); 254 class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onLis ten, onCancel);
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after
351 } 343 }
352 void _resume(_) { 344 void _resume(_) {
353 if (_pauseCount > 0) _pauseCount--; 345 if (_pauseCount > 0) _pauseCount--;
354 } 346 }
355 Future cancel() { 347 Future cancel() {
356 return new _Future.immediate(null); 348 return new _Future.immediate(null);
357 } 349 }
358 bool get isPaused => _pauseCount > 0; 350 bool get isPaused => _pauseCount > 0;
359 Future asFuture([Object value]) => new _Future(); 351 Future asFuture([Object value]) => new _Future();
360 } 352 }
361 typedef void __t4<T>(_BufferingStreamSubscription<T> __u5); 353 typedef void __t3<T>(_BufferingStreamSubscription<T> __u4);
362 typedef dynamic __t6<T>(_BroadcastSubscription<T> __u7); 354 typedef dynamic __t5<T>(_BroadcastSubscription<T> __u6);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698