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

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

Issue 1070453002: Refactor reifier to make it less dart_codegen specific. (Closed) Base URL: git@github.com:dart-lang/dart-dev-compiler.git@master
Patch Set: Address comments, rebase 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 abstract class StreamController<T> implements StreamSink<T> {Stream<T> get stre am; 2 abstract class StreamController<T> implements StreamSink<T> {Stream<T> get stre am;
3 factory StreamController({ 3 factory StreamController({
4 void onListen(), void onPause(), void onResume(), onCancel(), bool sync : fals e} 4 void onListen(), void onPause(), void onResume(), onCancel(), bool sync : fals e}
5 ) { 5 ) {
6 if (onListen == null && onPause == null && onResume == null && onCancel == nul l) { 6 if (onListen == null && onPause == null && onResume == null && onCancel == nul l) {
7 return ((__x52) => DEVC$RT.cast(__x52, DEVC$RT.type((_StreamController<dynam ic> _) { 7 return ((__x46) => DEVC$RT.cast(__x46, DEVC$RT.type((_StreamController<dynam ic> _) {
8 } 8 }
9 ), DEVC$RT.type((StreamController<T> _) { 9 ), DEVC$RT.type((StreamController<T> _) {
10 } 10 }
11 ), "CompositeCast", """line 83, column 14 of dart:async/stream_controller.da rt: """, __x52 is StreamController<T>, false))(sync ? new _NoCallbackSyncStreamC ontroller() : new _NoCallbackAsyncStreamController()); 11 ), "CompositeCast", """line 83, column 14 of dart:async/stream_controller.da rt: """, __x46 is StreamController<T>, false))(sync ? new _NoCallbackSyncStreamC ontroller() : new _NoCallbackAsyncStreamController());
12 } 12 }
13 return sync ? new _SyncStreamController<T>(onListen, onPause, onResume, onCan cel) : new _AsyncStreamController<T>(onListen, onPause, onResume, onCancel); 13 return sync ? new _SyncStreamController<T>(onListen, onPause, onResume, onCan cel) : new _AsyncStreamController<T>(onListen, onPause, onResume, onCancel);
14 } 14 }
15 factory StreamController.broadcast({ 15 factory StreamController.broadcast({
16 void onListen(), void onCancel(), bool sync : false} 16 void onListen(), void onCancel(), bool sync : false}
17 ) { 17 ) {
18 return sync ? new _SyncBroadcastStreamController<T>(onListen, onCancel) : new _AsyncBroadcastStreamController<T>(onListen, onCancel); 18 return sync ? new _SyncBroadcastStreamController<T>(onListen, onCancel) : new _AsyncBroadcastStreamController<T>(onListen, onCancel);
19 } 19 }
20 StreamSink<T> get sink; 20 StreamSink<T> get sink;
21 bool get isClosed; 21 bool get isClosed;
(...skipping 179 matching lines...) Expand 10 before | Expand all | Expand 10 after
201 _StreamControllerAddStreamState addState = DEVC$RT.cast(_varData, dynamic, DEVC$ RT.type((_StreamControllerAddStreamState<dynamic> _) { 201 _StreamControllerAddStreamState addState = DEVC$RT.cast(_varData, dynamic, DEVC$ RT.type((_StreamControllerAddStreamState<dynamic> _) {
202 } 202 }
203 ), "DynamicCast", """line 530, column 50 of dart:async/stream_controller.dart: " "", _varData is _StreamControllerAddStreamState<dynamic>, true); 203 ), "DynamicCast", """line 530, column 50 of dart:async/stream_controller.dart: " "", _varData is _StreamControllerAddStreamState<dynamic>, true);
204 result = addState.cancel(); 204 result = addState.cancel();
205 } 205 }
206 _varData = null; 206 _varData = null;
207 _state = (_state & ~(_STATE_SUBSCRIBED | _STATE_ADDSTREAM)) | _STATE_CANCELED; 207 _state = (_state & ~(_STATE_SUBSCRIBED | _STATE_ADDSTREAM)) | _STATE_CANCELED;
208 if (_onCancel != null) { 208 if (_onCancel != null) {
209 if (result == null) { 209 if (result == null) {
210 try { 210 try {
211 result = ((__x53) => DEVC$RT.cast(__x53, dynamic, DEVC$RT.type((Future<dynam ic> _) { 211 result = ((__x47) => DEVC$RT.cast(__x47, dynamic, DEVC$RT.type((Future<dynam ic> _) {
212 } 212 }
213 ), "DynamicCast", """line 542, column 20 of dart:async/stream_controller.dar t: """, __x53 is Future<dynamic>, true))(_onCancel()); 213 ), "DynamicCast", """line 542, column 20 of dart:async/stream_controller.dar t: """, __x47 is Future<dynamic>, true))(_onCancel());
214 } 214 }
215 catch (e, s) { 215 catch (e, s) {
216 result = new _Future().._asyncCompleteError(e, s); 216 result = new _Future().._asyncCompleteError(e, s);
217 } 217 }
218 } 218 }
219 else { 219 else {
220 result = result.whenComplete(_onCancel); 220 result = result.whenComplete(_onCancel);
221 } 221 }
222 } 222 }
223 void complete() { 223 void complete() {
(...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after
339 _target.addError(error, stackTrace); 339 _target.addError(error, stackTrace);
340 } 340 }
341 Future close() => _target.close(); 341 Future close() => _target.close();
342 Future addStream(Stream<T> source, { 342 Future addStream(Stream<T> source, {
343 bool cancelOnError : true} 343 bool cancelOnError : true}
344 ) => _target.addStream(source, cancelOnError: cancelOnError); 344 ) => _target.addStream(source, cancelOnError: cancelOnError);
345 Future get done => _target.done; 345 Future get done => _target.done;
346 } 346 }
347 class _AddStreamState<T> {final _Future addStreamFuture; 347 class _AddStreamState<T> {final _Future addStreamFuture;
348 final StreamSubscription addSubscription; 348 final StreamSubscription addSubscription;
349 _AddStreamState(_EventSink<T> controller, Stream source, bool cancelOnError) : addStreamFuture = new _Future(), addSubscription = source.listen(controller._add , onError: ((__x54) => DEVC$RT.cast(__x54, dynamic, Function, "DynamicCast", """ line 746, column 50 of dart:async/stream_controller.dart: """, __x54 is Function , true))(cancelOnError ? makeErrorHandler(controller) : controller._addError), o nDone: controller._close, cancelOnError: cancelOnError); 349 _AddStreamState(_EventSink<T> controller, Stream source, bool cancelOnError) : addStreamFuture = new _Future(), addSubscription = source.listen(controller._add , onError: ((__x48) => DEVC$RT.cast(__x48, dynamic, Function, "DynamicCast", """ line 746, column 50 of dart:async/stream_controller.dart: """, __x48 is Function , true))(cancelOnError ? makeErrorHandler(controller) : controller._addError), o nDone: controller._close, cancelOnError: cancelOnError);
350 static makeErrorHandler(_EventSink controller) => (e, StackTrace s) { 350 static makeErrorHandler(_EventSink controller) => (e, StackTrace s) {
351 controller._addError(e, s); 351 controller._addError(e, s);
352 controller._close(); 352 controller._close();
353 } 353 }
354 ; 354 ;
355 void pause() { 355 void pause() {
356 addSubscription.pause(); 356 addSubscription.pause();
357 } 357 }
358 void resume() { 358 void resume() {
359 addSubscription.resume(); 359 addSubscription.resume();
(...skipping 17 matching lines...) Expand all
377 _StreamControllerAddStreamState(_StreamController controller, this.varData, Str eam source, bool cancelOnError) : super(DEVC$RT.cast(controller, DEVC$RT.type((_ StreamController<dynamic> _) { 377 _StreamControllerAddStreamState(_StreamController controller, this.varData, Str eam source, bool cancelOnError) : super(DEVC$RT.cast(controller, DEVC$RT.type((_ StreamController<dynamic> _) {
378 } 378 }
379 ), DEVC$RT.type((_EventSink<T> _) { 379 ), DEVC$RT.type((_EventSink<T> _) {
380 } 380 }
381 ), "CompositeCast", """line 798, column 15 of dart:async/stream_controller.dart: """, controller is _EventSink<T>, false), source, cancelOnError) { 381 ), "CompositeCast", """line 798, column 15 of dart:async/stream_controller.dart: """, controller is _EventSink<T>, false), source, cancelOnError) {
382 if (controller.isPaused) { 382 if (controller.isPaused) {
383 addSubscription.pause(); 383 addSubscription.pause();
384 } 384 }
385 } 385 }
386 } 386 }
OLDNEW
« no previous file with comments | « test/dart_codegen/expect/async/stream.dart ('k') | test/dart_codegen/expect/async/stream_impl.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698