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

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

Issue 1096583002: Reifier hookup (Closed) Base URL: git@github.com:dart-lang/dart-dev-compiler.git@master
Patch Set: Address comments 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(((__x7) => DEVC$RT.cast(__x7, DEVC$RT.type((__t5<T> _) { 240 _forEachListener(((__x7) => DEVC$RT.cast(__x7, DEVC$RT.type((__CastType5<T> _) {
241 } 241 }
242 ), DEVC$RT.type((__t3<T> _) { 242 ), DEVC$RT.type((__CastType3<T> _) {
243 } 243 }
244 ), "InferableClosure", """line 372, column 24 of dart:async/broadcast_stream_con troller.dart: """, __x7 is __t3<T>, false))((_BroadcastSubscription<T> subscript ion) { 244 ), "InferableClosure", """line 372, column 24 of dart:async/broadcast_stream_con troller.dart: """, __x7 is __CastType3<T>, false))((_BroadcastSubscription<T> su bscription) {
245 subscription._close(); 245 subscription._close();
246 } 246 }
247 )); 247 ));
248 } 248 }
249 else { 249 else {
250 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as yncComplete(null); 250 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as yncComplete(null);
251 } 251 }
252 } 252 }
253 } 253 }
254 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
343 } 343 }
344 void _resume(_) { 344 void _resume(_) {
345 if (_pauseCount > 0) _pauseCount--; 345 if (_pauseCount > 0) _pauseCount--;
346 } 346 }
347 Future cancel() { 347 Future cancel() {
348 return new _Future.immediate(null); 348 return new _Future.immediate(null);
349 } 349 }
350 bool get isPaused => _pauseCount > 0; 350 bool get isPaused => _pauseCount > 0;
351 Future asFuture([Object value]) => new _Future(); 351 Future asFuture([Object value]) => new _Future();
352 } 352 }
353 typedef void __t3<T>(_BufferingStreamSubscription<T> __u4); 353 typedef void __CastType3<T>(_BufferingStreamSubscription<T> __u4);
354 typedef dynamic __t5<T>(_BroadcastSubscription<T> __u6); 354 typedef dynamic __CastType5<T>(_BroadcastSubscription<T> __u6);
OLDNEW
« no previous file with comments | « test/dart_codegen/expect/async/async_error.dart ('k') | test/dart_codegen/expect/async/future.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698