| OLD | NEW |
| 1 var async; | 1 var async; |
| 2 (function(async) { | 2 (function(async) { |
| 3 'use strict'; | 3 'use strict'; |
| 4 dart.copyProperties(async, { | 4 dart.copyProperties(async, { |
| 5 get _hasDocument() { | 5 get _hasDocument() { |
| 6 return dart.equals(dart.dinvokef(/* Unimplemented unknown name */JS, 'Stri
ng', 'typeof document'), 'object'); | 6 return dart.equals(dart.dinvokef(/* Unimplemented unknown name */JS, 'Stri
ng', 'typeof document'), 'object'); |
| 7 } | 7 } |
| 8 }); | 8 }); |
| 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 864 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 875 } | 875 } |
| 876 then(f, opt$) { | 876 then(f, opt$) { |
| 877 let onError = opt$.onError === void 0 ? null : opt$.onError; | 877 let onError = opt$.onError === void 0 ? null : opt$.onError; |
| 878 let result = new _Future(); | 878 let result = new _Future(); |
| 879 if (!dart.notNull(core.identical(result._zone, _ROOT_ZONE))) { | 879 if (!dart.notNull(core.identical(result._zone, _ROOT_ZONE))) { |
| 880 f = result._zone.registerUnaryCallback(dart.as(f, dart.throw_("Unimple
mented type (dynamic) → dynamic"))); | 880 f = result._zone.registerUnaryCallback(dart.as(f, dart.throw_("Unimple
mented type (dynamic) → dynamic"))); |
| 881 if (onError !== null) { | 881 if (onError !== null) { |
| 882 onError = _registerErrorHandler(onError, result._zone); | 882 onError = _registerErrorHandler(onError, result._zone); |
| 883 } | 883 } |
| 884 } | 884 } |
| 885 this._addListener(new _FutureListener.then(result, f, onError)); | 885 this._addListener(new _FutureListener.then(result, dart.as(f, _FutureOnV
alue), onError)); |
| 886 return result; | 886 return result; |
| 887 } | 887 } |
| 888 catchError(onError, opt$) { | 888 catchError(onError, opt$) { |
| 889 let test = opt$.test === void 0 ? null : opt$.test; | 889 let test = opt$.test === void 0 ? null : opt$.test; |
| 890 let result = new _Future(); | 890 let result = new _Future(); |
| 891 if (!dart.notNull(core.identical(result._zone, _ROOT_ZONE))) { | 891 if (!dart.notNull(core.identical(result._zone, _ROOT_ZONE))) { |
| 892 onError = _registerErrorHandler(onError, result._zone); | 892 onError = _registerErrorHandler(onError, result._zone); |
| 893 if (test !== null) | 893 if (test !== null) |
| 894 test = dart.as(result._zone.registerUnaryCallback(test), dart.throw_
("Unimplemented type (dynamic) → bool")); | 894 test = dart.as(result._zone.registerUnaryCallback(test), dart.throw_
("Unimplemented type (dynamic) → bool")); |
| 895 } | 895 } |
| (...skipping 385 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1281 } finally { | 1281 } finally { |
| 1282 async._lastPriorityCallback = null; | 1282 async._lastPriorityCallback = null; |
| 1283 async._isInCallbackLoop = false; | 1283 async._isInCallbackLoop = false; |
| 1284 if (async._nextCallback !== null) | 1284 if (async._nextCallback !== null) |
| 1285 _AsyncRun._scheduleImmediate(_asyncRunCallback); | 1285 _AsyncRun._scheduleImmediate(_asyncRunCallback); |
| 1286 } | 1286 } |
| 1287 } | 1287 } |
| 1288 // Function _scheduleAsyncCallback: (dynamic) → void | 1288 // Function _scheduleAsyncCallback: (dynamic) → void |
| 1289 function _scheduleAsyncCallback(callback) { | 1289 function _scheduleAsyncCallback(callback) { |
| 1290 if (async._nextCallback === null) { | 1290 if (async._nextCallback === null) { |
| 1291 async._nextCallback = async._lastCallback = new _AsyncCallbackEntry(callba
ck); | 1291 async._nextCallback = async._lastCallback = new _AsyncCallbackEntry(dart.a
s(callback, _AsyncCallback)); |
| 1292 if (!dart.notNull(async._isInCallbackLoop)) { | 1292 if (!dart.notNull(async._isInCallbackLoop)) { |
| 1293 _AsyncRun._scheduleImmediate(_asyncRunCallback); | 1293 _AsyncRun._scheduleImmediate(_asyncRunCallback); |
| 1294 } | 1294 } |
| 1295 } else { | 1295 } else { |
| 1296 let newEntry = new _AsyncCallbackEntry(callback); | 1296 let newEntry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); |
| 1297 async._lastCallback.next = newEntry; | 1297 async._lastCallback.next = newEntry; |
| 1298 async._lastCallback = newEntry; | 1298 async._lastCallback = newEntry; |
| 1299 } | 1299 } |
| 1300 } | 1300 } |
| 1301 // Function _schedulePriorityAsyncCallback: (dynamic) → void | 1301 // Function _schedulePriorityAsyncCallback: (dynamic) → void |
| 1302 function _schedulePriorityAsyncCallback(callback) { | 1302 function _schedulePriorityAsyncCallback(callback) { |
| 1303 let entry = new _AsyncCallbackEntry(callback); | 1303 let entry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); |
| 1304 if (async._nextCallback === null) { | 1304 if (async._nextCallback === null) { |
| 1305 _scheduleAsyncCallback(callback); | 1305 _scheduleAsyncCallback(callback); |
| 1306 async._lastPriorityCallback = async._lastCallback; | 1306 async._lastPriorityCallback = async._lastCallback; |
| 1307 } else if (async._lastPriorityCallback === null) { | 1307 } else if (async._lastPriorityCallback === null) { |
| 1308 entry.next = async._nextCallback; | 1308 entry.next = async._nextCallback; |
| 1309 async._nextCallback = async._lastPriorityCallback = entry; | 1309 async._nextCallback = async._lastPriorityCallback = entry; |
| 1310 } else { | 1310 } else { |
| 1311 entry.next = async._lastPriorityCallback.next; | 1311 entry.next = async._lastPriorityCallback.next; |
| 1312 async._lastPriorityCallback.next = entry; | 1312 async._lastPriorityCallback.next = entry; |
| 1313 async._lastPriorityCallback = entry; | 1313 async._lastPriorityCallback = entry; |
| (...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1444 sendEvent(); | 1444 sendEvent(); |
| 1445 }); | 1445 }); |
| 1446 }).bind(this), onCancel: (() => { | 1446 }).bind(this), onCancel: (() => { |
| 1447 if (timer !== null) | 1447 if (timer !== null) |
| 1448 timer.cancel(); | 1448 timer.cancel(); |
| 1449 timer = null; | 1449 timer = null; |
| 1450 }).bind(this)}); | 1450 }).bind(this)}); |
| 1451 return controller.stream; | 1451 return controller.stream; |
| 1452 } | 1452 } |
| 1453 Stream$eventTransformed(source, mapSink) { | 1453 Stream$eventTransformed(source, mapSink) { |
| 1454 return dart.as(new _BoundSinkStream(source, mapSink), Stream$(T)); | 1454 return dart.as(new _BoundSinkStream(source, dart.as(mapSink, _SinkMapper
)), Stream$(T)); |
| 1455 } | 1455 } |
| 1456 get isBroadcast() { | 1456 get isBroadcast() { |
| 1457 return false; | 1457 return false; |
| 1458 } | 1458 } |
| 1459 asBroadcastStream(opt$) { | 1459 asBroadcastStream(opt$) { |
| 1460 let onListen = opt$.onListen === void 0 ? null : opt$.onListen; | 1460 let onListen = opt$.onListen === void 0 ? null : opt$.onListen; |
| 1461 let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel; | 1461 let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel; |
| 1462 return new _AsBroadcastStream(this, onListen, onCancel); | 1462 return new _AsBroadcastStream(this, dart.as(onListen, dart.throw_("Unimp
lemented type (StreamSubscription<dynamic>) → void")), dart.as(onCancel, dart.th
row_("Unimplemented type (StreamSubscription<dynamic>) → void"))); |
| 1463 } | 1463 } |
| 1464 where(test) { | 1464 where(test) { |
| 1465 return new _WhereStream(this, test); | 1465 return new _WhereStream(this, test); |
| 1466 } | 1466 } |
| 1467 map(convert) { | 1467 map(convert) { |
| 1468 return new _MapStream(this, convert); | 1468 return new _MapStream(this, convert); |
| 1469 } | 1469 } |
| 1470 asyncMap(convert) { | 1470 asyncMap(convert) { |
| 1471 let controller = null; | 1471 let controller = null; |
| 1472 let subscription = null; | 1472 let subscription = null; |
| (...skipping 252 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1725 } | 1725 } |
| 1726 drain(futureValue) { | 1726 drain(futureValue) { |
| 1727 if (futureValue === void 0) | 1727 if (futureValue === void 0) |
| 1728 futureValue = null; | 1728 futureValue = null; |
| 1729 return this.listen(null, {cancelOnError: true}).asFuture(futureValue); | 1729 return this.listen(null, {cancelOnError: true}).asFuture(futureValue); |
| 1730 } | 1730 } |
| 1731 take(count) { | 1731 take(count) { |
| 1732 return dart.as(new _TakeStream(this, count), Stream$(T)); | 1732 return dart.as(new _TakeStream(this, count), Stream$(T)); |
| 1733 } | 1733 } |
| 1734 takeWhile(test) { | 1734 takeWhile(test) { |
| 1735 return dart.as(new _TakeWhileStream(this, test), Stream$(T)); | 1735 return dart.as(new _TakeWhileStream(this, dart.as(test, dart.throw_("Uni
mplemented type (dynamic) → bool"))), Stream$(T)); |
| 1736 } | 1736 } |
| 1737 skip(count) { | 1737 skip(count) { |
| 1738 return dart.as(new _SkipStream(this, count), Stream$(T)); | 1738 return dart.as(new _SkipStream(this, count), Stream$(T)); |
| 1739 } | 1739 } |
| 1740 skipWhile(test) { | 1740 skipWhile(test) { |
| 1741 return dart.as(new _SkipWhileStream(this, test), Stream$(T)); | 1741 return dart.as(new _SkipWhileStream(this, dart.as(test, dart.throw_("Uni
mplemented type (dynamic) → bool"))), Stream$(T)); |
| 1742 } | 1742 } |
| 1743 distinct(equals) { | 1743 distinct(equals) { |
| 1744 if (equals === void 0) | 1744 if (equals === void 0) |
| 1745 equals = null; | 1745 equals = null; |
| 1746 return dart.as(new _DistinctStream(this, equals), Stream$(T)); | 1746 return dart.as(new _DistinctStream(this, dart.as(equals, dart.throw_("Un
implemented type (dynamic, dynamic) → bool"))), Stream$(T)); |
| 1747 } | 1747 } |
| 1748 get first() { | 1748 get first() { |
| 1749 let future = new _Future(); | 1749 let future = new _Future(); |
| 1750 let subscription = null; | 1750 let subscription = null; |
| 1751 subscription = this.listen((value) => { | 1751 subscription = this.listen((value) => { |
| 1752 _cancelAndValue(subscription, future, value); | 1752 _cancelAndValue(subscription, future, value); |
| 1753 }, { | 1753 }, { |
| 1754 onError: future._completeError, | 1754 onError: future._completeError, |
| 1755 onDone: () => { | 1755 onDone: () => { |
| 1756 try { | 1756 try { |
| (...skipping 511 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2268 dart.assert(this._isAddingStream); | 2268 dart.assert(this._isAddingStream); |
| 2269 let addState = dart.as(this._varData, _StreamControllerAddStreamState); | 2269 let addState = dart.as(this._varData, _StreamControllerAddStreamState); |
| 2270 this._varData = addState.varData; | 2270 this._varData = addState.varData; |
| 2271 this._state = ~_STATE_ADDSTREAM; | 2271 this._state = ~_STATE_ADDSTREAM; |
| 2272 addState.complete(); | 2272 addState.complete(); |
| 2273 } | 2273 } |
| 2274 _subscribe(onData, onError, onDone, cancelOnError) { | 2274 _subscribe(onData, onError, onDone, cancelOnError) { |
| 2275 if (!dart.notNull(this._isInitialState)) { | 2275 if (!dart.notNull(this._isInitialState)) { |
| 2276 throw new core.StateError("Stream has already been listened to."); | 2276 throw new core.StateError("Stream has already been listened to."); |
| 2277 } | 2277 } |
| 2278 let subscription = new _ControllerSubscription(this, onData, onError, on
Done, cancelOnError); | 2278 let subscription = new _ControllerSubscription(this, dart.as(onData, dar
t.throw_("Unimplemented type (dynamic) → void")), onError, onDone, cancelOnError
); |
| 2279 let pendingEvents = this._pendingEvents; | 2279 let pendingEvents = this._pendingEvents; |
| 2280 this._state = _STATE_SUBSCRIBED; | 2280 this._state = _STATE_SUBSCRIBED; |
| 2281 if (this._isAddingStream) { | 2281 if (this._isAddingStream) { |
| 2282 let addState = dart.as(this._varData, _StreamControllerAddStreamState)
; | 2282 let addState = dart.as(this._varData, _StreamControllerAddStreamState)
; |
| 2283 addState.varData = subscription; | 2283 addState.varData = subscription; |
| 2284 addState.resume(); | 2284 addState.resume(); |
| 2285 } else { | 2285 } else { |
| 2286 this._varData = subscription; | 2286 this._varData = subscription; |
| 2287 } | 2287 } |
| 2288 subscription._setPendingEvents(pendingEvents); | 2288 subscription._setPendingEvents(pendingEvents); |
| (...skipping 616 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2905 this._isUsed = false; | 2905 this._isUsed = false; |
| 2906 super._StreamImpl(); | 2906 super._StreamImpl(); |
| 2907 } | 2907 } |
| 2908 _createSubscription(onData, onError, onDone, cancelOnError) { | 2908 _createSubscription(onData, onError, onDone, cancelOnError) { |
| 2909 if (this._isUsed) | 2909 if (this._isUsed) |
| 2910 throw new core.StateError("Stream has already been listened to."); | 2910 throw new core.StateError("Stream has already been listened to."); |
| 2911 this._isUsed = true; | 2911 this._isUsed = true; |
| 2912 return ((_) => { | 2912 return ((_) => { |
| 2913 _._setPendingEvents(this._pending()); | 2913 _._setPendingEvents(this._pending()); |
| 2914 return _; | 2914 return _; |
| 2915 }).bind(this)(new _BufferingStreamSubscription(onData, onError, onDone,
cancelOnError)); | 2915 }).bind(this)(new _BufferingStreamSubscription(dart.as(onData, dart.thro
w_("Unimplemented type (dynamic) → void")), onError, onDone, cancelOnError)); |
| 2916 } | 2916 } |
| 2917 } | 2917 } |
| 2918 return _GeneratedStreamImpl; | 2918 return _GeneratedStreamImpl; |
| 2919 }); | 2919 }); |
| 2920 let _GeneratedStreamImpl = _GeneratedStreamImpl$(dynamic); | 2920 let _GeneratedStreamImpl = _GeneratedStreamImpl$(dynamic); |
| 2921 let _IterablePendingEvents$ = dart.generic(function(T) { | 2921 let _IterablePendingEvents$ = dart.generic(function(T) { |
| 2922 class _IterablePendingEvents extends _PendingEvents { | 2922 class _IterablePendingEvents extends _PendingEvents { |
| 2923 _IterablePendingEvents(data) { | 2923 _IterablePendingEvents(data) { |
| 2924 this._iterator = data.iterator; | 2924 this._iterator = data.iterator; |
| 2925 super._PendingEvents(); | 2925 super._PendingEvents(); |
| (...skipping 617 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3543 sink._add(inputEvent); | 3543 sink._add(inputEvent); |
| 3544 } | 3544 } |
| 3545 } | 3545 } |
| 3546 } | 3546 } |
| 3547 return _WhereStream; | 3547 return _WhereStream; |
| 3548 }); | 3548 }); |
| 3549 let _WhereStream = _WhereStream$(dynamic); | 3549 let _WhereStream = _WhereStream$(dynamic); |
| 3550 let _MapStream$ = dart.generic(function(S, T) { | 3550 let _MapStream$ = dart.generic(function(S, T) { |
| 3551 class _MapStream extends _ForwardingStream$(S, T) { | 3551 class _MapStream extends _ForwardingStream$(S, T) { |
| 3552 _MapStream(source, transform) { | 3552 _MapStream(source, transform) { |
| 3553 this._transform = transform; | 3553 this._transform = dart.as(transform, _Transformation); |
| 3554 super._ForwardingStream(source); | 3554 super._ForwardingStream(source); |
| 3555 } | 3555 } |
| 3556 _handleData(inputEvent, sink) { | 3556 _handleData(inputEvent, sink) { |
| 3557 let outputEvent = null; | 3557 let outputEvent = null; |
| 3558 try { | 3558 try { |
| 3559 outputEvent = dart.as(this._transform(inputEvent), T); | 3559 outputEvent = dart.as(this._transform(inputEvent), T); |
| 3560 } catch (e) { | 3560 } catch (e) { |
| 3561 let s = dart.stackTrace(e); | 3561 let s = dart.stackTrace(e); |
| 3562 _addErrorWithReplacement(sink, e, s); | 3562 _addErrorWithReplacement(sink, e, s); |
| 3563 return; | 3563 return; |
| (...skipping 330 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3894 _BoundSinkStream(_stream, _sinkMapper) { | 3894 _BoundSinkStream(_stream, _sinkMapper) { |
| 3895 this._stream = _stream; | 3895 this._stream = _stream; |
| 3896 this._sinkMapper = _sinkMapper; | 3896 this._sinkMapper = _sinkMapper; |
| 3897 super.Stream(); | 3897 super.Stream(); |
| 3898 } | 3898 } |
| 3899 listen(onData, opt$) { | 3899 listen(onData, opt$) { |
| 3900 let onError = opt$.onError === void 0 ? null : opt$.onError; | 3900 let onError = opt$.onError === void 0 ? null : opt$.onError; |
| 3901 let onDone = opt$.onDone === void 0 ? null : opt$.onDone; | 3901 let onDone = opt$.onDone === void 0 ? null : opt$.onDone; |
| 3902 let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOn
Error; | 3902 let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOn
Error; |
| 3903 cancelOnError = core.identical(true, cancelOnError); | 3903 cancelOnError = core.identical(true, cancelOnError); |
| 3904 let subscription = dart.as(new _SinkTransformerStreamSubscription(this._
stream, this._sinkMapper, onData, onError, onDone, cancelOnError), StreamSubscri
ption$(T)); | 3904 let subscription = dart.as(new _SinkTransformerStreamSubscription(this._
stream, dart.as(this._sinkMapper, _SinkMapper), dart.as(onData, dart.throw_("Uni
mplemented type (dynamic) → void")), onError, onDone, cancelOnError), StreamSubs
cription$(T)); |
| 3905 return subscription; | 3905 return subscription; |
| 3906 } | 3906 } |
| 3907 } | 3907 } |
| 3908 return _BoundSinkStream; | 3908 return _BoundSinkStream; |
| 3909 }); | 3909 }); |
| 3910 let _BoundSinkStream = _BoundSinkStream$(dynamic, dynamic); | 3910 let _BoundSinkStream = _BoundSinkStream$(dynamic, dynamic); |
| 3911 let _HandlerEventSink$ = dart.generic(function(S, T) { | 3911 let _HandlerEventSink$ = dart.generic(function(S, T) { |
| 3912 class _HandlerEventSink extends dart.Object { | 3912 class _HandlerEventSink extends dart.Object { |
| 3913 _HandlerEventSink(_handleData, _handleError, _handleDone, _sink) { | 3913 _HandlerEventSink(_handleData, _handleError, _handleDone, _sink) { |
| 3914 this._handleData = _handleData; | 3914 this._handleData = _handleData; |
| (...skipping 138 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4053 let runBinary = opt$.runBinary === void 0 ? null : opt$.runBinary; | 4053 let runBinary = opt$.runBinary === void 0 ? null : opt$.runBinary; |
| 4054 let registerCallback = opt$.registerCallback === void 0 ? null : opt$.regi
sterCallback; | 4054 let registerCallback = opt$.registerCallback === void 0 ? null : opt$.regi
sterCallback; |
| 4055 let registerUnaryCallback = opt$.registerUnaryCallback === void 0 ? null :
opt$.registerUnaryCallback; | 4055 let registerUnaryCallback = opt$.registerUnaryCallback === void 0 ? null :
opt$.registerUnaryCallback; |
| 4056 let registerBinaryCallback = opt$.registerBinaryCallback === void 0 ? null
: opt$.registerBinaryCallback; | 4056 let registerBinaryCallback = opt$.registerBinaryCallback === void 0 ? null
: opt$.registerBinaryCallback; |
| 4057 let errorCallback = opt$.errorCallback === void 0 ? null : opt$.errorCallb
ack; | 4057 let errorCallback = opt$.errorCallback === void 0 ? null : opt$.errorCallb
ack; |
| 4058 let scheduleMicrotask = opt$.scheduleMicrotask === void 0 ? null : opt$.sc
heduleMicrotask; | 4058 let scheduleMicrotask = opt$.scheduleMicrotask === void 0 ? null : opt$.sc
heduleMicrotask; |
| 4059 let createTimer = opt$.createTimer === void 0 ? null : opt$.createTimer; | 4059 let createTimer = opt$.createTimer === void 0 ? null : opt$.createTimer; |
| 4060 let createPeriodicTimer = opt$.createPeriodicTimer === void 0 ? null : opt
$.createPeriodicTimer; | 4060 let createPeriodicTimer = opt$.createPeriodicTimer === void 0 ? null : opt
$.createPeriodicTimer; |
| 4061 let print = opt$.print === void 0 ? null : opt$.print; | 4061 let print = opt$.print === void 0 ? null : opt$.print; |
| 4062 let fork = opt$.fork === void 0 ? null : opt$.fork; | 4062 let fork = opt$.fork === void 0 ? null : opt$.fork; |
| 4063 return new ZoneSpecification({handleUncaughtError: handleUncaughtError !==
null ? handleUncaughtError : other.handleUncaughtError, run: run !== null ? run
: other.run, runUnary: runUnary !== null ? runUnary : other.runUnary, runBinary
: runBinary !== null ? runBinary : other.runBinary, registerCallback: registerCa
llback !== null ? registerCallback : other.registerCallback, registerUnaryCallba
ck: registerUnaryCallback !== null ? registerUnaryCallback : other.registerUnary
Callback, registerBinaryCallback: registerBinaryCallback !== null ? registerBina
ryCallback : other.registerBinaryCallback, errorCallback: errorCallback !== null
? errorCallback : other.errorCallback, scheduleMicrotask: scheduleMicrotask !==
null ? scheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer !=
= null ? createTimer : other.createTimer, createPeriodicTimer: createPeriodicTim
er !== null ? createPeriodicTimer : other.createPeriodicTimer, print: print !==
null ? print : other.print, fork: fork !== null ? fork : other.fork}); | 4063 return new ZoneSpecification({handleUncaughtError: dart.as(handleUncaughtE
rror !== null ? handleUncaughtError : other.handleUncaughtError, dart.throw_("Un
implemented type (Zone, ZoneDelegate, Zone, dynamic, StackTrace) → dynamic")), r
un: dart.as(run !== null ? run : other.run, dart.throw_("Unimplemented type (Zon
e, ZoneDelegate, Zone, () → dynamic) → dynamic")), runUnary: dart.as(runUnary !=
= null ? runUnary : other.runUnary, dart.throw_("Unimplemented type (Zone, ZoneD
elegate, Zone, (dynamic) → dynamic, dynamic) → dynamic")), runBinary: dart.as(ru
nBinary !== null ? runBinary : other.runBinary, dart.throw_("Unimplemented type
(Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic, dynamic, dynamic) → dyn
amic")), registerCallback: dart.as(registerCallback !== null ? registerCallback
: other.registerCallback, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Z
one, () → dynamic) → ZoneCallback")), registerUnaryCallback: dart.as(registerUna
ryCallback !== null ? registerUnaryCallback : other.registerUnaryCallback, dart.
throw_("Unimplemented type (Zone, ZoneDelegate, Zone, (dynamic) → dynamic) → Zon
eUnaryCallback")), registerBinaryCallback: dart.as(registerBinaryCallback !== nu
ll ? registerBinaryCallback : other.registerBinaryCallback, dart.throw_("Unimple
mented type (Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic) → ZoneBinar
yCallback")), errorCallback: dart.as(errorCallback !== null ? errorCallback : ot
her.errorCallback, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, Ob
ject, StackTrace) → AsyncError")), scheduleMicrotask: dart.as(scheduleMicrotask
!== null ? scheduleMicrotask : other.scheduleMicrotask, dart.throw_("Unimplement
ed type (Zone, ZoneDelegate, Zone, () → dynamic) → void")), createTimer: dart.as
(createTimer !== null ? createTimer : other.createTimer, dart.throw_("Unimplemen
ted type (Zone, ZoneDelegate, Zone, Duration, () → void) → Timer")), createPerio
dicTimer: dart.as(createPeriodicTimer !== null ? createPeriodicTimer : other.cre
atePeriodicTimer, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, Dur
ation, (Timer) → void) → Timer")), print: dart.as(print !== null ? print : other
.print, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, String) → voi
d")), fork: dart.as(fork !== null ? fork : other.fork, dart.throw_("Unimplemente
d type (Zone, ZoneDelegate, Zone, ZoneSpecification, Map<dynamic, dynamic>) → Zo
ne"))}); |
| 4064 } | 4064 } |
| 4065 } | 4065 } |
| 4066 dart.defineNamedConstructor(ZoneSpecification, 'from'); | 4066 dart.defineNamedConstructor(ZoneSpecification, 'from'); |
| 4067 class _ZoneSpecification extends dart.Object { | 4067 class _ZoneSpecification extends dart.Object { |
| 4068 _ZoneSpecification(opt$) { | 4068 _ZoneSpecification(opt$) { |
| 4069 let handleUncaughtError = opt$.handleUncaughtError === void 0 ? null : opt
$.handleUncaughtError; | 4069 let handleUncaughtError = opt$.handleUncaughtError === void 0 ? null : opt
$.handleUncaughtError; |
| 4070 let run = opt$.run === void 0 ? null : opt$.run; | 4070 let run = opt$.run === void 0 ? null : opt$.run; |
| 4071 let runUnary = opt$.runUnary === void 0 ? null : opt$.runUnary; | 4071 let runUnary = opt$.runUnary === void 0 ? null : opt$.runUnary; |
| 4072 let runBinary = opt$.runBinary === void 0 ? null : opt$.runBinary; | 4072 let runBinary = opt$.runBinary === void 0 ? null : opt$.runBinary; |
| 4073 let registerCallback = opt$.registerCallback === void 0 ? null : opt$.regi
sterCallback; | 4073 let registerCallback = opt$.registerCallback === void 0 ? null : opt$.regi
sterCallback; |
| (...skipping 418 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4492 let valueMap = null; | 4492 let valueMap = null; |
| 4493 if (zoneValues === null) { | 4493 if (zoneValues === null) { |
| 4494 if (dart.is(zone, _Zone)) { | 4494 if (dart.is(zone, _Zone)) { |
| 4495 valueMap = zone._map; | 4495 valueMap = zone._map; |
| 4496 } else { | 4496 } else { |
| 4497 valueMap = new collection.HashMap(); | 4497 valueMap = new collection.HashMap(); |
| 4498 } | 4498 } |
| 4499 } else { | 4499 } else { |
| 4500 valueMap = new collection.HashMap.from(zoneValues); | 4500 valueMap = new collection.HashMap.from(zoneValues); |
| 4501 } | 4501 } |
| 4502 return new _CustomZone(zone, specification, valueMap); | 4502 return new _CustomZone(dart.as(zone, _Zone), specification, valueMap); |
| 4503 } | 4503 } |
| 4504 class _RootZoneSpecification extends dart.Object { | 4504 class _RootZoneSpecification extends dart.Object { |
| 4505 get handleUncaughtError() { | 4505 get handleUncaughtError() { |
| 4506 return _rootHandleUncaughtError; | 4506 return _rootHandleUncaughtError; |
| 4507 } | 4507 } |
| 4508 get run() { | 4508 get run() { |
| 4509 return _rootRun; | 4509 return _rootRun; |
| 4510 } | 4510 } |
| 4511 get runUnary() { | 4511 get runUnary() { |
| 4512 return _rootRunUnary; | 4512 return _rootRunUnary; |
| (...skipping 27 matching lines...) Expand all Loading... |
| 4540 } | 4540 } |
| 4541 get fork() { | 4541 get fork() { |
| 4542 return _rootFork; | 4542 return _rootFork; |
| 4543 } | 4543 } |
| 4544 } | 4544 } |
| 4545 class _RootZone extends _Zone { | 4545 class _RootZone extends _Zone { |
| 4546 _RootZone() { | 4546 _RootZone() { |
| 4547 super._Zone(); | 4547 super._Zone(); |
| 4548 } | 4548 } |
| 4549 get _run() { | 4549 get _run() { |
| 4550 return new _ZoneFunction(_ROOT_ZONE, _rootRun); | 4550 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRun); |
| 4551 } | 4551 } |
| 4552 get _runUnary() { | 4552 get _runUnary() { |
| 4553 return new _ZoneFunction(_ROOT_ZONE, _rootRunUnary); | 4553 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRunUnary); |
| 4554 } | 4554 } |
| 4555 get _runBinary() { | 4555 get _runBinary() { |
| 4556 return new _ZoneFunction(_ROOT_ZONE, _rootRunBinary); | 4556 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRunBinary); |
| 4557 } | 4557 } |
| 4558 get _registerCallback() { | 4558 get _registerCallback() { |
| 4559 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback); | 4559 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRegisterCallback
); |
| 4560 } | 4560 } |
| 4561 get _registerUnaryCallback() { | 4561 get _registerUnaryCallback() { |
| 4562 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback); | 4562 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRegisterUnaryCal
lback); |
| 4563 } | 4563 } |
| 4564 get _registerBinaryCallback() { | 4564 get _registerBinaryCallback() { |
| 4565 return new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallback); | 4565 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRegisterBinaryCa
llback); |
| 4566 } | 4566 } |
| 4567 get _errorCallback() { | 4567 get _errorCallback() { |
| 4568 return new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback); | 4568 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootErrorCallback); |
| 4569 } | 4569 } |
| 4570 get _scheduleMicrotask() { | 4570 get _scheduleMicrotask() { |
| 4571 return new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask); | 4571 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootScheduleMicrotas
k); |
| 4572 } | 4572 } |
| 4573 get _createTimer() { | 4573 get _createTimer() { |
| 4574 return new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer); | 4574 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootCreateTimer); |
| 4575 } | 4575 } |
| 4576 get _createPeriodicTimer() { | 4576 get _createPeriodicTimer() { |
| 4577 return new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer); | 4577 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootCreatePeriodicTi
mer); |
| 4578 } | 4578 } |
| 4579 get _print() { | 4579 get _print() { |
| 4580 return new _ZoneFunction(_ROOT_ZONE, _rootPrint); | 4580 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootPrint); |
| 4581 } | 4581 } |
| 4582 get _fork() { | 4582 get _fork() { |
| 4583 return new _ZoneFunction(_ROOT_ZONE, _rootFork); | 4583 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootFork); |
| 4584 } | 4584 } |
| 4585 get _handleUncaughtError() { | 4585 get _handleUncaughtError() { |
| 4586 return new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError); | 4586 return new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootHandleUncaughtEr
ror); |
| 4587 } | 4587 } |
| 4588 get parent() { | 4588 get parent() { |
| 4589 return null; | 4589 return null; |
| 4590 } | 4590 } |
| 4591 get _map() { | 4591 get _map() { |
| 4592 return _rootMap; | 4592 return _rootMap; |
| 4593 } | 4593 } |
| 4594 get _delegate() { | 4594 get _delegate() { |
| 4595 if (_rootDelegate !== null) | 4595 if (_rootDelegate !== null) |
| 4596 return _rootDelegate; | 4596 return _rootDelegate; |
| (...skipping 184 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4781 async.StreamIterator$ = StreamIterator$; | 4781 async.StreamIterator$ = StreamIterator$; |
| 4782 async.StreamController = StreamController; | 4782 async.StreamController = StreamController; |
| 4783 async.StreamController$ = StreamController$; | 4783 async.StreamController$ = StreamController$; |
| 4784 async.Timer = Timer; | 4784 async.Timer = Timer; |
| 4785 async.AsyncError = AsyncError; | 4785 async.AsyncError = AsyncError; |
| 4786 async.ZoneSpecification = ZoneSpecification; | 4786 async.ZoneSpecification = ZoneSpecification; |
| 4787 async.ZoneDelegate = ZoneDelegate; | 4787 async.ZoneDelegate = ZoneDelegate; |
| 4788 async.Zone = Zone; | 4788 async.Zone = Zone; |
| 4789 async.runZoned = runZoned; | 4789 async.runZoned = runZoned; |
| 4790 })(async || (async = {})); | 4790 })(async || (async = {})); |
| OLD | NEW |