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

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

Issue 1131143002: Angular workarounds (Closed) Base URL: https://github.com/dart-lang/dev_compiler.git@master
Patch Set: Rebase on latest Created 5 years, 7 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 var async = dart.defineLibrary(async, {}); 1 var async = dart.defineLibrary(async, {});
2 var core = dart.import(core); 2 var core = dart.import(core);
3 var _internal = dart.import(_internal); 3 var _internal = dart.import(_internal);
4 var _js_helper = dart.lazyImport(_js_helper); 4 var _js_helper = dart.lazyImport(_js_helper);
5 var _isolate_helper = dart.lazyImport(_isolate_helper); 5 var _isolate_helper = dart.lazyImport(_isolate_helper);
6 var collection = dart.import(collection); 6 var collection = dart.import(collection);
7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { 7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) {
8 'use strict'; 8 'use strict';
9 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic 9 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic
10 function _invokeErrorHandler(errorHandler, error, stackTrace) { 10 function _invokeErrorHandler(errorHandler, error, stackTrace) {
(...skipping 2088 matching lines...) Expand 10 before | Expand all | Expand 10 after
2099 } 2099 }
2100 dart.defineNamedConstructor(_FutureListener, 'then'); 2100 dart.defineNamedConstructor(_FutureListener, 'then');
2101 dart.defineNamedConstructor(_FutureListener, 'catchError'); 2101 dart.defineNamedConstructor(_FutureListener, 'catchError');
2102 dart.defineNamedConstructor(_FutureListener, 'whenComplete'); 2102 dart.defineNamedConstructor(_FutureListener, 'whenComplete');
2103 dart.defineNamedConstructor(_FutureListener, 'chain'); 2103 dart.defineNamedConstructor(_FutureListener, 'chain');
2104 _FutureListener.MASK_VALUE = 1; 2104 _FutureListener.MASK_VALUE = 1;
2105 _FutureListener.MASK_ERROR = 2; 2105 _FutureListener.MASK_ERROR = 2;
2106 _FutureListener.MASK_TEST_ERROR = 4; 2106 _FutureListener.MASK_TEST_ERROR = 4;
2107 _FutureListener.MASK_WHENCOMPLETE = 8; 2107 _FutureListener.MASK_WHENCOMPLETE = 8;
2108 _FutureListener.STATE_CHAIN = 0; 2108 _FutureListener.STATE_CHAIN = 0;
2109 _FutureListener.STATE_THEN = _FutureListener.MASK_VALUE; 2109 dart.defineLazyProperties(_FutureListener, {
2110 _FutureListener.STATE_THEN_ONERROR = dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureListener.MASK_ERROR); 2110 get STATE_THEN() {
2111 _FutureListener.STATE_CATCHERROR = _FutureListener.MASK_ERROR; 2111 return _FutureListener.MASK_VALUE;
2112 _FutureListener.STATE_CATCHERROR_TEST = dart.notNull(_FutureListener.MASK_ERRO R) | dart.notNull(_FutureListener.MASK_TEST_ERROR); 2112 },
2113 _FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE; 2113 set STATE_THEN(_) {},
2114 get STATE_THEN_ONERROR() {
2115 return dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureList ener.MASK_ERROR);
2116 },
2117 set STATE_THEN_ONERROR(_) {},
2118 get STATE_CATCHERROR() {
2119 return _FutureListener.MASK_ERROR;
2120 },
2121 set STATE_CATCHERROR(_) {},
2122 get STATE_CATCHERROR_TEST() {
2123 return dart.notNull(_FutureListener.MASK_ERROR) | dart.notNull(_FutureList ener.MASK_TEST_ERROR);
2124 },
2125 set STATE_CATCHERROR_TEST(_) {},
2126 get STATE_WHENCOMPLETE() {
2127 return _FutureListener.MASK_WHENCOMPLETE;
2128 },
2129 set STATE_WHENCOMPLETE(_) {}
2130 });
2114 let _resultOrListeners = Symbol('_resultOrListeners'); 2131 let _resultOrListeners = Symbol('_resultOrListeners');
2115 let _isChained = Symbol('_isChained'); 2132 let _isChained = Symbol('_isChained');
2116 let _isComplete = Symbol('_isComplete'); 2133 let _isComplete = Symbol('_isComplete');
2117 let _hasValue = Symbol('_hasValue'); 2134 let _hasValue = Symbol('_hasValue');
2118 let _hasError = Symbol('_hasError'); 2135 let _hasError = Symbol('_hasError');
2119 let _markPendingCompletion = Symbol('_markPendingCompletion'); 2136 let _markPendingCompletion = Symbol('_markPendingCompletion');
2120 let _value = Symbol('_value'); 2137 let _value = Symbol('_value');
2121 let _error = Symbol('_error'); 2138 let _error = Symbol('_error');
2122 let _setValue = Symbol('_setValue'); 2139 let _setValue = Symbol('_setValue');
2123 let _setErrorObject = Symbol('_setErrorObject'); 2140 let _setErrorObject = Symbol('_setErrorObject');
2124 let _setError = Symbol('_setError'); 2141 let _setError = Symbol('_setError');
2125 let _removeListeners = Symbol('_removeListeners'); 2142 let _removeListeners = Symbol('_removeListeners');
2126 let _Future$ = dart.generic(function(T) { 2143 let _Future$ = dart.generic(function(T) {
2127 class _Future extends core.Object { 2144 class _Future extends core.Object {
2128 _Future() { 2145 _Future() {
2146 this[_state] = _Future._INCOMPLETE;
2129 this[_zone] = Zone.current; 2147 this[_zone] = Zone.current;
2130 this[_state] = _Future._INCOMPLETE;
2131 this[_resultOrListeners] = null; 2148 this[_resultOrListeners] = null;
2132 } 2149 }
2133 immediate(value) { 2150 immediate(value) {
2151 this[_state] = _Future._INCOMPLETE;
2134 this[_zone] = Zone.current; 2152 this[_zone] = Zone.current;
2135 this[_state] = _Future._INCOMPLETE;
2136 this[_resultOrListeners] = null; 2153 this[_resultOrListeners] = null;
2137 this[_asyncComplete](value); 2154 this[_asyncComplete](value);
2138 } 2155 }
2139 immediateError(error, stackTrace) { 2156 immediateError(error, stackTrace) {
2140 if (stackTrace === void 0) 2157 if (stackTrace === void 0)
2141 stackTrace = null; 2158 stackTrace = null;
2159 this[_state] = _Future._INCOMPLETE;
2142 this[_zone] = Zone.current; 2160 this[_zone] = Zone.current;
2143 this[_state] = _Future._INCOMPLETE;
2144 this[_resultOrListeners] = null; 2161 this[_resultOrListeners] = null;
2145 this[_asyncCompleteError](error, stackTrace); 2162 this[_asyncCompleteError](error, stackTrace);
2146 } 2163 }
2147 get [_mayComplete]() { 2164 get [_mayComplete]() {
2148 return this[_state] == _Future._INCOMPLETE; 2165 return this[_state] == _Future._INCOMPLETE;
2149 } 2166 }
2150 get [_isChained]() { 2167 get [_isChained]() {
2151 return this[_state] == _Future._CHAINED; 2168 return this[_state] == _Future._CHAINED;
2152 } 2169 }
2153 get [_isComplete]() { 2170 get [_isComplete]() {
(...skipping 689 matching lines...) Expand 10 before | Expand all | Expand 10 after
2843 let _StreamControllerLifecycle = _StreamControllerLifecycle$(); 2860 let _StreamControllerLifecycle = _StreamControllerLifecycle$();
2844 let _varData = Symbol('_varData'); 2861 let _varData = Symbol('_varData');
2845 let _isInitialState = Symbol('_isInitialState'); 2862 let _isInitialState = Symbol('_isInitialState');
2846 let _subscription = Symbol('_subscription'); 2863 let _subscription = Symbol('_subscription');
2847 let _pendingEvents = Symbol('_pendingEvents'); 2864 let _pendingEvents = Symbol('_pendingEvents');
2848 let _ensurePendingEvents = Symbol('_ensurePendingEvents'); 2865 let _ensurePendingEvents = Symbol('_ensurePendingEvents');
2849 let _badEventState = Symbol('_badEventState'); 2866 let _badEventState = Symbol('_badEventState');
2850 let _StreamController$ = dart.generic(function(T) { 2867 let _StreamController$ = dart.generic(function(T) {
2851 class _StreamController extends core.Object { 2868 class _StreamController extends core.Object {
2852 _StreamController() { 2869 _StreamController() {
2870 this[_state] = _StreamController._STATE_INITIAL;
2853 this[_varData] = null; 2871 this[_varData] = null;
2854 this[_state] = _StreamController._STATE_INITIAL;
2855 this[_doneFuture] = null; 2872 this[_doneFuture] = null;
2856 } 2873 }
2857 get stream() { 2874 get stream() {
2858 return new (_ControllerStream$(T))(this); 2875 return new (_ControllerStream$(T))(this);
2859 } 2876 }
2860 get sink() { 2877 get sink() {
2861 return new (_StreamSinkWrapper$(T))(this); 2878 return new (_StreamSinkWrapper$(T))(this);
2862 } 2879 }
2863 get [_isCanceled]() { 2880 get [_isCanceled]() {
2864 return (dart.notNull(this[_state]) & dart.notNull(_StreamController._STA TE_CANCELED)) != 0; 2881 return (dart.notNull(this[_state]) & dart.notNull(_StreamController._STA TE_CANCELED)) != 0;
(...skipping 812 matching lines...) Expand 10 before | Expand all | Expand 10 after
3677 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$( T)]; 3694 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$( T)];
3678 return _BroadcastSubscriptionWrapper; 3695 return _BroadcastSubscriptionWrapper;
3679 }); 3696 });
3680 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); 3697 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$();
3681 let _current = Symbol('_current'); 3698 let _current = Symbol('_current');
3682 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); 3699 let _futureOrPrefetch = Symbol('_futureOrPrefetch');
3683 let _clear = Symbol('_clear'); 3700 let _clear = Symbol('_clear');
3684 let _StreamIteratorImpl$ = dart.generic(function(T) { 3701 let _StreamIteratorImpl$ = dart.generic(function(T) {
3685 class _StreamIteratorImpl extends core.Object { 3702 class _StreamIteratorImpl extends core.Object {
3686 _StreamIteratorImpl(stream) { 3703 _StreamIteratorImpl(stream) {
3704 this[_state] = _StreamIteratorImpl._STATE_FOUND;
3687 this[_subscription] = null; 3705 this[_subscription] = null;
3688 this[_current] = null; 3706 this[_current] = null;
3689 this[_futureOrPrefetch] = null; 3707 this[_futureOrPrefetch] = null;
3690 this[_state] = _StreamIteratorImpl._STATE_FOUND;
3691 this[_subscription] = stream.listen(this[_onData].bind(this), {onError: this[_onError].bind(this), onDone: this[_onDone].bind(this), cancelOnError: true }); 3708 this[_subscription] = stream.listen(this[_onData].bind(this), {onError: this[_onError].bind(this), onDone: this[_onDone].bind(this), cancelOnError: true });
3692 } 3709 }
3693 get current() { 3710 get current() {
3694 return this[_current]; 3711 return this[_current];
3695 } 3712 }
3696 moveNext() { 3713 moveNext() {
3697 if (this[_state] == _StreamIteratorImpl._STATE_DONE) { 3714 if (this[_state] == _StreamIteratorImpl._STATE_DONE) {
3698 return new (_Future$(core.bool)).immediate(false); 3715 return new (_Future$(core.bool)).immediate(false);
3699 } 3716 }
3700 if (this[_state] == _StreamIteratorImpl._STATE_MOVING) { 3717 if (this[_state] == _StreamIteratorImpl._STATE_MOVING) {
(...skipping 943 matching lines...) Expand 10 before | Expand all | Expand 10 after
4644 let previous = Zone._current; 4661 let previous = Zone._current;
4645 Zone._current = zone; 4662 Zone._current = zone;
4646 return previous; 4663 return previous;
4647 } 4664 }
4648 static _leave(previous) { 4665 static _leave(previous) {
4649 dart.assert(previous != null); 4666 dart.assert(previous != null);
4650 Zone._current = previous; 4667 Zone._current = previous;
4651 } 4668 }
4652 } 4669 }
4653 dart.defineNamedConstructor(Zone, '_'); 4670 dart.defineNamedConstructor(Zone, '_');
4654 Zone.ROOT = _ROOT_ZONE; 4671 dart.defineLazyProperties(Zone, {
4655 Zone._current = _ROOT_ZONE; 4672 get ROOT() {
4673 return _ROOT_ZONE;
4674 },
4675 set ROOT(_) {},
4676 get _current() {
4677 return _ROOT_ZONE;
4678 },
4679 set _current(_) {}
4680 });
4656 let _delegate = Symbol('_delegate'); 4681 let _delegate = Symbol('_delegate');
4657 // Function _parentDelegate: (_Zone) → ZoneDelegate 4682 // Function _parentDelegate: (_Zone) → ZoneDelegate
4658 function _parentDelegate(zone) { 4683 function _parentDelegate(zone) {
4659 if (zone.parent == null) 4684 if (zone.parent == null)
4660 return null; 4685 return null;
4661 return zone.parent[_delegate]; 4686 return zone.parent[_delegate];
4662 } 4687 }
4663 let _delegationTarget = Symbol('_delegationTarget'); 4688 let _delegationTarget = Symbol('_delegationTarget');
4664 let _handleUncaughtError = Symbol('_handleUncaughtError'); 4689 let _handleUncaughtError = Symbol('_handleUncaughtError');
4665 let _run = Symbol('_run'); 4690 let _run = Symbol('_run');
(...skipping 694 matching lines...) Expand 10 before | Expand all | Expand 10 after
5360 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; 5385 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler;
5361 exports.CreateTimerHandler = CreateTimerHandler; 5386 exports.CreateTimerHandler = CreateTimerHandler;
5362 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; 5387 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler;
5363 exports.PrintHandler = PrintHandler; 5388 exports.PrintHandler = PrintHandler;
5364 exports.ForkHandler = ForkHandler; 5389 exports.ForkHandler = ForkHandler;
5365 exports.ZoneSpecification = ZoneSpecification; 5390 exports.ZoneSpecification = ZoneSpecification;
5366 exports.ZoneDelegate = ZoneDelegate; 5391 exports.ZoneDelegate = ZoneDelegate;
5367 exports.Zone = Zone; 5392 exports.Zone = Zone;
5368 exports.runZoned = runZoned; 5393 exports.runZoned = runZoned;
5369 })(async, core, _internal, _js_helper, _isolate_helper, collection); 5394 })(async, core, _internal, _js_helper, _isolate_helper, collection);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698