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

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

Issue 959073002: Fix new line breaks on } (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 9 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(DDC$RT.cast(controller, DDC$RT.type((_S treamControllerLifecycle<dynamic> _) { 2 class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_Strea mControllerLifecycle controller) : super(DDC$RT.cast(controller, DDC$RT.type((_S treamControllerLifecycle<dynamic> _) {
3 } 3 }
4 ), DDC$RT.type((_StreamControllerLifecycle<T> _) { 4 ), DDC$RT.type((_StreamControllerLifecycle<T> _) {
5 } 5 }
6 ), "CastDynamic", """line 8, column 67 of dart:async/broadcast_stream_controller .dart: """, controller is _StreamControllerLifecycle<T>, false)); 6 ), "CastDynamic", """line 8, column 67 of dart:async/broadcast_stream_controller .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 247 matching lines...) Expand 10 before | Expand all | Expand 10 after
258 } 258 }
259 )); 259 ));
260 } 260 }
261 else { 261 else {
262 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as yncComplete(null); 262 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as yncComplete(null);
263 } 263 }
264 } 264 }
265 } 265 }
266 class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onLis ten, onCancel); 266 class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onLis ten, onCancel);
267 void _sendData(T data) { 267 void _sendData(T data) {
268 for (_BroadcastSubscriptionLink link = _next; 268 for (_BroadcastSubscriptionLink link = _next; !identical(link, this); link = lin k._next) {
269 !identical(link, this);
270 link = link._next) {
271 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio nLink, DDC$RT.type((_BroadcastSubscription<T> _) { 269 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio nLink, DDC$RT.type((_BroadcastSubscription<T> _) {
272 } 270 }
273 ), "CastGeneral", """line 393, column 48 of dart:async/broadcast_stream_controll er.dart: """, link is _BroadcastSubscription<T>, false); 271 ), "CastGeneral", """line 393, column 48 of dart:async/broadcast_stream_controll er.dart: """, link is _BroadcastSubscription<T>, false);
274 subscription._addPending(new _DelayedData(data)); 272 subscription._addPending(new _DelayedData(data));
275 } 273 }
276 } 274 }
277 void _sendError(Object error, StackTrace stackTrace) { 275 void _sendError(Object error, StackTrace stackTrace) {
278 for (_BroadcastSubscriptionLink link = _next; 276 for (_BroadcastSubscriptionLink link = _next; !identical(link, this); link = lin k._next) {
279 !identical(link, this);
280 link = link._next) {
281 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio nLink, DDC$RT.type((_BroadcastSubscription<T> _) { 277 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio nLink, DDC$RT.type((_BroadcastSubscription<T> _) {
282 } 278 }
283 ), "CastGeneral", """line 402, column 48 of dart:async/broadcast_stream_controll er.dart: """, link is _BroadcastSubscription<T>, false); 279 ), "CastGeneral", """line 402, column 48 of dart:async/broadcast_stream_controll er.dart: """, link is _BroadcastSubscription<T>, false);
284 subscription._addPending(new _DelayedError(error, stackTrace)); 280 subscription._addPending(new _DelayedError(error, stackTrace));
285 } 281 }
286 } 282 }
287 void _sendDone() { 283 void _sendDone() {
288 if (!_isEmpty) { 284 if (!_isEmpty) {
289 for (_BroadcastSubscriptionLink link = _next; 285 for (_BroadcastSubscriptionLink link = _next; !identical(link, this); link = lin k._next) {
290 !identical(link, this);
291 link = link._next) {
292 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio nLink, DDC$RT.type((_BroadcastSubscription<T> _) { 286 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio nLink, DDC$RT.type((_BroadcastSubscription<T> _) {
293 } 287 }
294 ), "CastGeneral", """line 412, column 50 of dart:async/broadcast_stream_controll er.dart: """, link is _BroadcastSubscription<T>, false); 288 ), "CastGeneral", """line 412, column 50 of dart:async/broadcast_stream_controll er.dart: """, link is _BroadcastSubscription<T>, false);
295 subscription._addPending(const _DelayedDone()); 289 subscription._addPending(const _DelayedDone());
296 } 290 }
297 } 291 }
298 else { 292 else {
299 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as yncComplete(null); 293 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as yncComplete(null);
300 } 294 }
301 } 295 }
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after
363 if (_pauseCount > 0) _pauseCount--; 357 if (_pauseCount > 0) _pauseCount--;
364 } 358 }
365 Future cancel() { 359 Future cancel() {
366 return new _Future.immediate(null); 360 return new _Future.immediate(null);
367 } 361 }
368 bool get isPaused => _pauseCount > 0; 362 bool get isPaused => _pauseCount > 0;
369 Future asFuture([Object value]) => new _Future(); 363 Future asFuture([Object value]) => new _Future();
370 } 364 }
371 typedef void __t5<T>(_BufferingStreamSubscription<T> __u6); 365 typedef void __t5<T>(_BufferingStreamSubscription<T> __u6);
372 typedef dynamic __t7<T>(_BroadcastSubscription<T> __u8); 366 typedef dynamic __t7<T>(_BroadcastSubscription<T> __u8);
OLDNEW
« no previous file with comments | « test/dart_codegen/expect/async/async_error.dart ('k') | test/dart_codegen/expect/collection/iterable.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698