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

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

Issue 1135883004: Make typedefs lazy again (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: 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 34 matching lines...) Expand 10 before | Expand all | Expand 10 after
45 return null; 45 return null;
46 } 46 }
47 toString() { 47 toString() {
48 let result = `Uncaught Error: ${this.error}`; 48 let result = `Uncaught Error: ${this.error}`;
49 if (this.stackTrace != null) { 49 if (this.stackTrace != null) {
50 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; 50 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`;
51 } 51 }
52 return result; 52 return result;
53 } 53 }
54 } 54 }
55 let __CastType0 = dart.typedef('__CastType0', dart.functionType(dart.dynamic, [dart.dynamic])); 55 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn amic, [dart.dynamic]));
56 let _add = Symbol('_add'); 56 let _add = Symbol('_add');
57 let _closeUnchecked = Symbol('_closeUnchecked'); 57 let _closeUnchecked = Symbol('_closeUnchecked');
58 let _addError = Symbol('_addError'); 58 let _addError = Symbol('_addError');
59 let _completeError = Symbol('_completeError'); 59 let _completeError = Symbol('_completeError');
60 let _complete = Symbol('_complete'); 60 let _complete = Symbol('_complete');
61 let _sink = Symbol('_sink'); 61 let _sink = Symbol('_sink');
62 let Stream$ = dart.generic(function(T) { 62 let Stream$ = dart.generic(function(T) {
63 class Stream extends core.Object { 63 class Stream extends core.Object {
64 Stream() { 64 Stream() {
65 } 65 }
(...skipping 1641 matching lines...) Expand 10 before | Expand all | Expand 10 after
1707 if (value === void 0) 1707 if (value === void 0)
1708 value = null; 1708 value = null;
1709 return new _Future(); 1709 return new _Future();
1710 } 1710 }
1711 } 1711 }
1712 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; 1712 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)];
1713 return _DoneSubscription; 1713 return _DoneSubscription;
1714 }); 1714 });
1715 let _DoneSubscription = _DoneSubscription$(); 1715 let _DoneSubscription = _DoneSubscription$();
1716 let __CastType2$ = dart.generic(function(T) { 1716 let __CastType2$ = dart.generic(function(T) {
1717 let __CastType2 = dart.typedef('__CastType2', dart.functionType(dart.void, [ _BufferingStreamSubscription$(T)])); 1717 let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.v oid, [_BufferingStreamSubscription$(T)]));
1718 return __CastType2; 1718 return __CastType2;
1719 }); 1719 });
1720 let __CastType2 = __CastType2$(); 1720 let __CastType2 = __CastType2$();
1721 class DeferredLibrary extends core.Object { 1721 class DeferredLibrary extends core.Object {
1722 DeferredLibrary(libraryName, opts) { 1722 DeferredLibrary(libraryName, opts) {
1723 let uri = opts && 'uri' in opts ? opts.uri : null; 1723 let uri = opts && 'uri' in opts ? opts.uri : null;
1724 this.libraryName = libraryName; 1724 this.libraryName = libraryName;
1725 this.uri = uri; 1725 this.uri = uri;
1726 } 1726 }
1727 load() { 1727 load() {
(...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after
1944 if (replacement != null) { 1944 if (replacement != null) {
1945 error = _nonNullError(replacement.error); 1945 error = _nonNullError(replacement.error);
1946 stackTrace = replacement.stackTrace; 1946 stackTrace = replacement.stackTrace;
1947 } 1947 }
1948 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); 1948 result[_completeError](error, dart.as(stackTrace, core.StackTrace));
1949 } 1949 }
1950 // Function _nonNullError: (Object) → Object 1950 // Function _nonNullError: (Object) → Object
1951 function _nonNullError(error) { 1951 function _nonNullError(error) {
1952 return error != null ? error : new core.NullThrownError(); 1952 return error != null ? error : new core.NullThrownError();
1953 } 1953 }
1954 let __CastType4 = dart.typedef('__CastType4', dart.functionType(dart.dynamic, [dart.dynamic])); 1954 let __CastType4 = dart.typedef('__CastType4', () => dart.functionType(dart.dyn amic, [dart.dynamic]));
1955 let _FutureOnValue$ = dart.generic(function(T) { 1955 let _FutureOnValue$ = dart.generic(function(T) {
1956 let _FutureOnValue = dart.typedef('_FutureOnValue', dart.functionType(dart.d ynamic, [T])); 1956 let _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionType( dart.dynamic, [T]));
1957 return _FutureOnValue; 1957 return _FutureOnValue;
1958 }); 1958 });
1959 let _FutureOnValue = _FutureOnValue$(); 1959 let _FutureOnValue = _FutureOnValue$();
1960 let _FutureErrorTest = dart.typedef('_FutureErrorTest', dart.functionType(core .bool, [dart.dynamic])); 1960 let _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionTyp e(core.bool, [dart.dynamic]));
1961 let _FutureAction = dart.typedef('_FutureAction', dart.functionType(dart.dynam ic, [])); 1961 let _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(dart .dynamic, []));
1962 let _Completer$ = dart.generic(function(T) { 1962 let _Completer$ = dart.generic(function(T) {
1963 class _Completer extends core.Object { 1963 class _Completer extends core.Object {
1964 _Completer() { 1964 _Completer() {
1965 this.future = new (_Future$(T))(); 1965 this.future = new (_Future$(T))();
1966 } 1966 }
1967 completeError(error, stackTrace) { 1967 completeError(error, stackTrace) {
1968 if (stackTrace === void 0) 1968 if (stackTrace === void 0)
1969 stackTrace = null; 1969 stackTrace = null;
1970 error = _nonNullError(error); 1970 error = _nonNullError(error);
1971 if (!dart.notNull(this.future[_mayComplete])) 1971 if (!dart.notNull(this.future[_mayComplete]))
(...skipping 571 matching lines...) Expand 10 before | Expand all | Expand 10 after
2543 dart.defineNamedConstructor(_Future, 'immediateError'); 2543 dart.defineNamedConstructor(_Future, 'immediateError');
2544 return _Future; 2544 return _Future;
2545 }); 2545 });
2546 let _Future = _Future$(); 2546 let _Future = _Future$();
2547 _Future._INCOMPLETE = 0; 2547 _Future._INCOMPLETE = 0;
2548 _Future._PENDING_COMPLETE = 1; 2548 _Future._PENDING_COMPLETE = 1;
2549 _Future._CHAINED = 2; 2549 _Future._CHAINED = 2;
2550 _Future._VALUE = 4; 2550 _Future._VALUE = 4;
2551 _Future._ERROR = 8; 2551 _Future._ERROR = 8;
2552 let __CastType6$ = dart.generic(function(T) { 2552 let __CastType6$ = dart.generic(function(T) {
2553 let __CastType6 = dart.typedef('__CastType6', dart.functionType(dart.dynamic , [T])); 2553 let __CastType6 = dart.typedef('__CastType6', () => dart.functionType(dart.d ynamic, [T]));
2554 return __CastType6; 2554 return __CastType6;
2555 }); 2555 });
2556 let __CastType6 = __CastType6$(); 2556 let __CastType6 = __CastType6$();
2557 let __CastType8 = dart.typedef('__CastType8', dart.functionType(core.bool, [da rt.dynamic])); 2557 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo l, [dart.dynamic]));
2558 let __CastType10 = dart.typedef('__CastType10', dart.functionType(dart.dynamic , [dart.dynamic])); 2558 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.d ynamic, [dart.dynamic]));
2559 let _AsyncCallback = dart.typedef('_AsyncCallback', dart.functionType(dart.voi d, [])); 2559 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da rt.void, []));
2560 class _AsyncCallbackEntry extends core.Object { 2560 class _AsyncCallbackEntry extends core.Object {
2561 _AsyncCallbackEntry(callback) { 2561 _AsyncCallbackEntry(callback) {
2562 this.callback = callback; 2562 this.callback = callback;
2563 this.next = null; 2563 this.next = null;
2564 } 2564 }
2565 } 2565 }
2566 exports._nextCallback = null; 2566 exports._nextCallback = null;
2567 exports._lastCallback = null; 2567 exports._lastCallback = null;
2568 exports._lastPriorityCallback = null; 2568 exports._lastPriorityCallback = null;
2569 exports._isInCallbackLoop = false; 2569 exports._isInCallbackLoop = false;
(...skipping 210 matching lines...) Expand 10 before | Expand all | Expand 10 after
2780 this[_sink].addError(error, stackTrace); 2780 this[_sink].addError(error, stackTrace);
2781 } 2781 }
2782 close() { 2782 close() {
2783 this[_sink].close(); 2783 this[_sink].close();
2784 } 2784 }
2785 } 2785 }
2786 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; 2786 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)];
2787 return _ControllerEventSinkWrapper; 2787 return _ControllerEventSinkWrapper;
2788 }); 2788 });
2789 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); 2789 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$();
2790 let __CastType12 = dart.typedef('__CastType12', dart.functionType(dart.void, [ StreamSubscription])); 2790 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v oid, [StreamSubscription]));
2791 let __CastType14 = dart.typedef('__CastType14', dart.functionType(dart.dynamic , [dart.dynamic, core.StackTrace])); 2791 let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart.d ynamic, [dart.dynamic, core.StackTrace]));
2792 let __CastType17 = dart.typedef('__CastType17', dart.functionType(dart.void, [ ])); 2792 let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.v oid, []));
2793 let __CastType18 = dart.typedef('__CastType18', dart.functionType(dart.void, [ EventSink])); 2793 let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.v oid, [EventSink]));
2794 let StreamController$ = dart.generic(function(T) { 2794 let StreamController$ = dart.generic(function(T) {
2795 class StreamController extends core.Object { 2795 class StreamController extends core.Object {
2796 StreamController(opts) { 2796 StreamController(opts) {
2797 let onListen = opts && 'onListen' in opts ? opts.onListen : null; 2797 let onListen = opts && 'onListen' in opts ? opts.onListen : null;
2798 let onPause = opts && 'onPause' in opts ? opts.onPause : null; 2798 let onPause = opts && 'onPause' in opts ? opts.onPause : null;
2799 let onResume = opts && 'onResume' in opts ? opts.onResume : null; 2799 let onResume = opts && 'onResume' in opts ? opts.onResume : null;
2800 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; 2800 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
2801 let sync = opts && 'sync' in opts ? opts.sync : false; 2801 let sync = opts && 'sync' in opts ? opts.sync : false;
2802 if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && d art.notNull(onResume == null) && dart.notNull(onCancel == null)) { 2802 if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && d art.notNull(onResume == null) && dart.notNull(onCancel == null)) {
2803 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC allbackAsyncStreamController(), StreamController$(T)); 2803 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC allbackAsyncStreamController(), StreamController$(T));
(...skipping 336 matching lines...) Expand 10 before | Expand all | Expand 10 after
3140 } 3140 }
3141 get [_onResume]() { 3141 get [_onResume]() {
3142 return null; 3142 return null;
3143 } 3143 }
3144 get [_onCancel]() { 3144 get [_onCancel]() {
3145 return null; 3145 return null;
3146 } 3146 }
3147 } 3147 }
3148 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _ AsyncStreamControllerDispatch, _NoCallbacks) {} 3148 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _ AsyncStreamControllerDispatch, _NoCallbacks) {}
3149 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S yncStreamControllerDispatch, _NoCallbacks) {} 3149 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S yncStreamControllerDispatch, _NoCallbacks) {}
3150 let _NotificationHandler = dart.typedef('_NotificationHandler', dart.functionT ype(dart.dynamic, [])); 3150 let _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.fun ctionType(dart.dynamic, []));
3151 // Function _runGuarded: (() → dynamic) → Future<dynamic> 3151 // Function _runGuarded: (() → dynamic) → Future<dynamic>
3152 function _runGuarded(notificationHandler) { 3152 function _runGuarded(notificationHandler) {
3153 if (notificationHandler == null) 3153 if (notificationHandler == null)
3154 return null; 3154 return null;
3155 try { 3155 try {
3156 let result = notificationHandler(); 3156 let result = notificationHandler();
3157 if (dart.is(result, Future)) 3157 if (dart.is(result, Future))
3158 return dart.as(result, Future); 3158 return dart.as(result, Future);
3159 return null; 3159 return null;
3160 } catch (e) { 3160 } catch (e) {
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after
3254 let _EventDispatch = _EventDispatch$(); 3254 let _EventDispatch = _EventDispatch$();
3255 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; 3255 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1;
3256 _BufferingStreamSubscription._STATE_CLOSED = 2; 3256 _BufferingStreamSubscription._STATE_CLOSED = 2;
3257 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; 3257 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4;
3258 _BufferingStreamSubscription._STATE_CANCELED = 8; 3258 _BufferingStreamSubscription._STATE_CANCELED = 8;
3259 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; 3259 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16;
3260 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; 3260 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32;
3261 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; 3261 _BufferingStreamSubscription._STATE_HAS_PENDING = 64;
3262 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; 3262 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128;
3263 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; 3263 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7;
3264 let _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionType( _PendingEvents, []));
3265 let _isUsed = Symbol('_isUsed');
3266 let _GeneratedStreamImpl$ = dart.generic(function(T) {
3267 class _GeneratedStreamImpl extends _StreamImpl$(T) {
3268 _GeneratedStreamImpl(pending) {
3269 this[_pending] = pending;
3270 this[_isUsed] = false;
3271 }
3272 [_createSubscription](onData, onError, onDone, cancelOnError) {
3273 dart.as(onData, dart.functionType(dart.void, [T]));
3274 dart.as(onDone, dart.functionType(dart.void, []));
3275 if (this[_isUsed])
3276 throw new core.StateError("Stream has already been listened to.");
3277 this[_isUsed] = true;
3278 return dart.as((() => {
3279 let _ = new _BufferingStreamSubscription(onData, onError, onDone, canc elOnError);
3280 _[_setPendingEvents](this[_pending]());
3281 return _;
3282 }).bind(this)(), StreamSubscription$(T));
3283 }
3284 }
3285 return _GeneratedStreamImpl;
3286 });
3287 let _GeneratedStreamImpl = _GeneratedStreamImpl$();
3264 let _eventScheduled = Symbol('_eventScheduled'); 3288 let _eventScheduled = Symbol('_eventScheduled');
3265 class _PendingEvents extends core.Object { 3289 class _PendingEvents extends core.Object {
3266 _PendingEvents() { 3290 _PendingEvents() {
3267 this[_state] = _PendingEvents._STATE_UNSCHEDULED; 3291 this[_state] = _PendingEvents._STATE_UNSCHEDULED;
3268 } 3292 }
3269 get isScheduled() { 3293 get isScheduled() {
3270 return this[_state] == _PendingEvents._STATE_SCHEDULED; 3294 return this[_state] == _PendingEvents._STATE_SCHEDULED;
3271 } 3295 }
3272 get [_eventScheduled]() { 3296 get [_eventScheduled]() {
3273 return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents._STATE_SC HEDULED); 3297 return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents._STATE_SC HEDULED);
(...skipping 14 matching lines...) Expand all
3288 return; 3312 return;
3289 this.handleNext(dispatch); 3313 this.handleNext(dispatch);
3290 }).bind(this)); 3314 }).bind(this));
3291 this[_state] = _PendingEvents._STATE_SCHEDULED; 3315 this[_state] = _PendingEvents._STATE_SCHEDULED;
3292 } 3316 }
3293 cancelSchedule() { 3317 cancelSchedule() {
3294 if (this.isScheduled) 3318 if (this.isScheduled)
3295 this[_state] = _PendingEvents._STATE_CANCELED; 3319 this[_state] = _PendingEvents._STATE_CANCELED;
3296 } 3320 }
3297 } 3321 }
3298 let _EventGenerator = dart.typedef('_EventGenerator', dart.functionType(_Pendi ngEvents, []));
3299 let _isUsed = Symbol('_isUsed');
3300 let _GeneratedStreamImpl$ = dart.generic(function(T) {
3301 class _GeneratedStreamImpl extends _StreamImpl$(T) {
3302 _GeneratedStreamImpl(pending) {
3303 this[_pending] = pending;
3304 this[_isUsed] = false;
3305 }
3306 [_createSubscription](onData, onError, onDone, cancelOnError) {
3307 dart.as(onData, dart.functionType(dart.void, [T]));
3308 dart.as(onDone, dart.functionType(dart.void, []));
3309 if (this[_isUsed])
3310 throw new core.StateError("Stream has already been listened to.");
3311 this[_isUsed] = true;
3312 return dart.as((() => {
3313 let _ = new _BufferingStreamSubscription(onData, onError, onDone, canc elOnError);
3314 _[_setPendingEvents](this[_pending]());
3315 return _;
3316 }).bind(this)(), StreamSubscription$(T));
3317 }
3318 }
3319 return _GeneratedStreamImpl;
3320 });
3321 let _GeneratedStreamImpl = _GeneratedStreamImpl$();
3322 let _iterator = Symbol('_iterator'); 3322 let _iterator = Symbol('_iterator');
3323 let _IterablePendingEvents$ = dart.generic(function(T) { 3323 let _IterablePendingEvents$ = dart.generic(function(T) {
3324 class _IterablePendingEvents extends _PendingEvents { 3324 class _IterablePendingEvents extends _PendingEvents {
3325 _IterablePendingEvents(data) { 3325 _IterablePendingEvents(data) {
3326 this[_iterator] = data[core.$iterator]; 3326 this[_iterator] = data[core.$iterator];
3327 super._PendingEvents(); 3327 super._PendingEvents();
3328 } 3328 }
3329 get isEmpty() { 3329 get isEmpty() {
3330 return this[_iterator] == null; 3330 return this[_iterator] == null;
3331 } 3331 }
(...skipping 21 matching lines...) Expand all
3353 clear() { 3353 clear() {
3354 if (this.isScheduled) 3354 if (this.isScheduled)
3355 this.cancelSchedule(); 3355 this.cancelSchedule();
3356 this[_iterator] = null; 3356 this[_iterator] = null;
3357 } 3357 }
3358 } 3358 }
3359 return _IterablePendingEvents; 3359 return _IterablePendingEvents;
3360 }); 3360 });
3361 let _IterablePendingEvents = _IterablePendingEvents$(); 3361 let _IterablePendingEvents = _IterablePendingEvents$();
3362 let _DataHandler$ = dart.generic(function(T) { 3362 let _DataHandler$ = dart.generic(function(T) {
3363 let _DataHandler = dart.typedef('_DataHandler', dart.functionType(dart.void, [T])); 3363 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart .void, [T]));
3364 return _DataHandler; 3364 return _DataHandler;
3365 }); 3365 });
3366 let _DataHandler = _DataHandler$(); 3366 let _DataHandler = _DataHandler$();
3367 let _DoneHandler = dart.typedef('_DoneHandler', dart.functionType(dart.void, [ ])); 3367 let _DoneHandler = dart.typedef('_DoneHandler', () => dart.functionType(dart.v oid, []));
3368 // Function _nullDataHandler: (dynamic) → void 3368 // Function _nullDataHandler: (dynamic) → void
3369 function _nullDataHandler(value) { 3369 function _nullDataHandler(value) {
3370 } 3370 }
3371 // Function _nullErrorHandler: (dynamic, [StackTrace]) → void 3371 // Function _nullErrorHandler: (dynamic, [StackTrace]) → void
3372 function _nullErrorHandler(error, stackTrace) { 3372 function _nullErrorHandler(error, stackTrace) {
3373 if (stackTrace === void 0) 3373 if (stackTrace === void 0)
3374 stackTrace = null; 3374 stackTrace = null;
3375 Zone.current.handleUncaughtError(error, stackTrace); 3375 Zone.current.handleUncaughtError(error, stackTrace);
3376 } 3376 }
3377 // Function _nullDoneHandler: () → void 3377 // Function _nullDoneHandler: () → void
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after
3471 this[_next] = this[_previous] = this; 3471 this[_next] = this[_previous] = this;
3472 } 3472 }
3473 [_insertBefore](newNext) { 3473 [_insertBefore](newNext) {
3474 let newPrevious = newNext[_previous]; 3474 let newPrevious = newNext[_previous];
3475 newPrevious[_next] = this; 3475 newPrevious[_next] = this;
3476 newNext[_previous] = this[_previous]; 3476 newNext[_previous] = this[_previous];
3477 this[_previous][_next] = newNext; 3477 this[_previous][_next] = newNext;
3478 this[_previous] = newPrevious; 3478 this[_previous] = newPrevious;
3479 } 3479 }
3480 } 3480 }
3481 let _broadcastCallback = dart.typedef('_broadcastCallback', dart.functionType( dart.void, [StreamSubscription])); 3481 let _broadcastCallback = dart.typedef('_broadcastCallback', () => dart.functio nType(dart.void, [StreamSubscription]));
3482 let _schedule = Symbol('_schedule'); 3482 let _schedule = Symbol('_schedule');
3483 let _isSent = Symbol('_isSent'); 3483 let _isSent = Symbol('_isSent');
3484 let _isScheduled = Symbol('_isScheduled'); 3484 let _isScheduled = Symbol('_isScheduled');
3485 let _DoneStreamSubscription$ = dart.generic(function(T) { 3485 let _DoneStreamSubscription$ = dart.generic(function(T) {
3486 class _DoneStreamSubscription extends core.Object { 3486 class _DoneStreamSubscription extends core.Object {
3487 _DoneStreamSubscription(onDone) { 3487 _DoneStreamSubscription(onDone) {
3488 this[_onDone] = onDone; 3488 this[_onDone] = onDone;
3489 this[_zone] = Zone.current; 3489 this[_zone] = Zone.current;
3490 this[_state] = 0; 3490 this[_state] = 0;
3491 this[_schedule](); 3491 this[_schedule]();
(...skipping 300 matching lines...) Expand 10 before | Expand all | Expand 10 after
3792 return _StreamIteratorImpl; 3792 return _StreamIteratorImpl;
3793 }); 3793 });
3794 let _StreamIteratorImpl = _StreamIteratorImpl$(); 3794 let _StreamIteratorImpl = _StreamIteratorImpl$();
3795 _StreamIteratorImpl._STATE_FOUND = 0; 3795 _StreamIteratorImpl._STATE_FOUND = 0;
3796 _StreamIteratorImpl._STATE_DONE = 1; 3796 _StreamIteratorImpl._STATE_DONE = 1;
3797 _StreamIteratorImpl._STATE_MOVING = 2; 3797 _StreamIteratorImpl._STATE_MOVING = 2;
3798 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; 3798 _StreamIteratorImpl._STATE_EXTRA_DATA = 3;
3799 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; 3799 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
3800 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; 3800 _StreamIteratorImpl._STATE_EXTRA_DONE = 5;
3801 let __CastType20$ = dart.generic(function(T) { 3801 let __CastType20$ = dart.generic(function(T) {
3802 let __CastType20 = dart.typedef('__CastType20', dart.functionType(dart.void, [T])); 3802 let __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart .void, [T]));
3803 return __CastType20; 3803 return __CastType20;
3804 }); 3804 });
3805 let __CastType20 = __CastType20$(); 3805 let __CastType20 = __CastType20$();
3806 let __CastType22 = dart.typedef('__CastType22', dart.functionType(dart.dynamic , [dart.dynamic, dart.dynamic])); 3806 let __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart.d ynamic, [dart.dynamic, dart.dynamic]));
3807 let __CastType25 = dart.typedef('__CastType25', dart.functionType(dart.dynamic , [dart.dynamic])); 3807 let __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart.d ynamic, [dart.dynamic]));
3808 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT race) → dynamic) → dynamic 3808 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT race) → dynamic) → dynamic
3809 function _runUserCode(userCode, onSuccess, onError) { 3809 function _runUserCode(userCode, onSuccess, onError) {
3810 try { 3810 try {
3811 dart.dcall(onSuccess, userCode()); 3811 dart.dcall(onSuccess, userCode());
3812 } catch (e) { 3812 } catch (e) {
3813 let s = dart.stackTrace(e); 3813 let s = dart.stackTrace(e);
3814 let replacement = Zone.current.errorCallback(e, s); 3814 let replacement = Zone.current.errorCallback(e, s);
3815 if (replacement == null) { 3815 if (replacement == null) {
3816 dart.dcall(onError, e, s); 3816 dart.dcall(onError, e, s);
3817 } else { 3817 } else {
(...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after
3942 this[_stream][_handleError](error, stackTrace, this); 3942 this[_stream][_handleError](error, stackTrace, this);
3943 } 3943 }
3944 [_handleDone]() { 3944 [_handleDone]() {
3945 this[_stream][_handleDone](this); 3945 this[_stream][_handleDone](this);
3946 } 3946 }
3947 } 3947 }
3948 return _ForwardingStreamSubscription; 3948 return _ForwardingStreamSubscription;
3949 }); 3949 });
3950 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); 3950 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$();
3951 let _Predicate$ = dart.generic(function(T) { 3951 let _Predicate$ = dart.generic(function(T) {
3952 let _Predicate = dart.typedef('_Predicate', dart.functionType(core.bool, [T] )); 3952 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo l, [T]));
3953 return _Predicate; 3953 return _Predicate;
3954 }); 3954 });
3955 let _Predicate = _Predicate$(); 3955 let _Predicate = _Predicate$();
3956 // Function _addErrorWithReplacement: (_EventSink<dynamic>, dynamic, dynamic) → void 3956 // Function _addErrorWithReplacement: (_EventSink<dynamic>, dynamic, dynamic) → void
3957 function _addErrorWithReplacement(sink, error, stackTrace) { 3957 function _addErrorWithReplacement(sink, error, stackTrace) {
3958 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core .StackTrace)); 3958 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core .StackTrace));
3959 if (replacement != null) { 3959 if (replacement != null) {
3960 error = _nonNullError(replacement.error); 3960 error = _nonNullError(replacement.error);
3961 stackTrace = replacement.stackTrace; 3961 stackTrace = replacement.stackTrace;
3962 } 3962 }
(...skipping 20 matching lines...) Expand all
3983 3983
3984 if (satisfies) { 3984 if (satisfies) {
3985 sink[_add](inputEvent); 3985 sink[_add](inputEvent);
3986 } 3986 }
3987 } 3987 }
3988 } 3988 }
3989 return _WhereStream; 3989 return _WhereStream;
3990 }); 3990 });
3991 let _WhereStream = _WhereStream$(); 3991 let _WhereStream = _WhereStream$();
3992 let _Transformation$ = dart.generic(function(S, T) { 3992 let _Transformation$ = dart.generic(function(S, T) {
3993 let _Transformation = dart.typedef('_Transformation', dart.functionType(T, [ S])); 3993 let _Transformation = dart.typedef('_Transformation', () => dart.functionTyp e(T, [S]));
3994 return _Transformation; 3994 return _Transformation;
3995 }); 3995 });
3996 let _Transformation = _Transformation$(); 3996 let _Transformation = _Transformation$();
3997 let _transform = Symbol('_transform'); 3997 let _transform = Symbol('_transform');
3998 let _MapStream$ = dart.generic(function(S, T) { 3998 let _MapStream$ = dart.generic(function(S, T) {
3999 class _MapStream extends _ForwardingStream$(S, T) { 3999 class _MapStream extends _ForwardingStream$(S, T) {
4000 _MapStream(source, transform) { 4000 _MapStream(source, transform) {
4001 this[_transform] = transform; 4001 this[_transform] = transform;
4002 super._ForwardingStream(source); 4002 super._ForwardingStream(source);
4003 } 4003 }
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
4036 } catch (e) { 4036 } catch (e) {
4037 let s = dart.stackTrace(e); 4037 let s = dart.stackTrace(e);
4038 _addErrorWithReplacement(sink, e, s); 4038 _addErrorWithReplacement(sink, e, s);
4039 } 4039 }
4040 4040
4041 } 4041 }
4042 } 4042 }
4043 return _ExpandStream; 4043 return _ExpandStream;
4044 }); 4044 });
4045 let _ExpandStream = _ExpandStream$(); 4045 let _ExpandStream = _ExpandStream$();
4046 let _ErrorTest = dart.typedef('_ErrorTest', dart.functionType(core.bool, [dart .dynamic])); 4046 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool, [dart.dynamic]));
4047 let _HandleErrorStream$ = dart.generic(function(T) { 4047 let _HandleErrorStream$ = dart.generic(function(T) {
4048 class _HandleErrorStream extends _ForwardingStream$(T, T) { 4048 class _HandleErrorStream extends _ForwardingStream$(T, T) {
4049 _HandleErrorStream(source, onError, test) { 4049 _HandleErrorStream(source, onError, test) {
4050 this[_transform] = onError; 4050 this[_transform] = onError;
4051 this[_test] = test; 4051 this[_test] = test;
4052 super._ForwardingStream(source); 4052 super._ForwardingStream(source);
4053 } 4053 }
4054 [_handleError](error, stackTrace, sink) { 4054 [_handleError](error, stackTrace, sink) {
4055 dart.as(sink, _EventSink$(T)); 4055 dart.as(sink, _EventSink$(T));
4056 let matches = true; 4056 let matches = true;
(...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after
4187 if (!dart.notNull(satisfies)) { 4187 if (!dart.notNull(satisfies)) {
4188 this[_hasFailed] = true; 4188 this[_hasFailed] = true;
4189 sink[_add](inputEvent); 4189 sink[_add](inputEvent);
4190 } 4190 }
4191 } 4191 }
4192 } 4192 }
4193 return _SkipWhileStream; 4193 return _SkipWhileStream;
4194 }); 4194 });
4195 let _SkipWhileStream = _SkipWhileStream$(); 4195 let _SkipWhileStream = _SkipWhileStream$();
4196 let _Equality$ = dart.generic(function(T) { 4196 let _Equality$ = dart.generic(function(T) {
4197 let _Equality = dart.typedef('_Equality', dart.functionType(core.bool, [T, T ])); 4197 let _Equality = dart.typedef('_Equality', () => dart.functionType(core.bool, [T, T]));
4198 return _Equality; 4198 return _Equality;
4199 }); 4199 });
4200 let _Equality = _Equality$(); 4200 let _Equality = _Equality$();
4201 let _equals = Symbol('_equals'); 4201 let _equals = Symbol('_equals');
4202 let _DistinctStream$ = dart.generic(function(T) { 4202 let _DistinctStream$ = dart.generic(function(T) {
4203 class _DistinctStream extends _ForwardingStream$(T, T) { 4203 class _DistinctStream extends _ForwardingStream$(T, T) {
4204 _DistinctStream(source, equals) { 4204 _DistinctStream(source, equals) {
4205 this[_previous] = _DistinctStream$()._SENTINEL; 4205 this[_previous] = _DistinctStream$()._SENTINEL;
4206 this[_equals] = equals; 4206 this[_equals] = equals;
4207 super._ForwardingStream(source); 4207 super._ForwardingStream(source);
(...skipping 139 matching lines...) Expand 10 before | Expand all | Expand 10 after
4347 let s = dart.stackTrace(e); 4347 let s = dart.stackTrace(e);
4348 this[_addError](e, s); 4348 this[_addError](e, s);
4349 } 4349 }
4350 4350
4351 } 4351 }
4352 } 4352 }
4353 return _SinkTransformerStreamSubscription; 4353 return _SinkTransformerStreamSubscription;
4354 }); 4354 });
4355 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$() ; 4355 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$() ;
4356 let _SinkMapper$ = dart.generic(function(S, T) { 4356 let _SinkMapper$ = dart.generic(function(S, T) {
4357 let _SinkMapper = dart.typedef('_SinkMapper', dart.functionType(EventSink$(S ), [EventSink$(T)])); 4357 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS ink$(S), [EventSink$(T)]));
4358 return _SinkMapper; 4358 return _SinkMapper;
4359 }); 4359 });
4360 let _SinkMapper = _SinkMapper$(); 4360 let _SinkMapper = _SinkMapper$();
4361 let _sinkMapper = Symbol('_sinkMapper'); 4361 let _sinkMapper = Symbol('_sinkMapper');
4362 let _StreamSinkTransformer$ = dart.generic(function(S, T) { 4362 let _StreamSinkTransformer$ = dart.generic(function(S, T) {
4363 class _StreamSinkTransformer extends core.Object { 4363 class _StreamSinkTransformer extends core.Object {
4364 _StreamSinkTransformer(sinkMapper) { 4364 _StreamSinkTransformer(sinkMapper) {
4365 this[_sinkMapper] = sinkMapper; 4365 this[_sinkMapper] = sinkMapper;
4366 } 4366 }
4367 bind(stream) { 4367 bind(stream) {
(...skipping 23 matching lines...) Expand all
4391 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null; 4391 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
4392 cancelOnError = core.identical(true, cancelOnError); 4392 cancelOnError = core.identical(true, cancelOnError);
4393 let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic , T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, o nDone, cancelOnError); 4393 let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic , T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, o nDone, cancelOnError);
4394 return subscription; 4394 return subscription;
4395 } 4395 }
4396 } 4396 }
4397 return _BoundSinkStream; 4397 return _BoundSinkStream;
4398 }); 4398 });
4399 let _BoundSinkStream = _BoundSinkStream$(); 4399 let _BoundSinkStream = _BoundSinkStream$();
4400 let _TransformDataHandler$ = dart.generic(function(S, T) { 4400 let _TransformDataHandler$ = dart.generic(function(S, T) {
4401 let _TransformDataHandler = dart.typedef('_TransformDataHandler', dart.funct ionType(dart.void, [S, EventSink$(T)])); 4401 let _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart .functionType(dart.void, [S, EventSink$(T)]));
4402 return _TransformDataHandler; 4402 return _TransformDataHandler;
4403 }); 4403 });
4404 let _TransformDataHandler = _TransformDataHandler$(); 4404 let _TransformDataHandler = _TransformDataHandler$();
4405 let _TransformErrorHandler$ = dart.generic(function(T) { 4405 let _TransformErrorHandler$ = dart.generic(function(T) {
4406 let _TransformErrorHandler = dart.typedef('_TransformErrorHandler', dart.fun ctionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)])); 4406 let _TransformErrorHandler = dart.typedef('_TransformErrorHandler', () => da rt.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)]));
4407 return _TransformErrorHandler; 4407 return _TransformErrorHandler;
4408 }); 4408 });
4409 let _TransformErrorHandler = _TransformErrorHandler$(); 4409 let _TransformErrorHandler = _TransformErrorHandler$();
4410 let _TransformDoneHandler$ = dart.generic(function(T) { 4410 let _TransformDoneHandler$ = dart.generic(function(T) {
4411 let _TransformDoneHandler = dart.typedef('_TransformDoneHandler', dart.funct ionType(dart.void, [EventSink$(T)])); 4411 let _TransformDoneHandler = dart.typedef('_TransformDoneHandler', () => dart .functionType(dart.void, [EventSink$(T)]));
4412 return _TransformDoneHandler; 4412 return _TransformDoneHandler;
4413 }); 4413 });
4414 let _TransformDoneHandler = _TransformDoneHandler$(); 4414 let _TransformDoneHandler = _TransformDoneHandler$();
4415 let _HandlerEventSink$ = dart.generic(function(S, T) { 4415 let _HandlerEventSink$ = dart.generic(function(S, T) {
4416 class _HandlerEventSink extends core.Object { 4416 class _HandlerEventSink extends core.Object {
4417 _HandlerEventSink(handleData, handleError, handleDone, sink) { 4417 _HandlerEventSink(handleData, handleError, handleDone, sink) {
4418 this[_handleData] = handleData; 4418 this[_handleData] = handleData;
4419 this[_handleError] = handleError; 4419 this[_handleError] = handleError;
4420 this[_handleDone] = handleDone; 4420 this[_handleDone] = handleDone;
4421 this[_sink] = sink; 4421 this[_sink] = sink;
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after
4465 sink.addError(error); 4465 sink.addError(error);
4466 } 4466 }
4467 static _defaultHandleDone(sink) { 4467 static _defaultHandleDone(sink) {
4468 sink.close(); 4468 sink.close();
4469 } 4469 }
4470 } 4470 }
4471 return _StreamHandlerTransformer; 4471 return _StreamHandlerTransformer;
4472 }); 4472 });
4473 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); 4473 let _StreamHandlerTransformer = _StreamHandlerTransformer$();
4474 let _SubscriptionTransformer$ = dart.generic(function(S, T) { 4474 let _SubscriptionTransformer$ = dart.generic(function(S, T) {
4475 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', dart .functionType(StreamSubscription$(T), [Stream$(S), core.bool])); 4475 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () = > dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool]));
4476 return _SubscriptionTransformer; 4476 return _SubscriptionTransformer;
4477 }); 4477 });
4478 let _SubscriptionTransformer = _SubscriptionTransformer$(); 4478 let _SubscriptionTransformer = _SubscriptionTransformer$();
4479 let _transformer = Symbol('_transformer'); 4479 let _transformer = Symbol('_transformer');
4480 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { 4480 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) {
4481 class _StreamSubscriptionTransformer extends core.Object { 4481 class _StreamSubscriptionTransformer extends core.Object {
4482 _StreamSubscriptionTransformer(transformer) { 4482 _StreamSubscriptionTransformer(transformer) {
4483 this[_transformer] = transformer; 4483 this[_transformer] = transformer;
4484 } 4484 }
4485 bind(stream) { 4485 bind(stream) {
(...skipping 23 matching lines...) Expand all
4509 result.onData(onData); 4509 result.onData(onData);
4510 result.onError(onError); 4510 result.onError(onError);
4511 result.onDone(onDone); 4511 result.onDone(onDone);
4512 return result; 4512 return result;
4513 } 4513 }
4514 } 4514 }
4515 return _BoundSubscriptionStream; 4515 return _BoundSubscriptionStream;
4516 }); 4516 });
4517 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); 4517 let _BoundSubscriptionStream = _BoundSubscriptionStream$();
4518 let __CastType27$ = dart.generic(function(S, T) { 4518 let __CastType27$ = dart.generic(function(S, T) {
4519 let __CastType27 = dart.typedef('__CastType27', dart.functionType(dart.void, [S, EventSink$(T)])); 4519 let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart .void, [S, EventSink$(T)]));
4520 return __CastType27; 4520 return __CastType27;
4521 }); 4521 });
4522 let __CastType27 = __CastType27$(); 4522 let __CastType27 = __CastType27$();
4523 let __CastType30$ = dart.generic(function(T) { 4523 let __CastType30$ = dart.generic(function(T) {
4524 let __CastType30 = dart.typedef('__CastType30', dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)])); 4524 let __CastType30 = dart.typedef('__CastType30', () => dart.functionType(dart .void, [core.Object, core.StackTrace, EventSink$(T)]));
4525 return __CastType30; 4525 return __CastType30;
4526 }); 4526 });
4527 let __CastType30 = __CastType30$(); 4527 let __CastType30 = __CastType30$();
4528 class Timer extends core.Object { 4528 class Timer extends core.Object {
4529 Timer(duration, callback) { 4529 Timer(duration, callback) {
4530 if (dart.equals(Zone.current, Zone.ROOT)) { 4530 if (dart.equals(Zone.current, Zone.ROOT)) {
4531 return Zone.current.createTimer(duration, callback); 4531 return Zone.current.createTimer(duration, callback);
4532 } 4532 }
4533 return Zone.current.createTimer(duration, Zone.current.bindCallback(callba ck, {runGuarded: true})); 4533 return Zone.current.createTimer(duration, Zone.current.bindCallback(callba ck, {runGuarded: true}));
4534 } 4534 }
(...skipping 13 matching lines...) Expand all
4548 return new _isolate_helper.TimerImpl(milliseconds, callback); 4548 return new _isolate_helper.TimerImpl(milliseconds, callback);
4549 } 4549 }
4550 static _createPeriodicTimer(duration, callback) { 4550 static _createPeriodicTimer(duration, callback) {
4551 let milliseconds = duration.inMilliseconds; 4551 let milliseconds = duration.inMilliseconds;
4552 if (dart.notNull(milliseconds) < 0) 4552 if (dart.notNull(milliseconds) < 0)
4553 milliseconds = 0; 4553 milliseconds = 0;
4554 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); 4554 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback);
4555 } 4555 }
4556 } 4556 }
4557 dart.defineNamedConstructor(Timer, 'periodic'); 4557 dart.defineNamedConstructor(Timer, 'periodic');
4558 let __CastType34 = dart.typedef('__CastType34', dart.functionType(dart.void, [ Timer])); 4558 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v oid, [Timer]));
4559 let ZoneCallback = dart.typedef('ZoneCallback', dart.functionType(dart.dynamic , [])); 4559 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart.d ynamic, []));
4560 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', dart.functionType(da rt.dynamic, [dart.dynamic])); 4560 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT ype(dart.dynamic, [dart.dynamic]));
4561 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', dart.functionType( dart.dynamic, [dart.dynamic, dart.dynamic])); 4561 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functio nType(dart.dynamic, [dart.dynamic, dart.dynamic]));
4562 class Zone extends core.Object { 4562 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', () => dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, cor e.StackTrace]));
4563 _() { 4563 let RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dynam ic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])]));
4564 } 4564 let RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionType( dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.d ynamic]), dart.dynamic]));
4565 static get current() { 4565 let RunBinaryHandler = dart.typedef('RunBinaryHandler', () => dart.functionTyp e(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart .dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]));
4566 return Zone._current; 4566 let RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () => da rt.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart. dynamic, [])]));
4567 } 4567 let RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandler' , () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.fun ctionType(dart.dynamic, [dart.dynamic])]));
4568 static _enter(zone) { 4568 let RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHandle r', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart. functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]));
4569 dart.assert(zone != null); 4569 let ErrorCallbackHandler = dart.typedef('ErrorCallbackHandler', () => dart.fun ctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace])) ;
4570 dart.assert(!dart.notNull(core.identical(zone, Zone._current))); 4570 let ScheduleMicrotaskHandler = dart.typedef('ScheduleMicrotaskHandler', () => dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.d ynamic, [])]));
4571 let previous = Zone._current; 4571 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo id, [])]));
4572 Zone._current = zone; 4572 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', () => dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func tionType(dart.void, [Timer])]));
4573 return previous; 4573 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v oid, [Zone, ZoneDelegate, Zone, core.String]));
4574 } 4574 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z one, ZoneDelegate, Zone, ZoneSpecification, core.Map]));
4575 static _leave(previous) { 4575 class _ZoneFunction extends core.Object {
4576 dart.assert(previous != null); 4576 _ZoneFunction(zone, func) {
4577 Zone._current = previous; 4577 this.zone = zone;
4578 this.function = func;
4578 } 4579 }
4579 } 4580 }
4580 dart.defineNamedConstructor(Zone, '_');
4581 class ZoneDelegate extends core.Object {}
4582 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', da rt.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.Stac kTrace]));
4583 let RunHandler = dart.typedef('RunHandler', dart.functionType(dart.dynamic, [Z one, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])]));
4584 let RunUnaryHandler = dart.typedef('RunUnaryHandler', dart.functionType(dart.d ynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic ]), dart.dynamic]));
4585 let RunBinaryHandler = dart.typedef('RunBinaryHandler', dart.functionType(dart .dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynam ic, dart.dynamic]), dart.dynamic, dart.dynamic]));
4586 let RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', dart.fun ctionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynami c, [])]));
4587 let RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandler' , dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.functionT ype(dart.dynamic, [dart.dynamic])]));
4588 let RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHandle r', dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.functi onType(dart.dynamic, [dart.dynamic, dart.dynamic])]));
4589 let ErrorCallbackHandler = dart.typedef('ErrorCallbackHandler', dart.functionT ype(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]));
4590 let ScheduleMicrotaskHandler = dart.typedef('ScheduleMicrotaskHandler', dart.f unctionType(dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic , [])]));
4591 let CreateTimerHandler = dart.typedef('CreateTimerHandler', dart.functionType( Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [] )]));
4592 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', da rt.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionTy pe(dart.void, [Timer])]));
4593 let PrintHandler = dart.typedef('PrintHandler', dart.functionType(dart.void, [ Zone, ZoneDelegate, Zone, core.String]));
4594 class ZoneSpecification extends core.Object { 4581 class ZoneSpecification extends core.Object {
4595 ZoneSpecification(opts) { 4582 ZoneSpecification(opts) {
4596 return new _ZoneSpecification(opts); 4583 return new _ZoneSpecification(opts);
4597 } 4584 }
4598 from(other, opts) { 4585 from(other, opts) {
4599 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han dleUncaughtError : null; 4586 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han dleUncaughtError : null;
4600 let run = opts && 'run' in opts ? opts.run : null; 4587 let run = opts && 'run' in opts ? opts.run : null;
4601 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; 4588 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null;
4602 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; 4589 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null;
4603 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC allback : null; 4590 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC allback : null;
4604 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts .registerUnaryCallback : null; 4591 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts .registerUnaryCallback : null;
4605 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op ts.registerBinaryCallback : null; 4592 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op ts.registerBinaryCallback : null;
4606 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback : null; 4593 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback : null;
4607 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul eMicrotask : null; 4594 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul eMicrotask : null;
4608 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; 4595 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null;
4609 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre atePeriodicTimer : null; 4596 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre atePeriodicTimer : null;
4610 let print = opts && 'print' in opts ? opts.print : null; 4597 let print = opts && 'print' in opts ? opts.print : null;
4611 let fork = opts && 'fork' in opts ? opts.fork : null; 4598 let fork = opts && 'fork' in opts ? opts.fork : null;
4612 return new ZoneSpecification({handleUncaughtError: handleUncaughtError != null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run : other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null ? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print : other.print, fork: fork != null ? fork : other.fork}); 4599 return new ZoneSpecification({handleUncaughtError: handleUncaughtError != null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run : other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null ? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print : other.print, fork: fork != null ? fork : other.fork});
4613 } 4600 }
4614 } 4601 }
4615 dart.defineNamedConstructor(ZoneSpecification, 'from'); 4602 dart.defineNamedConstructor(ZoneSpecification, 'from');
4616 let ForkHandler = dart.typedef('ForkHandler', dart.functionType(Zone, [Zone, Z oneDelegate, Zone, ZoneSpecification, core.Map]));
4617 class _ZoneFunction extends core.Object {
4618 _ZoneFunction(zone, func) {
4619 this.zone = zone;
4620 this.function = func;
4621 }
4622 }
4623 class _ZoneSpecification extends core.Object { 4603 class _ZoneSpecification extends core.Object {
4624 _ZoneSpecification(opts) { 4604 _ZoneSpecification(opts) {
4625 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han dleUncaughtError : null; 4605 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han dleUncaughtError : null;
4626 let run = opts && 'run' in opts ? opts.run : null; 4606 let run = opts && 'run' in opts ? opts.run : null;
4627 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; 4607 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null;
4628 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; 4608 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null;
4629 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC allback : null; 4609 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC allback : null;
4630 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts .registerUnaryCallback : null; 4610 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts .registerUnaryCallback : null;
4631 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op ts.registerBinaryCallback : null; 4611 let registerBinaryCallback = opts && 'registerBinaryCallback' in opts ? op ts.registerBinaryCallback : null;
4632 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback : null; 4612 let errorCallback = opts && 'errorCallback' in opts ? opts.errorCallback : null;
(...skipping 11 matching lines...) Expand all
4644 this.registerBinaryCallback = registerBinaryCallback; 4624 this.registerBinaryCallback = registerBinaryCallback;
4645 this.errorCallback = errorCallback; 4625 this.errorCallback = errorCallback;
4646 this.scheduleMicrotask = scheduleMicrotask; 4626 this.scheduleMicrotask = scheduleMicrotask;
4647 this.createTimer = createTimer; 4627 this.createTimer = createTimer;
4648 this.createPeriodicTimer = createPeriodicTimer; 4628 this.createPeriodicTimer = createPeriodicTimer;
4649 this.print = print; 4629 this.print = print;
4650 this.fork = fork; 4630 this.fork = fork;
4651 } 4631 }
4652 } 4632 }
4653 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; 4633 _ZoneSpecification[dart.implements] = () => [ZoneSpecification];
4634 class ZoneDelegate extends core.Object {}
4635 class Zone extends core.Object {
4636 _() {
4637 }
4638 static get current() {
4639 return Zone._current;
4640 }
4641 static _enter(zone) {
4642 dart.assert(zone != null);
4643 dart.assert(!dart.notNull(core.identical(zone, Zone._current)));
4644 let previous = Zone._current;
4645 Zone._current = zone;
4646 return previous;
4647 }
4648 static _leave(previous) {
4649 dart.assert(previous != null);
4650 Zone._current = previous;
4651 }
4652 }
4653 dart.defineNamedConstructor(Zone, '_');
4654 class _Zone extends core.Object { 4654 class _Zone extends core.Object {
4655 _Zone() { 4655 _Zone() {
4656 } 4656 }
4657 inSameErrorZone(otherZone) { 4657 inSameErrorZone(otherZone) {
4658 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone)); 4658 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone));
4659 } 4659 }
4660 } 4660 }
4661 _Zone[dart.implements] = () => [Zone]; 4661 _Zone[dart.implements] = () => [Zone];
4662 let _run = Symbol('_run'); 4662 let _run = Symbol('_run');
4663 let _runUnary = Symbol('_runUnary'); 4663 let _runUnary = Symbol('_runUnary');
(...skipping 639 matching lines...) Expand 10 before | Expand all | Expand 10 after
5303 } else if (errorHandler != null) { 5303 } else if (errorHandler != null) {
5304 zoneSpecification = new ZoneSpecification.from(zoneSpecification, {handleU ncaughtError: errorHandler}); 5304 zoneSpecification = new ZoneSpecification.from(zoneSpecification, {handleU ncaughtError: errorHandler});
5305 } 5305 }
5306 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues: zoneValues}); 5306 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues: zoneValues});
5307 if (onError != null) { 5307 if (onError != null) {
5308 return zone.runGuarded(body); 5308 return zone.runGuarded(body);
5309 } else { 5309 } else {
5310 return zone.run(body); 5310 return zone.run(body);
5311 } 5311 }
5312 } 5312 }
5313 let __CastType36 = dart.typedef('__CastType36', dart.functionType(dart.void, [ Timer])); 5313 let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.v oid, [Timer]));
5314 let __CastType38 = dart.typedef('__CastType38', dart.functionType(dart.dynamic , [dart.dynamic])); 5314 let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(dart.d ynamic, [dart.dynamic]));
5315 dart.copyProperties(exports, { 5315 dart.copyProperties(exports, {
5316 get _hasDocument() { 5316 get _hasDocument() {
5317 return typeof document == 'object'; 5317 return typeof document == 'object';
5318 } 5318 }
5319 }); 5319 });
5320 // Exports: 5320 // Exports:
5321 exports.AsyncError = AsyncError; 5321 exports.AsyncError = AsyncError;
5322 exports.Stream$ = Stream$; 5322 exports.Stream$ = Stream$;
5323 exports.Stream = Stream; 5323 exports.Stream = Stream;
5324 exports.DeferredLibrary = DeferredLibrary; 5324 exports.DeferredLibrary = DeferredLibrary;
(...skipping 17 matching lines...) Expand all
5342 exports.StreamTransformer$ = StreamTransformer$; 5342 exports.StreamTransformer$ = StreamTransformer$;
5343 exports.StreamTransformer = StreamTransformer; 5343 exports.StreamTransformer = StreamTransformer;
5344 exports.StreamIterator$ = StreamIterator$; 5344 exports.StreamIterator$ = StreamIterator$;
5345 exports.StreamIterator = StreamIterator; 5345 exports.StreamIterator = StreamIterator;
5346 exports.StreamController$ = StreamController$; 5346 exports.StreamController$ = StreamController$;
5347 exports.StreamController = StreamController; 5347 exports.StreamController = StreamController;
5348 exports.Timer = Timer; 5348 exports.Timer = Timer;
5349 exports.ZoneCallback = ZoneCallback; 5349 exports.ZoneCallback = ZoneCallback;
5350 exports.ZoneUnaryCallback = ZoneUnaryCallback; 5350 exports.ZoneUnaryCallback = ZoneUnaryCallback;
5351 exports.ZoneBinaryCallback = ZoneBinaryCallback; 5351 exports.ZoneBinaryCallback = ZoneBinaryCallback;
5352 exports.Zone = Zone;
5353 exports.ZoneDelegate = ZoneDelegate;
5354 exports.HandleUncaughtErrorHandler = HandleUncaughtErrorHandler; 5352 exports.HandleUncaughtErrorHandler = HandleUncaughtErrorHandler;
5355 exports.RunHandler = RunHandler; 5353 exports.RunHandler = RunHandler;
5356 exports.RunUnaryHandler = RunUnaryHandler; 5354 exports.RunUnaryHandler = RunUnaryHandler;
5357 exports.RunBinaryHandler = RunBinaryHandler; 5355 exports.RunBinaryHandler = RunBinaryHandler;
5358 exports.RegisterCallbackHandler = RegisterCallbackHandler; 5356 exports.RegisterCallbackHandler = RegisterCallbackHandler;
5359 exports.RegisterUnaryCallbackHandler = RegisterUnaryCallbackHandler; 5357 exports.RegisterUnaryCallbackHandler = RegisterUnaryCallbackHandler;
5360 exports.RegisterBinaryCallbackHandler = RegisterBinaryCallbackHandler; 5358 exports.RegisterBinaryCallbackHandler = RegisterBinaryCallbackHandler;
5361 exports.ErrorCallbackHandler = ErrorCallbackHandler; 5359 exports.ErrorCallbackHandler = ErrorCallbackHandler;
5362 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; 5360 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler;
5363 exports.CreateTimerHandler = CreateTimerHandler; 5361 exports.CreateTimerHandler = CreateTimerHandler;
5364 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; 5362 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler;
5365 exports.PrintHandler = PrintHandler; 5363 exports.PrintHandler = PrintHandler;
5364 exports.ForkHandler = ForkHandler;
5366 exports.ZoneSpecification = ZoneSpecification; 5365 exports.ZoneSpecification = ZoneSpecification;
5367 exports.ForkHandler = ForkHandler; 5366 exports.ZoneDelegate = ZoneDelegate;
5367 exports.Zone = Zone;
5368 exports.runZoned = runZoned; 5368 exports.runZoned = runZoned;
5369 })(async, core, _internal, _js_helper, _isolate_helper, collection); 5369 })(async, core, _internal, _js_helper, _isolate_helper, collection);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698