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

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

Issue 1636233002: fixes #427, static fields emitted outside the scope of their class (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: merged2 Created 4 years, 10 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/_internal.js ('k') | lib/runtime/dart/collection.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 dart_library.library('dart/async', null, /* Imports */[ 1 dart_library.library('dart/async', null, /* Imports */[
2 'dart/_runtime', 2 'dart/_runtime',
3 'dart/core', 3 'dart/core',
4 'dart/_internal', 4 'dart/_internal',
5 'dart/collection' 5 'dart/collection'
6 ], /* Lazy imports */[ 6 ], /* Lazy imports */[
7 'dart/_isolate_helper' 7 'dart/_isolate_helper'
8 ], function(exports, dart, core, _internal, collection, _isolate_helper) { 8 ], function(exports, dart, core, _internal, collection, _isolate_helper) {
9 'use strict'; 9 'use strict';
10 let dartx = dart.dartx; 10 let dartx = dart.dartx;
(...skipping 1171 matching lines...) Expand 10 before | Expand all | Expand 10 after
1182 [_onResume]: [dart.void, []], 1182 [_onResume]: [dart.void, []],
1183 [_onCancel]: [Future, []], 1183 [_onCancel]: [Future, []],
1184 [_addPending]: [dart.void, [_DelayedEvent]], 1184 [_addPending]: [dart.void, [_DelayedEvent]],
1185 [_sendData]: [dart.void, [T]], 1185 [_sendData]: [dart.void, [T]],
1186 [_sendError]: [dart.void, [core.Object, core.StackTrace]], 1186 [_sendError]: [dart.void, [core.Object, core.StackTrace]],
1187 [_sendDone]: [dart.void, []], 1187 [_sendDone]: [dart.void, []],
1188 [_guardCallback]: [dart.void, [dart.dynamic]], 1188 [_guardCallback]: [dart.void, [dart.dynamic]],
1189 [_checkState]: [dart.void, [core.bool]] 1189 [_checkState]: [dart.void, [core.bool]]
1190 }) 1190 })
1191 }); 1191 });
1192 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1;
1193 _BufferingStreamSubscription._STATE_CLOSED = 2;
1194 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4;
1195 _BufferingStreamSubscription._STATE_CANCELED = 8;
1196 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16;
1197 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32;
1198 _BufferingStreamSubscription._STATE_HAS_PENDING = 64;
1199 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128;
1200 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7;
1192 return _BufferingStreamSubscription; 1201 return _BufferingStreamSubscription;
1193 }); 1202 });
1194 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); 1203 let _BufferingStreamSubscription = _BufferingStreamSubscription$();
1195 const _recordCancel = Symbol('_recordCancel'); 1204 const _recordCancel = Symbol('_recordCancel');
1196 const _recordPause = Symbol('_recordPause'); 1205 const _recordPause = Symbol('_recordPause');
1197 const _recordResume = Symbol('_recordResume'); 1206 const _recordResume = Symbol('_recordResume');
1198 const _ControllerSubscription$ = dart.generic(function(T) { 1207 const _ControllerSubscription$ = dart.generic(function(T) {
1199 class _ControllerSubscription extends _BufferingStreamSubscription$(T) { 1208 class _ControllerSubscription extends _BufferingStreamSubscription$(T) {
1200 _ControllerSubscription(controller, onData, onError, onDone, cancelOnError ) { 1209 _ControllerSubscription(controller, onData, onError, onDone, cancelOnError ) {
1201 this[_controller] = controller; 1210 this[_controller] = controller;
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after
1253 } 1262 }
1254 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink] ; 1263 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink] ;
1255 dart.setSignature(_BroadcastSubscription, { 1264 dart.setSignature(_BroadcastSubscription, {
1256 constructors: () => ({_BroadcastSubscription: [_BroadcastSubscription$(T), [_StreamControllerLifecycle, dart.functionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]]}), 1265 constructors: () => ({_BroadcastSubscription: [_BroadcastSubscription$(T), [_StreamControllerLifecycle, dart.functionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]]}),
1257 methods: () => ({ 1266 methods: () => ({
1258 [_expectsEvent]: [core.bool, [core.int]], 1267 [_expectsEvent]: [core.bool, [core.int]],
1259 [_toggleEventId]: [dart.void, []], 1268 [_toggleEventId]: [dart.void, []],
1260 [_setRemoveAfterFiring]: [dart.void, []] 1269 [_setRemoveAfterFiring]: [dart.void, []]
1261 }) 1270 })
1262 }); 1271 });
1272 _BroadcastSubscription._STATE_EVENT_ID = 1;
1273 _BroadcastSubscription._STATE_FIRING = 2;
1274 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4;
1263 return _BroadcastSubscription; 1275 return _BroadcastSubscription;
1264 }); 1276 });
1265 let _BroadcastSubscription = _BroadcastSubscription$(); 1277 let _BroadcastSubscription = _BroadcastSubscription$();
1266 _BroadcastSubscription._STATE_EVENT_ID = 1;
1267 _BroadcastSubscription._STATE_FIRING = 2;
1268 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4;
1269 const _addStreamState = Symbol('_addStreamState'); 1278 const _addStreamState = Symbol('_addStreamState');
1270 const _doneFuture = Symbol('_doneFuture'); 1279 const _doneFuture = Symbol('_doneFuture');
1271 const _isEmpty = Symbol('_isEmpty'); 1280 const _isEmpty = Symbol('_isEmpty');
1272 const _hasOneListener = Symbol('_hasOneListener'); 1281 const _hasOneListener = Symbol('_hasOneListener');
1273 const _isAddingStream = Symbol('_isAddingStream'); 1282 const _isAddingStream = Symbol('_isAddingStream');
1274 const _mayAddEvent = Symbol('_mayAddEvent'); 1283 const _mayAddEvent = Symbol('_mayAddEvent');
1275 const _ensureDoneFuture = Symbol('_ensureDoneFuture'); 1284 const _ensureDoneFuture = Symbol('_ensureDoneFuture');
1276 const _addListener = Symbol('_addListener'); 1285 const _addListener = Symbol('_addListener');
1277 const _removeListener = Symbol('_removeListener'); 1286 const _removeListener = Symbol('_removeListener');
1278 const _callOnCancel = Symbol('_callOnCancel'); 1287 const _callOnCancel = Symbol('_callOnCancel');
(...skipping 215 matching lines...) Expand 10 before | Expand all | Expand 10 after
1494 addError: [dart.void, [core.Object], [core.StackTrace]], 1503 addError: [dart.void, [core.Object], [core.StackTrace]],
1495 close: [Future, []], 1504 close: [Future, []],
1496 addStream: [Future, [Stream$(T)], {cancelOnError: core.bool}], 1505 addStream: [Future, [Stream$(T)], {cancelOnError: core.bool}],
1497 [_add]: [dart.void, [T]], 1506 [_add]: [dart.void, [T]],
1498 [_addError]: [dart.void, [core.Object, core.StackTrace]], 1507 [_addError]: [dart.void, [core.Object, core.StackTrace]],
1499 [_close]: [dart.void, []], 1508 [_close]: [dart.void, []],
1500 [_forEachListener]: [dart.void, [dart.functionType(dart.void, [_Bufferin gStreamSubscription$(T)])]], 1509 [_forEachListener]: [dart.void, [dart.functionType(dart.void, [_Bufferin gStreamSubscription$(T)])]],
1501 [_callOnCancel]: [dart.void, []] 1510 [_callOnCancel]: [dart.void, []]
1502 }) 1511 })
1503 }); 1512 });
1513 _BroadcastStreamController._STATE_INITIAL = 0;
1514 _BroadcastStreamController._STATE_EVENT_ID = 1;
1515 _BroadcastStreamController._STATE_FIRING = 2;
1516 _BroadcastStreamController._STATE_CLOSED = 4;
1517 _BroadcastStreamController._STATE_ADDSTREAM = 8;
1504 return _BroadcastStreamController; 1518 return _BroadcastStreamController;
1505 }); 1519 });
1506 let _BroadcastStreamController = _BroadcastStreamController$(); 1520 let _BroadcastStreamController = _BroadcastStreamController$();
1507 _BroadcastStreamController._STATE_INITIAL = 0;
1508 _BroadcastStreamController._STATE_EVENT_ID = 1;
1509 _BroadcastStreamController._STATE_FIRING = 2;
1510 _BroadcastStreamController._STATE_CLOSED = 4;
1511 _BroadcastStreamController._STATE_ADDSTREAM = 8;
1512 const _SyncBroadcastStreamController$ = dart.generic(function(T) { 1521 const _SyncBroadcastStreamController$ = dart.generic(function(T) {
1513 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T) { 1522 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T) {
1514 _SyncBroadcastStreamController(onListen, onCancel) { 1523 _SyncBroadcastStreamController(onListen, onCancel) {
1515 super._BroadcastStreamController(onListen, onCancel); 1524 super._BroadcastStreamController(onListen, onCancel);
1516 } 1525 }
1517 [_sendData](data) { 1526 [_sendData](data) {
1518 dart.as(data, T); 1527 dart.as(data, T);
1519 if (dart.notNull(this[_isEmpty])) return; 1528 if (dart.notNull(this[_isEmpty])) return;
1520 if (dart.notNull(this[_hasOneListener])) { 1529 if (dart.notNull(this[_hasOneListener])) {
1521 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStr eamController._STATE_FIRING); 1530 this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStr eamController._STATE_FIRING);
(...skipping 400 matching lines...) Expand 10 before | Expand all | Expand 10 after
1922 error: [Future$(T), [core.Object], [core.StackTrace]], 1931 error: [Future$(T), [core.Object], [core.StackTrace]],
1923 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]] 1932 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]]
1924 }), 1933 }),
1925 statics: () => ({ 1934 statics: () => ({
1926 wait: [Future$(core.List), [core.Iterable$(Future$())], {eagerError: cor e.bool, cleanUp: dart.functionType(dart.void, [dart.dynamic])}], 1935 wait: [Future$(core.List), [core.Iterable$(Future$())], {eagerError: cor e.bool, cleanUp: dart.functionType(dart.void, [dart.dynamic])}],
1927 forEach: [Future$(), [core.Iterable, dart.functionType(dart.dynamic, [da rt.dynamic])]], 1936 forEach: [Future$(), [core.Iterable, dart.functionType(dart.dynamic, [da rt.dynamic])]],
1928 doWhile: [Future$(), [dart.functionType(dart.dynamic, [])]] 1937 doWhile: [Future$(), [dart.functionType(dart.dynamic, [])]]
1929 }), 1938 }),
1930 names: ['wait', 'forEach', 'doWhile'] 1939 names: ['wait', 'forEach', 'doWhile']
1931 }); 1940 });
1941 dart.defineLazyProperties(Future, {
1942 get _nullFuture() {
1943 return new _Future.immediate(null);
1944 }
1945 });
1932 return Future; 1946 return Future;
1933 }); 1947 });
1934 let Future = Future$(); 1948 let Future = Future$();
1935 dart.defineLazyProperties(Future, {
1936 get _nullFuture() {
1937 return new _Future.immediate(null);
1938 }
1939 });
1940 class TimeoutException extends core.Object { 1949 class TimeoutException extends core.Object {
1941 TimeoutException(message, duration) { 1950 TimeoutException(message, duration) {
1942 if (duration === void 0) duration = null; 1951 if (duration === void 0) duration = null;
1943 this.message = message; 1952 this.message = message;
1944 this.duration = duration; 1953 this.duration = duration;
1945 } 1954 }
1946 toString() { 1955 toString() {
1947 let result = "TimeoutException"; 1956 let result = "TimeoutException";
1948 if (this.duration != null) result = `TimeoutException after ${this.duratio n}`; 1957 if (this.duration != null) result = `TimeoutException after ${this.duratio n}`;
1949 if (this.message != null) result = `${result}: ${this.message}`; 1958 if (this.message != null) result = `${result}: ${this.message}`;
(...skipping 191 matching lines...) Expand 10 before | Expand all | Expand 10 after
2141 catchError: [_FutureListener, [_Future, core.Function, _FutureErrorTest]], 2150 catchError: [_FutureListener, [_Future, core.Function, _FutureErrorTest]],
2142 whenComplete: [_FutureListener, [_Future, _FutureAction]], 2151 whenComplete: [_FutureListener, [_Future, _FutureAction]],
2143 chain: [_FutureListener, [_Future]] 2152 chain: [_FutureListener, [_Future]]
2144 }) 2153 })
2145 }); 2154 });
2146 _FutureListener.MASK_VALUE = 1; 2155 _FutureListener.MASK_VALUE = 1;
2147 _FutureListener.MASK_ERROR = 2; 2156 _FutureListener.MASK_ERROR = 2;
2148 _FutureListener.MASK_TEST_ERROR = 4; 2157 _FutureListener.MASK_TEST_ERROR = 4;
2149 _FutureListener.MASK_WHENCOMPLETE = 8; 2158 _FutureListener.MASK_WHENCOMPLETE = 8;
2150 _FutureListener.STATE_CHAIN = 0; 2159 _FutureListener.STATE_CHAIN = 0;
2151 _FutureListener.STATE_THEN = _FutureListener.MASK_VALUE; 2160 dart.defineLazyProperties(_FutureListener, {
2152 _FutureListener.STATE_THEN_ONERROR = dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureListener.MASK_ERROR); 2161 get STATE_THEN() {
2153 _FutureListener.STATE_CATCHERROR = _FutureListener.MASK_ERROR; 2162 return _FutureListener.MASK_VALUE;
2154 _FutureListener.STATE_CATCHERROR_TEST = dart.notNull(_FutureListener.MASK_ERRO R) | dart.notNull(_FutureListener.MASK_TEST_ERROR); 2163 },
2155 _FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE; 2164 get STATE_THEN_ONERROR() {
2165 return dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureList ener.MASK_ERROR);
2166 },
2167 get STATE_CATCHERROR() {
2168 return _FutureListener.MASK_ERROR;
2169 },
2170 get STATE_CATCHERROR_TEST() {
2171 return dart.notNull(_FutureListener.MASK_ERROR) | dart.notNull(_FutureList ener.MASK_TEST_ERROR);
2172 },
2173 get STATE_WHENCOMPLETE() {
2174 return _FutureListener.MASK_WHENCOMPLETE;
2175 }
2176 });
2156 const _resultOrListeners = Symbol('_resultOrListeners'); 2177 const _resultOrListeners = Symbol('_resultOrListeners');
2157 const _isChained = Symbol('_isChained'); 2178 const _isChained = Symbol('_isChained');
2158 const _isComplete = Symbol('_isComplete'); 2179 const _isComplete = Symbol('_isComplete');
2159 const _hasValue = Symbol('_hasValue'); 2180 const _hasValue = Symbol('_hasValue');
2160 const _hasError = Symbol('_hasError'); 2181 const _hasError = Symbol('_hasError');
2161 const _markPendingCompletion = Symbol('_markPendingCompletion'); 2182 const _markPendingCompletion = Symbol('_markPendingCompletion');
2162 const _value = Symbol('_value'); 2183 const _value = Symbol('_value');
2163 const _error = Symbol('_error'); 2184 const _error = Symbol('_error');
2164 const _setValue = Symbol('_setValue'); 2185 const _setValue = Symbol('_setValue');
2165 const _setErrorObject = Symbol('_setErrorObject'); 2186 const _setErrorObject = Symbol('_setErrorObject');
(...skipping 435 matching lines...) Expand 10 before | Expand all | Expand 10 after
2601 [_asyncCompleteError]: [dart.void, [dart.dynamic, core.StackTrace]], 2622 [_asyncCompleteError]: [dart.void, [dart.dynamic, core.StackTrace]],
2602 timeout: [Future, [core.Duration], {onTimeout: dart.functionType(dart.dy namic, [])}] 2623 timeout: [Future, [core.Duration], {onTimeout: dart.functionType(dart.dy namic, [])}]
2603 }), 2624 }),
2604 statics: () => ({ 2625 statics: () => ({
2605 _chainForeignFuture: [dart.void, [Future, _Future$()]], 2626 _chainForeignFuture: [dart.void, [Future, _Future$()]],
2606 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]], 2627 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]],
2607 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]] 2628 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]]
2608 }), 2629 }),
2609 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners' ] 2630 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners' ]
2610 }); 2631 });
2632 _Future._INCOMPLETE = 0;
2633 _Future._PENDING_COMPLETE = 1;
2634 _Future._CHAINED = 2;
2635 _Future._VALUE = 4;
2636 _Future._ERROR = 8;
2611 return _Future; 2637 return _Future;
2612 }); 2638 });
2613 let _Future = _Future$(); 2639 let _Future = _Future$();
2614 _Future._INCOMPLETE = 0;
2615 _Future._PENDING_COMPLETE = 1;
2616 _Future._CHAINED = 2;
2617 _Future._VALUE = 4;
2618 _Future._ERROR = 8;
2619 const __CastType6$ = dart.generic(function(T, S) { 2640 const __CastType6$ = dart.generic(function(T, S) {
2620 const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(S, [ T])); 2641 const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(S, [ T]));
2621 return __CastType6; 2642 return __CastType6;
2622 }); 2643 });
2623 let __CastType6 = __CastType6$(); 2644 let __CastType6 = __CastType6$();
2624 const __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.b ool, [dart.dynamic])); 2645 const __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.b ool, [dart.dynamic]));
2625 const __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart .dynamic, [dart.dynamic])); 2646 const __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart .dynamic, [dart.dynamic]));
2626 const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType( dart.void, [])); 2647 const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType( dart.void, []));
2627 class _AsyncCallbackEntry extends core.Object { 2648 class _AsyncCallbackEntry extends core.Object {
2628 _AsyncCallbackEntry(callback) { 2649 _AsyncCallbackEntry(callback) {
(...skipping 549 matching lines...) Expand 10 before | Expand all | Expand 10 after
3178 [_closeUnchecked]: [dart.void, []], 3199 [_closeUnchecked]: [dart.void, []],
3179 [_add]: [dart.void, [T]], 3200 [_add]: [dart.void, [T]],
3180 [_addError]: [dart.void, [core.Object, core.StackTrace]], 3201 [_addError]: [dart.void, [core.Object, core.StackTrace]],
3181 [_close]: [dart.void, []], 3202 [_close]: [dart.void, []],
3182 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T] ), core.Function, dart.functionType(dart.void, []), core.bool]], 3203 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T] ), core.Function, dart.functionType(dart.void, []), core.bool]],
3183 [_recordCancel]: [Future, [StreamSubscription$(T)]], 3204 [_recordCancel]: [Future, [StreamSubscription$(T)]],
3184 [_recordPause]: [dart.void, [StreamSubscription$(T)]], 3205 [_recordPause]: [dart.void, [StreamSubscription$(T)]],
3185 [_recordResume]: [dart.void, [StreamSubscription$(T)]] 3206 [_recordResume]: [dart.void, [StreamSubscription$(T)]]
3186 }) 3207 })
3187 }); 3208 });
3209 _StreamController._STATE_INITIAL = 0;
3210 _StreamController._STATE_SUBSCRIBED = 1;
3211 _StreamController._STATE_CANCELED = 2;
3212 _StreamController._STATE_SUBSCRIPTION_MASK = 3;
3213 _StreamController._STATE_CLOSED = 4;
3214 _StreamController._STATE_ADDSTREAM = 8;
3188 return _StreamController; 3215 return _StreamController;
3189 }); 3216 });
3190 let _StreamController = _StreamController$(); 3217 let _StreamController = _StreamController$();
3191 _StreamController._STATE_INITIAL = 0;
3192 _StreamController._STATE_SUBSCRIBED = 1;
3193 _StreamController._STATE_CANCELED = 2;
3194 _StreamController._STATE_SUBSCRIPTION_MASK = 3;
3195 _StreamController._STATE_CLOSED = 4;
3196 _StreamController._STATE_ADDSTREAM = 8;
3197 const _SyncStreamControllerDispatch$ = dart.generic(function(T) { 3218 const _SyncStreamControllerDispatch$ = dart.generic(function(T) {
3198 class _SyncStreamControllerDispatch extends core.Object { 3219 class _SyncStreamControllerDispatch extends core.Object {
3199 [_sendData](data) { 3220 [_sendData](data) {
3200 dart.as(data, T); 3221 dart.as(data, T);
3201 this[_subscription][_add](data); 3222 this[_subscription][_add](data);
3202 } 3223 }
3203 [_sendError](error, stackTrace) { 3224 [_sendError](error, stackTrace) {
3204 this[_subscription][_addError](error, stackTrace); 3225 this[_subscription][_addError](error, stackTrace);
3205 } 3226 }
3206 [_sendDone]() { 3227 [_sendDone]() {
(...skipping 217 matching lines...) Expand 10 before | Expand all | Expand 10 after
3424 const _EventSink$ = dart.generic(function(T) { 3445 const _EventSink$ = dart.generic(function(T) {
3425 class _EventSink extends core.Object {} 3446 class _EventSink extends core.Object {}
3426 return _EventSink; 3447 return _EventSink;
3427 }); 3448 });
3428 let _EventSink = _EventSink$(); 3449 let _EventSink = _EventSink$();
3429 const _EventDispatch$ = dart.generic(function(T) { 3450 const _EventDispatch$ = dart.generic(function(T) {
3430 class _EventDispatch extends core.Object {} 3451 class _EventDispatch extends core.Object {}
3431 return _EventDispatch; 3452 return _EventDispatch;
3432 }); 3453 });
3433 let _EventDispatch = _EventDispatch$(); 3454 let _EventDispatch = _EventDispatch$();
3434 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1;
3435 _BufferingStreamSubscription._STATE_CLOSED = 2;
3436 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4;
3437 _BufferingStreamSubscription._STATE_CANCELED = 8;
3438 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16;
3439 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32;
3440 _BufferingStreamSubscription._STATE_HAS_PENDING = 64;
3441 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128;
3442 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7;
3443 const _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionTyp e(_PendingEvents, [])); 3455 const _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionTyp e(_PendingEvents, []));
3444 const _isUsed = Symbol('_isUsed'); 3456 const _isUsed = Symbol('_isUsed');
3445 const _GeneratedStreamImpl$ = dart.generic(function(T) { 3457 const _GeneratedStreamImpl$ = dart.generic(function(T) {
3446 class _GeneratedStreamImpl extends _StreamImpl$(T) { 3458 class _GeneratedStreamImpl extends _StreamImpl$(T) {
3447 _GeneratedStreamImpl(pending) { 3459 _GeneratedStreamImpl(pending) {
3448 this[_pending] = pending; 3460 this[_pending] = pending;
3449 this[_isUsed] = false; 3461 this[_isUsed] = false;
3450 } 3462 }
3451 [_createSubscription](onData, onError, onDone, cancelOnError) { 3463 [_createSubscription](onData, onError, onDone, cancelOnError) {
3452 dart.as(onData, dart.functionType(dart.void, [T])); 3464 dart.as(onData, dart.functionType(dart.void, [T]));
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
3495 cancelSchedule() { 3507 cancelSchedule() {
3496 if (dart.notNull(this.isScheduled)) this[_state] = _PendingEvents._STATE_C ANCELED; 3508 if (dart.notNull(this.isScheduled)) this[_state] = _PendingEvents._STATE_C ANCELED;
3497 } 3509 }
3498 } 3510 }
3499 dart.setSignature(_PendingEvents, { 3511 dart.setSignature(_PendingEvents, {
3500 methods: () => ({ 3512 methods: () => ({
3501 schedule: [dart.void, [_EventDispatch]], 3513 schedule: [dart.void, [_EventDispatch]],
3502 cancelSchedule: [dart.void, []] 3514 cancelSchedule: [dart.void, []]
3503 }) 3515 })
3504 }); 3516 });
3517 _PendingEvents._STATE_UNSCHEDULED = 0;
3518 _PendingEvents._STATE_SCHEDULED = 1;
3519 _PendingEvents._STATE_CANCELED = 3;
3505 const _iterator = Symbol('_iterator'); 3520 const _iterator = Symbol('_iterator');
3506 const _IterablePendingEvents$ = dart.generic(function(T) { 3521 const _IterablePendingEvents$ = dart.generic(function(T) {
3507 class _IterablePendingEvents extends _PendingEvents { 3522 class _IterablePendingEvents extends _PendingEvents {
3508 _IterablePendingEvents(data) { 3523 _IterablePendingEvents(data) {
3509 this[_iterator] = data[dartx.iterator]; 3524 this[_iterator] = data[dartx.iterator];
3510 super._PendingEvents(); 3525 super._PendingEvents();
3511 } 3526 }
3512 get isEmpty() { 3527 get isEmpty() {
3513 return this[_iterator] == null; 3528 return this[_iterator] == null;
3514 } 3529 }
(...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after
3617 } 3632 }
3618 set next(_) { 3633 set next(_) {
3619 dart.throw(new core.StateError("No events after a done.")); 3634 dart.throw(new core.StateError("No events after a done."));
3620 } 3635 }
3621 } 3636 }
3622 _DelayedDone[dart.implements] = () => [_DelayedEvent]; 3637 _DelayedDone[dart.implements] = () => [_DelayedEvent];
3623 dart.setSignature(_DelayedDone, { 3638 dart.setSignature(_DelayedDone, {
3624 constructors: () => ({_DelayedDone: [_DelayedDone, []]}), 3639 constructors: () => ({_DelayedDone: [_DelayedDone, []]}),
3625 methods: () => ({perform: [dart.void, [_EventDispatch]]}) 3640 methods: () => ({perform: [dart.void, [_EventDispatch]]})
3626 }); 3641 });
3627 _PendingEvents._STATE_UNSCHEDULED = 0;
3628 _PendingEvents._STATE_SCHEDULED = 1;
3629 _PendingEvents._STATE_CANCELED = 3;
3630 class _StreamImplEvents extends _PendingEvents { 3642 class _StreamImplEvents extends _PendingEvents {
3631 _StreamImplEvents() { 3643 _StreamImplEvents() {
3632 this.firstPendingEvent = null; 3644 this.firstPendingEvent = null;
3633 this.lastPendingEvent = null; 3645 this.lastPendingEvent = null;
3634 super._PendingEvents(); 3646 super._PendingEvents();
3635 } 3647 }
3636 get isEmpty() { 3648 get isEmpty() {
3637 return this.lastPendingEvent == null; 3649 return this.lastPendingEvent == null;
3638 } 3650 }
3639 add(event) { 3651 add(event) {
(...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after
3763 onData: [dart.void, [dart.functionType(dart.void, [T])]], 3775 onData: [dart.void, [dart.functionType(dart.void, [T])]],
3764 onError: [dart.void, [core.Function]], 3776 onError: [dart.void, [core.Function]],
3765 onDone: [dart.void, [dart.functionType(dart.void, [])]], 3777 onDone: [dart.void, [dart.functionType(dart.void, [])]],
3766 pause: [dart.void, [], [Future]], 3778 pause: [dart.void, [], [Future]],
3767 resume: [dart.void, []], 3779 resume: [dart.void, []],
3768 cancel: [Future, []], 3780 cancel: [Future, []],
3769 asFuture: [Future, [], [dart.dynamic]], 3781 asFuture: [Future, [], [dart.dynamic]],
3770 [_sendDone]: [dart.void, []] 3782 [_sendDone]: [dart.void, []]
3771 }) 3783 })
3772 }); 3784 });
3785 _DoneStreamSubscription._DONE_SENT = 1;
3786 _DoneStreamSubscription._SCHEDULED = 2;
3787 _DoneStreamSubscription._PAUSED = 4;
3773 return _DoneStreamSubscription; 3788 return _DoneStreamSubscription;
3774 }); 3789 });
3775 let _DoneStreamSubscription = _DoneStreamSubscription$(); 3790 let _DoneStreamSubscription = _DoneStreamSubscription$();
3776 _DoneStreamSubscription._DONE_SENT = 1;
3777 _DoneStreamSubscription._SCHEDULED = 2;
3778 _DoneStreamSubscription._PAUSED = 4;
3779 const _source = Symbol('_source'); 3791 const _source = Symbol('_source');
3780 const _onListenHandler = Symbol('_onListenHandler'); 3792 const _onListenHandler = Symbol('_onListenHandler');
3781 const _onCancelHandler = Symbol('_onCancelHandler'); 3793 const _onCancelHandler = Symbol('_onCancelHandler');
3782 const _cancelSubscription = Symbol('_cancelSubscription'); 3794 const _cancelSubscription = Symbol('_cancelSubscription');
3783 const _pauseSubscription = Symbol('_pauseSubscription'); 3795 const _pauseSubscription = Symbol('_pauseSubscription');
3784 const _resumeSubscription = Symbol('_resumeSubscription'); 3796 const _resumeSubscription = Symbol('_resumeSubscription');
3785 const _isSubscriptionPaused = Symbol('_isSubscriptionPaused'); 3797 const _isSubscriptionPaused = Symbol('_isSubscriptionPaused');
3786 const _AsBroadcastStream$ = dart.generic(function(T) { 3798 const _AsBroadcastStream$ = dart.generic(function(T) {
3787 class _AsBroadcastStream extends Stream$(T) { 3799 class _AsBroadcastStream extends Stream$(T) {
3788 _AsBroadcastStream(source, onListenHandler, onCancelHandler) { 3800 _AsBroadcastStream(source, onListenHandler, onCancelHandler) {
(...skipping 241 matching lines...) Expand 10 before | Expand all | Expand 10 after
4030 constructors: () => ({_StreamIteratorImpl: [_StreamIteratorImpl$(T), [Stre am$(T)]]}), 4042 constructors: () => ({_StreamIteratorImpl: [_StreamIteratorImpl$(T), [Stre am$(T)]]}),
4031 methods: () => ({ 4043 methods: () => ({
4032 moveNext: [Future$(core.bool), []], 4044 moveNext: [Future$(core.bool), []],
4033 [_clear]: [dart.void, []], 4045 [_clear]: [dart.void, []],
4034 cancel: [Future, []], 4046 cancel: [Future, []],
4035 [_onData]: [dart.void, [T]], 4047 [_onData]: [dart.void, [T]],
4036 [_onError]: [dart.void, [core.Object], [core.StackTrace]], 4048 [_onError]: [dart.void, [core.Object], [core.StackTrace]],
4037 [_onDone]: [dart.void, []] 4049 [_onDone]: [dart.void, []]
4038 }) 4050 })
4039 }); 4051 });
4052 _StreamIteratorImpl._STATE_FOUND = 0;
4053 _StreamIteratorImpl._STATE_DONE = 1;
4054 _StreamIteratorImpl._STATE_MOVING = 2;
4055 _StreamIteratorImpl._STATE_EXTRA_DATA = 3;
4056 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
4057 _StreamIteratorImpl._STATE_EXTRA_DONE = 5;
4040 return _StreamIteratorImpl; 4058 return _StreamIteratorImpl;
4041 }); 4059 });
4042 let _StreamIteratorImpl = _StreamIteratorImpl$(); 4060 let _StreamIteratorImpl = _StreamIteratorImpl$();
4043 _StreamIteratorImpl._STATE_FOUND = 0;
4044 _StreamIteratorImpl._STATE_DONE = 1;
4045 _StreamIteratorImpl._STATE_MOVING = 2;
4046 _StreamIteratorImpl._STATE_EXTRA_DATA = 3;
4047 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
4048 _StreamIteratorImpl._STATE_EXTRA_DONE = 5;
4049 const __CastType20$ = dart.generic(function(T) { 4061 const __CastType20$ = dart.generic(function(T) {
4050 const __CastType20 = dart.typedef('__CastType20', () => dart.functionType(da rt.void, [T])); 4062 const __CastType20 = dart.typedef('__CastType20', () => dart.functionType(da rt.void, [T]));
4051 return __CastType20; 4063 return __CastType20;
4052 }); 4064 });
4053 let __CastType20 = __CastType20$(); 4065 let __CastType20 = __CastType20$();
4054 const __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart .dynamic, [dart.dynamic, dart.dynamic])); 4066 const __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart .dynamic, [dart.dynamic, dart.dynamic]));
4055 const __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart .dynamic, [dart.dynamic])); 4067 const __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart .dynamic, [dart.dynamic]));
4056 function _runUserCode(userCode, onSuccess, onError) { 4068 function _runUserCode(userCode, onSuccess, onError) {
4057 try { 4069 try {
4058 dart.dcall(onSuccess, userCode()); 4070 dart.dcall(onSuccess, userCode());
(...skipping 464 matching lines...) Expand 10 before | Expand all | Expand 10 after
4523 sink[_add](inputEvent); 4535 sink[_add](inputEvent);
4524 this[_previous] = inputEvent; 4536 this[_previous] = inputEvent;
4525 } 4537 }
4526 } 4538 }
4527 } 4539 }
4528 } 4540 }
4529 dart.setSignature(_DistinctStream, { 4541 dart.setSignature(_DistinctStream, {
4530 constructors: () => ({_DistinctStream: [_DistinctStream$(T), [Stream$(T), dart.functionType(core.bool, [T, T])]]}), 4542 constructors: () => ({_DistinctStream: [_DistinctStream$(T), [Stream$(T), dart.functionType(core.bool, [T, T])]]}),
4531 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]}) 4543 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4532 }); 4544 });
4545 dart.defineLazyProperties(_DistinctStream, {
4546 get _SENTINEL() {
4547 return new core.Object();
4548 },
4549 set _SENTINEL(_) {}
4550 });
4533 return _DistinctStream; 4551 return _DistinctStream;
4534 }); 4552 });
4535 let _DistinctStream = _DistinctStream$(); 4553 let _DistinctStream = _DistinctStream$();
4536 dart.defineLazyProperties(_DistinctStream, {
4537 get _SENTINEL() {
4538 return new core.Object();
4539 },
4540 set _SENTINEL(_) {}
4541 });
4542 const _EventSinkWrapper$ = dart.generic(function(T) { 4554 const _EventSinkWrapper$ = dart.generic(function(T) {
4543 class _EventSinkWrapper extends core.Object { 4555 class _EventSinkWrapper extends core.Object {
4544 _EventSinkWrapper(sink) { 4556 _EventSinkWrapper(sink) {
4545 this[_sink] = sink; 4557 this[_sink] = sink;
4546 } 4558 }
4547 add(data) { 4559 add(data) {
4548 dart.as(data, T); 4560 dart.as(data, T);
4549 this[_sink][_add](data); 4561 this[_sink][_add](data);
4550 } 4562 }
4551 addError(error, stackTrace) { 4563 addError(error, stackTrace) {
(...skipping 460 matching lines...) Expand 10 before | Expand all | Expand 10 after
5012 } 5024 }
5013 dart.defineNamedConstructor(Zone, '_'); 5025 dart.defineNamedConstructor(Zone, '_');
5014 dart.setSignature(Zone, { 5026 dart.setSignature(Zone, {
5015 constructors: () => ({_: [Zone, []]}), 5027 constructors: () => ({_: [Zone, []]}),
5016 statics: () => ({ 5028 statics: () => ({
5017 _enter: [Zone, [Zone]], 5029 _enter: [Zone, [Zone]],
5018 _leave: [dart.void, [Zone]] 5030 _leave: [dart.void, [Zone]]
5019 }), 5031 }),
5020 names: ['_enter', '_leave'] 5032 names: ['_enter', '_leave']
5021 }); 5033 });
5022 class _Zone extends core.Object { 5034 dart.defineLazyProperties(Zone, {
5023 _Zone() { 5035 get ROOT() {
5024 } 5036 return _ROOT_ZONE;
5025 inSameErrorZone(otherZone) { 5037 },
5026 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone)); 5038 get _current() {
5027 } 5039 return _ROOT_ZONE;
5040 },
5041 set _current(_) {}
5042 });
5043 const _delegate = Symbol('_delegate');
5044 function _parentDelegate(zone) {
5045 if (zone.parent == null) return null;
5046 return zone.parent[_delegate];
5028 } 5047 }
5029 _Zone[dart.implements] = () => [Zone]; 5048 dart.fn(_parentDelegate, () => dart.definiteFunctionType(ZoneDelegate, [_Zone] ));
5030 dart.setSignature(_Zone, { 5049 const _delegationTarget = Symbol('_delegationTarget');
5031 constructors: () => ({_Zone: [_Zone, []]}), 5050 const _handleUncaughtError = Symbol('_handleUncaughtError');
5032 methods: () => ({inSameErrorZone: [core.bool, [Zone]]})
5033 });
5034 const _run = Symbol('_run'); 5051 const _run = Symbol('_run');
5035 const _runUnary = Symbol('_runUnary'); 5052 const _runUnary = Symbol('_runUnary');
5036 const _runBinary = Symbol('_runBinary'); 5053 const _runBinary = Symbol('_runBinary');
5037 const _registerCallback = Symbol('_registerCallback'); 5054 const _registerCallback = Symbol('_registerCallback');
5038 const _registerUnaryCallback = Symbol('_registerUnaryCallback'); 5055 const _registerUnaryCallback = Symbol('_registerUnaryCallback');
5039 const _registerBinaryCallback = Symbol('_registerBinaryCallback'); 5056 const _registerBinaryCallback = Symbol('_registerBinaryCallback');
5040 const _errorCallback = Symbol('_errorCallback'); 5057 const _errorCallback = Symbol('_errorCallback');
5041 const _scheduleMicrotask = Symbol('_scheduleMicrotask'); 5058 const _scheduleMicrotask = Symbol('_scheduleMicrotask');
5042 const _createTimer = Symbol('_createTimer'); 5059 const _createTimer = Symbol('_createTimer');
5043 const _createPeriodicTimer = Symbol('_createPeriodicTimer'); 5060 const _createPeriodicTimer = Symbol('_createPeriodicTimer');
5044 const _print = Symbol('_print'); 5061 const _print = Symbol('_print');
5045 const _fork = Symbol('_fork'); 5062 const _fork = Symbol('_fork');
5046 const _handleUncaughtError = Symbol('_handleUncaughtError');
5047 const _map = Symbol('_map');
5048 const _delegate = Symbol('_delegate');
5049 class _RootZone extends _Zone {
5050 _RootZone() {
5051 super._Zone();
5052 }
5053 get [_run]() {
5054 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun));
5055 }
5056 get [_runUnary]() {
5057 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary));
5058 }
5059 get [_runBinary]() {
5060 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary));
5061 }
5062 get [_registerCallback]() {
5063 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback));
5064 }
5065 get [_registerUnaryCallback]() {
5066 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback ));
5067 }
5068 get [_registerBinaryCallback]() {
5069 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallbac k));
5070 }
5071 get [_errorCallback]() {
5072 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback));
5073 }
5074 get [_scheduleMicrotask]() {
5075 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask));
5076 }
5077 get [_createTimer]() {
5078 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer));
5079 }
5080 get [_createPeriodicTimer]() {
5081 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer)) ;
5082 }
5083 get [_print]() {
5084 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint));
5085 }
5086 get [_fork]() {
5087 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork));
5088 }
5089 get [_handleUncaughtError]() {
5090 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError)) ;
5091 }
5092 get parent() {
5093 return null;
5094 }
5095 get [_map]() {
5096 return _RootZone._rootMap;
5097 }
5098 get [_delegate]() {
5099 if (_RootZone._rootDelegate != null) return _RootZone._rootDelegate;
5100 return _RootZone._rootDelegate = new _ZoneDelegate(this);
5101 }
5102 get errorZone() {
5103 return this;
5104 }
5105 runGuarded(f) {
5106 try {
5107 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
5108 return f();
5109 }
5110 return _rootRun(null, null, this, f);
5111 } catch (e) {
5112 let s = dart.stackTrace(e);
5113 return this.handleUncaughtError(e, s);
5114 }
5115
5116 }
5117 runUnaryGuarded(f, arg) {
5118 try {
5119 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
5120 return dart.dcall(f, arg);
5121 }
5122 return _rootRunUnary(null, null, this, f, arg);
5123 } catch (e) {
5124 let s = dart.stackTrace(e);
5125 return this.handleUncaughtError(e, s);
5126 }
5127
5128 }
5129 runBinaryGuarded(f, arg1, arg2) {
5130 try {
5131 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
5132 return dart.dcall(f, arg1, arg2);
5133 }
5134 return _rootRunBinary(null, null, this, f, arg1, arg2);
5135 } catch (e) {
5136 let s = dart.stackTrace(e);
5137 return this.handleUncaughtError(e, s);
5138 }
5139
5140 }
5141 bindCallback(f, opts) {
5142 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
5143 if (dart.notNull(runGuarded)) {
5144 return dart.fn((() => this.runGuarded(f)).bind(this));
5145 } else {
5146 return dart.fn((() => this.run(f)).bind(this));
5147 }
5148 }
5149 bindUnaryCallback(f, opts) {
5150 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
5151 if (dart.notNull(runGuarded)) {
5152 return dart.fn((arg => this.runUnaryGuarded(f, arg)).bind(this));
5153 } else {
5154 return dart.fn((arg => this.runUnary(f, arg)).bind(this));
5155 }
5156 }
5157 bindBinaryCallback(f, opts) {
5158 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
5159 if (dart.notNull(runGuarded)) {
5160 return dart.fn(((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bi nd(this));
5161 } else {
5162 return dart.fn(((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this ));
5163 }
5164 }
5165 get(key) {
5166 return null;
5167 }
5168 handleUncaughtError(error, stackTrace) {
5169 return _rootHandleUncaughtError(null, null, this, error, stackTrace);
5170 }
5171 fork(opts) {
5172 let specification = opts && 'specification' in opts ? opts.specification : null;
5173 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
5174 return _rootFork(null, null, this, specification, zoneValues);
5175 }
5176 run(f) {
5177 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return f();
5178 return _rootRun(null, null, this, f);
5179 }
5180 runUnary(f, arg) {
5181 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.d call(f, arg);
5182 return _rootRunUnary(null, null, this, f, arg);
5183 }
5184 runBinary(f, arg1, arg2) {
5185 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.d call(f, arg1, arg2);
5186 return _rootRunBinary(null, null, this, f, arg1, arg2);
5187 }
5188 registerCallback(f) {
5189 return f;
5190 }
5191 registerUnaryCallback(f) {
5192 return f;
5193 }
5194 registerBinaryCallback(f) {
5195 return f;
5196 }
5197 errorCallback(error, stackTrace) {
5198 return null;
5199 }
5200 scheduleMicrotask(f) {
5201 _rootScheduleMicrotask(null, null, this, f);
5202 }
5203 createTimer(duration, f) {
5204 return Timer._createTimer(duration, f);
5205 }
5206 createPeriodicTimer(duration, f) {
5207 return Timer._createPeriodicTimer(duration, f);
5208 }
5209 print(line) {
5210 _internal.printToConsole(line);
5211 }
5212 }
5213 dart.setSignature(_RootZone, {
5214 constructors: () => ({_RootZone: [_RootZone, []]}),
5215 methods: () => ({
5216 runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
5217 runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dyn amic]), dart.dynamic]],
5218 runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dy namic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5219 bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {runGu arded: core.bool}],
5220 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [d art.dynamic])], {runGuarded: core.bool}],
5221 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])], {runGuarded: core.bool}],
5222 get: [dart.dynamic, [core.Object]],
5223 handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]],
5224 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}] ,
5225 run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
5226 runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]],
5227 runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5228 registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]],
5229 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic , [dart.dynamic])]],
5230 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynam ic, [dart.dynamic, dart.dynamic])]],
5231 errorCallback: [AsyncError, [core.Object, core.StackTrace]],
5232 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]],
5233 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
5234 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]],
5235 print: [dart.void, [core.String]]
5236 })
5237 });
5238 const _ROOT_ZONE = dart.const(new _RootZone());
5239 Zone.ROOT = _ROOT_ZONE;
5240 Zone._current = _ROOT_ZONE;
5241 function _parentDelegate(zone) {
5242 if (zone.parent == null) return null;
5243 return zone.parent[_delegate];
5244 }
5245 dart.fn(_parentDelegate, ZoneDelegate, [_Zone]);
5246 const _delegationTarget = Symbol('_delegationTarget');
5247 class _ZoneDelegate extends core.Object { 5063 class _ZoneDelegate extends core.Object {
5248 _ZoneDelegate(delegationTarget) { 5064 _ZoneDelegate(delegationTarget) {
5249 this[_delegationTarget] = delegationTarget; 5065 this[_delegationTarget] = delegationTarget;
5250 } 5066 }
5251 handleUncaughtError(zone, error, stackTrace) { 5067 handleUncaughtError(zone, error, stackTrace) {
5252 let implementation = this[_delegationTarget][_handleUncaughtError]; 5068 let implementation = this[_delegationTarget][_handleUncaughtError];
5253 let implZone = implementation.zone; 5069 let implZone = implementation.zone;
5254 return dart.dcall(implementation.function, implZone, _parentDelegate(implZ one), zone, error, stackTrace); 5070 return dart.dcall(implementation.function, implZone, _parentDelegate(implZ one), zone, error, stackTrace);
5255 } 5071 }
5256 run(zone, f) { 5072 run(zone, f) {
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after
5327 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(dart.d ynamic, [dart.dynamic])]], 5143 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(dart.d ynamic, [dart.dynamic])]],
5328 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(dart .dynamic, [dart.dynamic, dart.dynamic])]], 5144 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(dart .dynamic, [dart.dynamic, dart.dynamic])]],
5329 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]], 5145 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]],
5330 scheduleMicrotask: [dart.void, [Zone, dart.functionType(dart.dynamic, [])] ], 5146 scheduleMicrotask: [dart.void, [Zone, dart.functionType(dart.dynamic, [])] ],
5331 createTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.void, [] )]], 5147 createTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.void, [] )]],
5332 createPeriodicTimer: [Timer, [Zone, core.Duration, dart.functionType(dart. void, [Timer])]], 5148 createPeriodicTimer: [Timer, [Zone, core.Duration, dart.functionType(dart. void, [Timer])]],
5333 print: [dart.void, [Zone, core.String]], 5149 print: [dart.void, [Zone, core.String]],
5334 fork: [Zone, [Zone, ZoneSpecification, core.Map]] 5150 fork: [Zone, [Zone, ZoneSpecification, core.Map]]
5335 }) 5151 })
5336 }); 5152 });
5153 class _Zone extends core.Object {
5154 _Zone() {
5155 }
5156 inSameErrorZone(otherZone) {
5157 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone));
5158 }
5159 }
5160 _Zone[dart.implements] = () => [Zone];
5161 dart.setSignature(_Zone, {
5162 constructors: () => ({_Zone: [_Zone, []]}),
5163 methods: () => ({inSameErrorZone: [core.bool, [Zone]]})
5164 });
5337 const _delegateCache = Symbol('_delegateCache'); 5165 const _delegateCache = Symbol('_delegateCache');
5166 const _map = Symbol('_map');
5338 class _CustomZone extends _Zone { 5167 class _CustomZone extends _Zone {
5339 get [_delegate]() { 5168 get [_delegate]() {
5340 if (this[_delegateCache] != null) return this[_delegateCache]; 5169 if (this[_delegateCache] != null) return this[_delegateCache];
5341 this[_delegateCache] = new _ZoneDelegate(this); 5170 this[_delegateCache] = new _ZoneDelegate(this);
5342 return this[_delegateCache]; 5171 return this[_delegateCache];
5343 } 5172 }
5344 _CustomZone(parent, specification, map) { 5173 _CustomZone(parent, specification, map) {
5345 this.parent = parent; 5174 this.parent = parent;
5346 this[_map] = map; 5175 this[_map] = map;
5347 this[_runUnary] = null; 5176 this[_runUnary] = null;
(...skipping 340 matching lines...) Expand 10 before | Expand all | Expand 10 after
5688 return _rootCreatePeriodicTimer; 5517 return _rootCreatePeriodicTimer;
5689 } 5518 }
5690 get print() { 5519 get print() {
5691 return _rootPrint; 5520 return _rootPrint;
5692 } 5521 }
5693 get fork() { 5522 get fork() {
5694 return _rootFork; 5523 return _rootFork;
5695 } 5524 }
5696 } 5525 }
5697 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification]; 5526 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification];
5527 class _RootZone extends _Zone {
5528 _RootZone() {
5529 super._Zone();
5530 }
5531 get [_run]() {
5532 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun));
5533 }
5534 get [_runUnary]() {
5535 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary));
5536 }
5537 get [_runBinary]() {
5538 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary));
5539 }
5540 get [_registerCallback]() {
5541 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback));
5542 }
5543 get [_registerUnaryCallback]() {
5544 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback ));
5545 }
5546 get [_registerBinaryCallback]() {
5547 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallbac k));
5548 }
5549 get [_errorCallback]() {
5550 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback));
5551 }
5552 get [_scheduleMicrotask]() {
5553 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask));
5554 }
5555 get [_createTimer]() {
5556 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer));
5557 }
5558 get [_createPeriodicTimer]() {
5559 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer)) ;
5560 }
5561 get [_print]() {
5562 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint));
5563 }
5564 get [_fork]() {
5565 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork));
5566 }
5567 get [_handleUncaughtError]() {
5568 return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError)) ;
5569 }
5570 get parent() {
5571 return null;
5572 }
5573 get [_map]() {
5574 return _RootZone._rootMap;
5575 }
5576 get [_delegate]() {
5577 if (_RootZone._rootDelegate != null) return _RootZone._rootDelegate;
5578 return _RootZone._rootDelegate = new _ZoneDelegate(this);
5579 }
5580 get errorZone() {
5581 return this;
5582 }
5583 runGuarded(f) {
5584 try {
5585 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
5586 return f();
5587 }
5588 return _rootRun(null, null, this, f);
5589 } catch (e) {
5590 let s = dart.stackTrace(e);
5591 return this.handleUncaughtError(e, s);
5592 }
5593
5594 }
5595 runUnaryGuarded(f, arg) {
5596 try {
5597 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
5598 return dart.dcall(f, arg);
5599 }
5600 return _rootRunUnary(null, null, this, f, arg);
5601 } catch (e) {
5602 let s = dart.stackTrace(e);
5603 return this.handleUncaughtError(e, s);
5604 }
5605
5606 }
5607 runBinaryGuarded(f, arg1, arg2) {
5608 try {
5609 if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
5610 return dart.dcall(f, arg1, arg2);
5611 }
5612 return _rootRunBinary(null, null, this, f, arg1, arg2);
5613 } catch (e) {
5614 let s = dart.stackTrace(e);
5615 return this.handleUncaughtError(e, s);
5616 }
5617
5618 }
5619 bindCallback(f, opts) {
5620 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
5621 if (dart.notNull(runGuarded)) {
5622 return dart.fn((() => this.runGuarded(f)).bind(this));
5623 } else {
5624 return dart.fn((() => this.run(f)).bind(this));
5625 }
5626 }
5627 bindUnaryCallback(f, opts) {
5628 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
5629 if (dart.notNull(runGuarded)) {
5630 return dart.fn((arg => this.runUnaryGuarded(f, arg)).bind(this));
5631 } else {
5632 return dart.fn((arg => this.runUnary(f, arg)).bind(this));
5633 }
5634 }
5635 bindBinaryCallback(f, opts) {
5636 let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
5637 if (dart.notNull(runGuarded)) {
5638 return dart.fn(((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bi nd(this));
5639 } else {
5640 return dart.fn(((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this ));
5641 }
5642 }
5643 get(key) {
5644 return null;
5645 }
5646 handleUncaughtError(error, stackTrace) {
5647 return _rootHandleUncaughtError(null, null, this, error, stackTrace);
5648 }
5649 fork(opts) {
5650 let specification = opts && 'specification' in opts ? opts.specification : null;
5651 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
5652 return _rootFork(null, null, this, specification, zoneValues);
5653 }
5654 run(f) {
5655 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return f();
5656 return _rootRun(null, null, this, f);
5657 }
5658 runUnary(f, arg) {
5659 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.d call(f, arg);
5660 return _rootRunUnary(null, null, this, f, arg);
5661 }
5662 runBinary(f, arg1, arg2) {
5663 if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.d call(f, arg1, arg2);
5664 return _rootRunBinary(null, null, this, f, arg1, arg2);
5665 }
5666 registerCallback(f) {
5667 return f;
5668 }
5669 registerUnaryCallback(f) {
5670 return f;
5671 }
5672 registerBinaryCallback(f) {
5673 return f;
5674 }
5675 errorCallback(error, stackTrace) {
5676 return null;
5677 }
5678 scheduleMicrotask(f) {
5679 _rootScheduleMicrotask(null, null, this, f);
5680 }
5681 createTimer(duration, f) {
5682 return Timer._createTimer(duration, f);
5683 }
5684 createPeriodicTimer(duration, f) {
5685 return Timer._createPeriodicTimer(duration, f);
5686 }
5687 print(line) {
5688 _internal.printToConsole(line);
5689 }
5690 }
5691 dart.setSignature(_RootZone, {
5692 constructors: () => ({_RootZone: [_RootZone, []]}),
5693 methods: () => ({
5694 runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
5695 runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dyn amic]), dart.dynamic]],
5696 runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dy namic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5697 bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {runGu arded: core.bool}],
5698 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [d art.dynamic])], {runGuarded: core.bool}],
5699 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])], {runGuarded: core.bool}],
5700 get: [dart.dynamic, [core.Object]],
5701 handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]],
5702 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}] ,
5703 run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
5704 runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]],
5705 runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5706 registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]],
5707 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic , [dart.dynamic])]],
5708 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynam ic, [dart.dynamic, dart.dynamic])]],
5709 errorCallback: [AsyncError, [core.Object, core.StackTrace]],
5710 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]],
5711 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
5712 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]],
5713 print: [dart.void, [core.String]]
5714 })
5715 });
5698 _RootZone._rootDelegate = null; 5716 _RootZone._rootDelegate = null;
5699 dart.defineLazyProperties(_RootZone, { 5717 dart.defineLazyProperties(_RootZone, {
5700 get _rootMap() { 5718 get _rootMap() {
5701 return collection.HashMap.new(); 5719 return collection.HashMap.new();
5702 }, 5720 },
5703 set _rootMap(_) {} 5721 set _rootMap(_) {}
5704 }); 5722 });
5723 const _ROOT_ZONE = dart.const(new _RootZone());
5705 function runZoned(body, opts) { 5724 function runZoned(body, opts) {
5706 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null; 5725 let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
5707 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci fication : null; 5726 let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpeci fication : null;
5708 let onError = opts && 'onError' in opts ? opts.onError : null; 5727 let onError = opts && 'onError' in opts ? opts.onError : null;
5709 let errorHandler = null; 5728 let errorHandler = null;
5710 if (onError != null) { 5729 if (onError != null) {
5711 errorHandler = dart.fn((self, parent, zone, error, stackTrace) => { 5730 errorHandler = dart.fn((self, parent, zone, error, stackTrace) => {
5712 try { 5731 try {
5713 if (dart.is(onError, ZoneBinaryCallback)) { 5732 if (dart.is(onError, ZoneBinaryCallback)) {
5714 return self.parent.runBinary(onError, error, stackTrace); 5733 return self.parent.runBinary(onError, error, stackTrace);
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after
5801 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; 5820 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler;
5802 exports.CreateTimerHandler = CreateTimerHandler; 5821 exports.CreateTimerHandler = CreateTimerHandler;
5803 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; 5822 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler;
5804 exports.PrintHandler = PrintHandler; 5823 exports.PrintHandler = PrintHandler;
5805 exports.ForkHandler = ForkHandler; 5824 exports.ForkHandler = ForkHandler;
5806 exports.ZoneSpecification = ZoneSpecification; 5825 exports.ZoneSpecification = ZoneSpecification;
5807 exports.ZoneDelegate = ZoneDelegate; 5826 exports.ZoneDelegate = ZoneDelegate;
5808 exports.Zone = Zone; 5827 exports.Zone = Zone;
5809 exports.runZoned = runZoned; 5828 exports.runZoned = runZoned;
5810 }); 5829 });
OLDNEW
« no previous file with comments | « lib/runtime/dart/_internal.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698