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

Side by Side Diff: lib/runtime/dart/async.js

Issue 1099333002: canonicalize const (Closed) Base URL: git@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
« no previous file with comments | « lib/runtime/dart/_js_helper.js ('k') | lib/runtime/dart/convert.js » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 var async; 1 var async;
2 (function(exports) { 2 (function(exports) {
3 'use strict'; 3 'use strict';
4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic
5 function _invokeErrorHandler(errorHandler, error, stackTrace) { 5 function _invokeErrorHandler(errorHandler, error, stackTrace) {
6 if (dart.is(errorHandler, ZoneBinaryCallback)) { 6 if (dart.is(errorHandler, ZoneBinaryCallback)) {
7 return dart.dcall(errorHandler, error, stackTrace); 7 return dart.dcall(errorHandler, error, stackTrace);
8 } else { 8 } else {
9 return dart.dcall(errorHandler, error); 9 return dart.dcall(errorHandler, error);
10 } 10 }
(...skipping 1042 matching lines...) Expand 10 before | Expand all | Expand 10 after
1053 } 1053 }
1054 } 1054 }
1055 [_close]() { 1055 [_close]() {
1056 dart.assert(!dart.notNull(this[_isClosed])); 1056 dart.assert(!dart.notNull(this[_isClosed]));
1057 if (this[_isCanceled]) 1057 if (this[_isCanceled])
1058 return; 1058 return;
1059 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStrea mSubscription[_STATE_CLOSED]); 1059 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStrea mSubscription[_STATE_CLOSED]);
1060 if (this[_canFire]) { 1060 if (this[_canFire]) {
1061 this[_sendDone](); 1061 this[_sendDone]();
1062 } else { 1062 } else {
1063 this[_addPending](new _DelayedDone()); 1063 this[_addPending](dart.const(new _DelayedDone()));
1064 } 1064 }
1065 } 1065 }
1066 [_onPause]() { 1066 [_onPause]() {
1067 dart.assert(this[_isInputPaused]); 1067 dart.assert(this[_isInputPaused]);
1068 } 1068 }
1069 [_onResume]() { 1069 [_onResume]() {
1070 dart.assert(!dart.notNull(this[_isInputPaused])); 1070 dart.assert(!dart.notNull(this[_isInputPaused]));
1071 } 1071 }
1072 [_onCancel]() { 1072 [_onCancel]() {
1073 dart.assert(this[_isCanceled]); 1073 dart.assert(this[_isCanceled]);
(...skipping 455 matching lines...) Expand 10 before | Expand all | Expand 10 after
1529 [_sendError](error, stackTrace) { 1529 [_sendError](error, stackTrace) {
1530 for (let link = this[_next]; !dart.notNull(core.identical(link, this)); link = link[_next]) { 1530 for (let link = this[_next]; !dart.notNull(core.identical(link, this)); link = link[_next]) {
1531 let subscription = dart.as(link, _BroadcastSubscription$(T)); 1531 let subscription = dart.as(link, _BroadcastSubscription$(T));
1532 subscription[_addPending](new _DelayedError(error, stackTrace)); 1532 subscription[_addPending](new _DelayedError(error, stackTrace));
1533 } 1533 }
1534 } 1534 }
1535 [_sendDone]() { 1535 [_sendDone]() {
1536 if (!dart.notNull(this[_isEmpty])) { 1536 if (!dart.notNull(this[_isEmpty])) {
1537 for (let link = this[_next]; !dart.notNull(core.identical(link, this)) ; link = link[_next]) { 1537 for (let link = this[_next]; !dart.notNull(core.identical(link, this)) ; link = link[_next]) {
1538 let subscription = dart.as(link, _BroadcastSubscription$(T)); 1538 let subscription = dart.as(link, _BroadcastSubscription$(T));
1539 subscription[_addPending](new _DelayedDone()); 1539 subscription[_addPending](dart.const(new _DelayedDone()));
1540 } 1540 }
1541 } else { 1541 } else {
1542 dart.assert(this[_doneFuture] != null); 1542 dart.assert(this[_doneFuture] != null);
1543 dart.assert(this[_doneFuture][_mayComplete]); 1543 dart.assert(this[_doneFuture][_mayComplete]);
1544 this[_doneFuture][_asyncComplete](null); 1544 this[_doneFuture][_asyncComplete](null);
1545 } 1545 }
1546 } 1546 }
1547 } 1547 }
1548 return _AsyncBroadcastStreamController; 1548 return _AsyncBroadcastStreamController;
1549 }); 1549 });
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after
1583 } 1583 }
1584 if (!dart.notNull(this[_mayAddEvent])) 1584 if (!dart.notNull(this[_mayAddEvent]))
1585 throw this[_addEventError](); 1585 throw this[_addEventError]();
1586 this[_sendError](error, stackTrace); 1586 this[_sendError](error, stackTrace);
1587 while (this[_hasPending]) { 1587 while (this[_hasPending]) {
1588 this[_pending].handleNext(this); 1588 this[_pending].handleNext(this);
1589 } 1589 }
1590 } 1590 }
1591 close() { 1591 close() {
1592 if (!dart.notNull(this.isClosed) && dart.notNull(this[_isFiring])) { 1592 if (!dart.notNull(this.isClosed) && dart.notNull(this[_isFiring])) {
1593 this[_addPendingEvent](new _DelayedDone()); 1593 this[_addPendingEvent](dart.const(new _DelayedDone()));
1594 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStr eamController[_STATE_CLOSED]); 1594 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStr eamController[_STATE_CLOSED]);
1595 return super.done; 1595 return super.done;
1596 } 1596 }
1597 let result = super.close(); 1597 let result = super.close();
1598 dart.assert(!dart.notNull(this[_hasPending])); 1598 dart.assert(!dart.notNull(this[_hasPending]));
1599 return result; 1599 return result;
1600 } 1600 }
1601 [_callOnCancel]() { 1601 [_callOnCancel]() {
1602 if (this[_hasPending]) { 1602 if (this[_hasPending]) {
1603 this[_pending].clear(); 1603 this[_pending].clear();
(...skipping 192 matching lines...) Expand 10 before | Expand all | Expand 10 after
1796 dart.dcall(cleanUp, value); 1796 dart.dcall(cleanUp, value);
1797 }); 1797 });
1798 } 1798 }
1799 if (remaining == 0 && !dart.notNull(eagerError)) { 1799 if (remaining == 0 && !dart.notNull(eagerError)) {
1800 result[_completeError](error, stackTrace); 1800 result[_completeError](error, stackTrace);
1801 } 1801 }
1802 } 1802 }
1803 }, {onError: handleError}); 1803 }, {onError: handleError});
1804 } 1804 }
1805 if (remaining == 0) { 1805 if (remaining == 0) {
1806 return new Future$(core.List).value(/* Unimplemented const */[]); 1806 return new Future$(core.List).value(dart.const([]));
1807 } 1807 }
1808 values = new core.List(remaining); 1808 values = new core.List(remaining);
1809 return result; 1809 return result;
1810 } 1810 }
1811 static forEach(input, f) { 1811 static forEach(input, f) {
1812 let iterator = input[core.$iterator]; 1812 let iterator = input[core.$iterator];
1813 return Future.doWhile(() => { 1813 return Future.doWhile(() => {
1814 if (!dart.notNull(iterator.moveNext())) 1814 if (!dart.notNull(iterator.moveNext()))
1815 return false; 1815 return false;
1816 return new Future.sync(() => dart.dcall(f, iterator.current)).then(_ = > true); 1816 return new Future.sync(() => dart.dcall(f, iterator.current)).then(_ = > true);
(...skipping 1072 matching lines...) Expand 10 before | Expand all | Expand 10 after
2889 if (!dart.notNull(this[_mayAddEvent])) 2889 if (!dart.notNull(this[_mayAddEvent]))
2890 throw this[_badEventState](); 2890 throw this[_badEventState]();
2891 this[_closeUnchecked](); 2891 this[_closeUnchecked]();
2892 return this[_ensureDoneFuture](); 2892 return this[_ensureDoneFuture]();
2893 } 2893 }
2894 [_closeUnchecked]() { 2894 [_closeUnchecked]() {
2895 this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamControll er[_STATE_CLOSED]); 2895 this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamControll er[_STATE_CLOSED]);
2896 if (this.hasListener) { 2896 if (this.hasListener) {
2897 this[_sendDone](); 2897 this[_sendDone]();
2898 } else if (this[_isInitialState]) { 2898 } else if (this[_isInitialState]) {
2899 this[_ensurePendingEvents]().add(new _DelayedDone()); 2899 this[_ensurePendingEvents]().add(dart.const(new _DelayedDone()));
2900 } 2900 }
2901 } 2901 }
2902 [_add](value) { 2902 [_add](value) {
2903 if (this.hasListener) { 2903 if (this.hasListener) {
2904 this[_sendData](value); 2904 this[_sendData](value);
2905 } else if (this[_isInitialState]) { 2905 } else if (this[_isInitialState]) {
2906 this[_ensurePendingEvents]().add(new (_DelayedData$(T))(value)); 2906 this[_ensurePendingEvents]().add(new (_DelayedData$(T))(value));
2907 } 2907 }
2908 } 2908 }
2909 [_addError](error, stackTrace) { 2909 [_addError](error, stackTrace) {
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after
3018 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(); 3018 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$();
3019 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) { 3019 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) {
3020 class _AsyncStreamControllerDispatch extends core.Object { 3020 class _AsyncStreamControllerDispatch extends core.Object {
3021 [_sendData](data) { 3021 [_sendData](data) {
3022 this[_subscription][_addPending](new _DelayedData(data)); 3022 this[_subscription][_addPending](new _DelayedData(data));
3023 } 3023 }
3024 [_sendError](error, stackTrace) { 3024 [_sendError](error, stackTrace) {
3025 this[_subscription][_addPending](new _DelayedError(error, stackTrace)); 3025 this[_subscription][_addPending](new _DelayedError(error, stackTrace));
3026 } 3026 }
3027 [_sendDone]() { 3027 [_sendDone]() {
3028 this[_subscription][_addPending](new _DelayedDone()); 3028 this[_subscription][_addPending](dart.const(new _DelayedDone()));
3029 } 3029 }
3030 } 3030 }
3031 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$( T)]; 3031 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$( T)];
3032 return _AsyncStreamControllerDispatch; 3032 return _AsyncStreamControllerDispatch;
3033 }); 3033 });
3034 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(); 3034 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$();
3035 let _AsyncStreamController$ = dart.generic(function(T) { 3035 let _AsyncStreamController$ = dart.generic(function(T) {
3036 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) { 3036 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) {
3037 _AsyncStreamController(onListen, onPause, onResume, onCancel) { 3037 _AsyncStreamController(onListen, onPause, onResume, onCancel) {
3038 this[_onListen] = onListen; 3038 this[_onListen] = onListen;
(...skipping 1869 matching lines...) Expand 10 before | Expand all | Expand 10 after
4908 _internal.printToConsole(line); 4908 _internal.printToConsole(line);
4909 } 4909 }
4910 // Function _printToZone: (String) → void 4910 // Function _printToZone: (String) → void
4911 function _printToZone(line) { 4911 function _printToZone(line) {
4912 Zone.current.print(line); 4912 Zone.current.print(line);
4913 } 4913 }
4914 // Function _rootFork: (Zone, ZoneDelegate, Zone, ZoneSpecification, Map<dynam ic, dynamic>) → Zone 4914 // Function _rootFork: (Zone, ZoneDelegate, Zone, ZoneSpecification, Map<dynam ic, dynamic>) → Zone
4915 function _rootFork(self, parent, zone, specification, zoneValues) { 4915 function _rootFork(self, parent, zone, specification, zoneValues) {
4916 _internal.printToZone = _printToZone; 4916 _internal.printToZone = _printToZone;
4917 if (specification == null) { 4917 if (specification == null) {
4918 specification = new ZoneSpecification(); 4918 specification = dart.const(new ZoneSpecification());
4919 } else if (!dart.is(specification, _ZoneSpecification)) { 4919 } else if (!dart.is(specification, _ZoneSpecification)) {
4920 throw new core.ArgumentError("ZoneSpecifications must be instantiated" + " with the provided constructor."); 4920 throw new core.ArgumentError("ZoneSpecifications must be instantiated" + " with the provided constructor.");
4921 } 4921 }
4922 let valueMap = null; 4922 let valueMap = null;
4923 if (zoneValues == null) { 4923 if (zoneValues == null) {
4924 if (dart.is(zone, _Zone)) { 4924 if (dart.is(zone, _Zone)) {
4925 valueMap = zone[_map]; 4925 valueMap = zone[_map];
4926 } else { 4926 } else {
4927 valueMap = new collection.HashMap(); 4927 valueMap = new collection.HashMap();
4928 } 4928 }
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
4973 } 4973 }
4974 } 4974 }
4975 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; 4975 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification];
4976 let _rootMap = Symbol('_rootMap'); 4976 let _rootMap = Symbol('_rootMap');
4977 let _rootDelegate = Symbol('_rootDelegate'); 4977 let _rootDelegate = Symbol('_rootDelegate');
4978 class _RootZone extends _Zone { 4978 class _RootZone extends _Zone {
4979 _RootZone() { 4979 _RootZone() {
4980 super._Zone(); 4980 super._Zone();
4981 } 4981 }
4982 get [_run]() { 4982 get [_run]() {
4983 return new _ZoneFunction(_ROOT_ZONE, _rootRun); 4983 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun));
4984 } 4984 }
4985 get [_runUnary]() { 4985 get [_runUnary]() {
4986 return new _ZoneFunction(_ROOT_ZONE, _rootRunUnary); 4986 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary));
4987 } 4987 }
4988 get [_runBinary]() { 4988 get [_runBinary]() {
4989 return new _ZoneFunction(_ROOT_ZONE, _rootRunBinary); 4989 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary));
4990 } 4990 }
4991 get [_registerCallback]() { 4991 get [_registerCallback]() {
4992 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback); 4992 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback));
4993 } 4993 }
4994 get [_registerUnaryCallback]() { 4994 get [_registerUnaryCallback]() {
4995 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback); 4995 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback ));
4996 } 4996 }
4997 get [_registerBinaryCallback]() { 4997 get [_registerBinaryCallback]() {
4998 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallback); 4998 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallbac k));
4999 } 4999 }
5000 get [_errorCallback]() { 5000 get [_errorCallback]() {
5001 return new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback); 5001 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback));
5002 } 5002 }
5003 get [_scheduleMicrotask]() { 5003 get [_scheduleMicrotask]() {
5004 return new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask); 5004 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask));
5005 } 5005 }
5006 get [_createTimer]() { 5006 get [_createTimer]() {
5007 return new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer); 5007 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer));
5008 } 5008 }
5009 get [_createPeriodicTimer]() { 5009 get [_createPeriodicTimer]() {
5010 return new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer); 5010 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer)) ;
5011 } 5011 }
5012 get [_print]() { 5012 get [_print]() {
5013 return new _ZoneFunction(_ROOT_ZONE, _rootPrint); 5013 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint));
5014 } 5014 }
5015 get [_fork]() { 5015 get [_fork]() {
5016 return new _ZoneFunction(_ROOT_ZONE, _rootFork); 5016 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork));
5017 } 5017 }
5018 get [_handleUncaughtError]() { 5018 get [_handleUncaughtError]() {
5019 return new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError); 5019 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError)) ;
5020 } 5020 }
5021 get parent() { 5021 get parent() {
5022 return null; 5022 return null;
5023 } 5023 }
5024 get [_map]() { 5024 get [_map]() {
5025 return _RootZone[_rootMap]; 5025 return _RootZone[_rootMap];
5026 } 5026 }
5027 get [_delegate]() { 5027 get [_delegate]() {
5028 if (_RootZone[_rootDelegate] != null) 5028 if (_RootZone[_rootDelegate] != null)
5029 return _RootZone[_rootDelegate]; 5029 return _RootZone[_rootDelegate];
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after
5143 _internal.printToConsole(line); 5143 _internal.printToConsole(line);
5144 } 5144 }
5145 } 5145 }
5146 _RootZone._rootDelegate = null; 5146 _RootZone._rootDelegate = null;
5147 dart.defineLazyProperties(_RootZone, { 5147 dart.defineLazyProperties(_RootZone, {
5148 get _rootMap() { 5148 get _rootMap() {
5149 return new collection.HashMap(); 5149 return new collection.HashMap();
5150 }, 5150 },
5151 set _rootMap(_) {} 5151 set _rootMap(_) {}
5152 }); 5152 });
5153 let _ROOT_ZONE = new _RootZone(); 5153 let _ROOT_ZONE = dart.const(new _RootZone());
5154 // Function runZoned: (() → dynamic, {zoneValues: Map<dynamic, dynamic>, zoneS pecification: ZoneSpecification, onError: Function}) → dynamic 5154 // Function runZoned: (() → dynamic, {zoneValues: Map<dynamic, dynamic>, zoneS pecification: ZoneSpecification, onError: Function}) → dynamic
5155 function runZoned(body, opts) { 5155 function runZoned(body, opts) {
5156 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; 5156 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
5157 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci fication : null; 5157 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci fication : null;
5158 let onError = opts && 'onError' in opts ? opts.onError : null; 5158 let onError = opts && 'onError' in opts ? opts.onError : null;
5159 let errorHandler = null; 5159 let errorHandler = null;
5160 if (onError != null) { 5160 if (onError != null) {
5161 errorHandler = (self, parent, zone, error, stackTrace) => { 5161 errorHandler = (self, parent, zone, error, stackTrace) => {
5162 try { 5162 try {
5163 if (dart.is(onError, ZoneBinaryCallback)) { 5163 if (dart.is(onError, ZoneBinaryCallback)) {
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after
5250 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; 5250 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler;
5251 exports.CreateTimerHandler = CreateTimerHandler; 5251 exports.CreateTimerHandler = CreateTimerHandler;
5252 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; 5252 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler;
5253 exports.PrintHandler = PrintHandler; 5253 exports.PrintHandler = PrintHandler;
5254 exports.ForkHandler = ForkHandler; 5254 exports.ForkHandler = ForkHandler;
5255 exports.ZoneSpecification = ZoneSpecification; 5255 exports.ZoneSpecification = ZoneSpecification;
5256 exports.ZoneDelegate = ZoneDelegate; 5256 exports.ZoneDelegate = ZoneDelegate;
5257 exports.Zone = Zone; 5257 exports.Zone = Zone;
5258 exports.runZoned = runZoned; 5258 exports.runZoned = runZoned;
5259 })(async || (async = {})); 5259 })(async || (async = {}));
OLDNEW
« no previous file with comments | « lib/runtime/dart/_js_helper.js ('k') | lib/runtime/dart/convert.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698