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

Unified 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, 11 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « lib/runtime/dart/_internal.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: lib/runtime/dart/async.js
diff --git a/lib/runtime/dart/async.js b/lib/runtime/dart/async.js
index dc746afdc18f53514d44595bca094bf3bcd92fb0..f01bd148074e6138341b5ec67fb4fa23f3aa80c2 100644
--- a/lib/runtime/dart/async.js
+++ b/lib/runtime/dart/async.js
@@ -1189,6 +1189,15 @@ dart_library.library('dart/async', null, /* Imports */[
[_checkState]: [dart.void, [core.bool]]
})
});
+ _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1;
+ _BufferingStreamSubscription._STATE_CLOSED = 2;
+ _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4;
+ _BufferingStreamSubscription._STATE_CANCELED = 8;
+ _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16;
+ _BufferingStreamSubscription._STATE_IN_CALLBACK = 32;
+ _BufferingStreamSubscription._STATE_HAS_PENDING = 64;
+ _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128;
+ _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7;
return _BufferingStreamSubscription;
});
let _BufferingStreamSubscription = _BufferingStreamSubscription$();
@@ -1260,12 +1269,12 @@ dart_library.library('dart/async', null, /* Imports */[
[_setRemoveAfterFiring]: [dart.void, []]
})
});
+ _BroadcastSubscription._STATE_EVENT_ID = 1;
+ _BroadcastSubscription._STATE_FIRING = 2;
+ _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4;
return _BroadcastSubscription;
});
let _BroadcastSubscription = _BroadcastSubscription$();
- _BroadcastSubscription._STATE_EVENT_ID = 1;
- _BroadcastSubscription._STATE_FIRING = 2;
- _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4;
const _addStreamState = Symbol('_addStreamState');
const _doneFuture = Symbol('_doneFuture');
const _isEmpty = Symbol('_isEmpty');
@@ -1501,14 +1510,14 @@ dart_library.library('dart/async', null, /* Imports */[
[_callOnCancel]: [dart.void, []]
})
});
+ _BroadcastStreamController._STATE_INITIAL = 0;
+ _BroadcastStreamController._STATE_EVENT_ID = 1;
+ _BroadcastStreamController._STATE_FIRING = 2;
+ _BroadcastStreamController._STATE_CLOSED = 4;
+ _BroadcastStreamController._STATE_ADDSTREAM = 8;
return _BroadcastStreamController;
});
let _BroadcastStreamController = _BroadcastStreamController$();
- _BroadcastStreamController._STATE_INITIAL = 0;
- _BroadcastStreamController._STATE_EVENT_ID = 1;
- _BroadcastStreamController._STATE_FIRING = 2;
- _BroadcastStreamController._STATE_CLOSED = 4;
- _BroadcastStreamController._STATE_ADDSTREAM = 8;
const _SyncBroadcastStreamController$ = dart.generic(function(T) {
class _SyncBroadcastStreamController extends _BroadcastStreamController$(T) {
_SyncBroadcastStreamController(onListen, onCancel) {
@@ -1929,14 +1938,14 @@ dart_library.library('dart/async', null, /* Imports */[
}),
names: ['wait', 'forEach', 'doWhile']
});
+ dart.defineLazyProperties(Future, {
+ get _nullFuture() {
+ return new _Future.immediate(null);
+ }
+ });
return Future;
});
let Future = Future$();
- dart.defineLazyProperties(Future, {
- get _nullFuture() {
- return new _Future.immediate(null);
- }
- });
class TimeoutException extends core.Object {
TimeoutException(message, duration) {
if (duration === void 0) duration = null;
@@ -2148,11 +2157,23 @@ dart_library.library('dart/async', null, /* Imports */[
_FutureListener.MASK_TEST_ERROR = 4;
_FutureListener.MASK_WHENCOMPLETE = 8;
_FutureListener.STATE_CHAIN = 0;
- _FutureListener.STATE_THEN = _FutureListener.MASK_VALUE;
- _FutureListener.STATE_THEN_ONERROR = dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureListener.MASK_ERROR);
- _FutureListener.STATE_CATCHERROR = _FutureListener.MASK_ERROR;
- _FutureListener.STATE_CATCHERROR_TEST = dart.notNull(_FutureListener.MASK_ERROR) | dart.notNull(_FutureListener.MASK_TEST_ERROR);
- _FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE;
+ dart.defineLazyProperties(_FutureListener, {
+ get STATE_THEN() {
+ return _FutureListener.MASK_VALUE;
+ },
+ get STATE_THEN_ONERROR() {
+ return dart.notNull(_FutureListener.MASK_VALUE) | dart.notNull(_FutureListener.MASK_ERROR);
+ },
+ get STATE_CATCHERROR() {
+ return _FutureListener.MASK_ERROR;
+ },
+ get STATE_CATCHERROR_TEST() {
+ return dart.notNull(_FutureListener.MASK_ERROR) | dart.notNull(_FutureListener.MASK_TEST_ERROR);
+ },
+ get STATE_WHENCOMPLETE() {
+ return _FutureListener.MASK_WHENCOMPLETE;
+ }
+ });
const _resultOrListeners = Symbol('_resultOrListeners');
const _isChained = Symbol('_isChained');
const _isComplete = Symbol('_isComplete');
@@ -2608,14 +2629,14 @@ dart_library.library('dart/async', null, /* Imports */[
}),
names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners']
});
+ _Future._INCOMPLETE = 0;
+ _Future._PENDING_COMPLETE = 1;
+ _Future._CHAINED = 2;
+ _Future._VALUE = 4;
+ _Future._ERROR = 8;
return _Future;
});
let _Future = _Future$();
- _Future._INCOMPLETE = 0;
- _Future._PENDING_COMPLETE = 1;
- _Future._CHAINED = 2;
- _Future._VALUE = 4;
- _Future._ERROR = 8;
const __CastType6$ = dart.generic(function(T, S) {
const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(S, [T]));
return __CastType6;
@@ -3185,15 +3206,15 @@ dart_library.library('dart/async', null, /* Imports */[
[_recordResume]: [dart.void, [StreamSubscription$(T)]]
})
});
+ _StreamController._STATE_INITIAL = 0;
+ _StreamController._STATE_SUBSCRIBED = 1;
+ _StreamController._STATE_CANCELED = 2;
+ _StreamController._STATE_SUBSCRIPTION_MASK = 3;
+ _StreamController._STATE_CLOSED = 4;
+ _StreamController._STATE_ADDSTREAM = 8;
return _StreamController;
});
let _StreamController = _StreamController$();
- _StreamController._STATE_INITIAL = 0;
- _StreamController._STATE_SUBSCRIBED = 1;
- _StreamController._STATE_CANCELED = 2;
- _StreamController._STATE_SUBSCRIPTION_MASK = 3;
- _StreamController._STATE_CLOSED = 4;
- _StreamController._STATE_ADDSTREAM = 8;
const _SyncStreamControllerDispatch$ = dart.generic(function(T) {
class _SyncStreamControllerDispatch extends core.Object {
[_sendData](data) {
@@ -3431,15 +3452,6 @@ dart_library.library('dart/async', null, /* Imports */[
return _EventDispatch;
});
let _EventDispatch = _EventDispatch$();
- _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1;
- _BufferingStreamSubscription._STATE_CLOSED = 2;
- _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4;
- _BufferingStreamSubscription._STATE_CANCELED = 8;
- _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16;
- _BufferingStreamSubscription._STATE_IN_CALLBACK = 32;
- _BufferingStreamSubscription._STATE_HAS_PENDING = 64;
- _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128;
- _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7;
const _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionType(_PendingEvents, []));
const _isUsed = Symbol('_isUsed');
const _GeneratedStreamImpl$ = dart.generic(function(T) {
@@ -3502,6 +3514,9 @@ dart_library.library('dart/async', null, /* Imports */[
cancelSchedule: [dart.void, []]
})
});
+ _PendingEvents._STATE_UNSCHEDULED = 0;
+ _PendingEvents._STATE_SCHEDULED = 1;
+ _PendingEvents._STATE_CANCELED = 3;
const _iterator = Symbol('_iterator');
const _IterablePendingEvents$ = dart.generic(function(T) {
class _IterablePendingEvents extends _PendingEvents {
@@ -3624,9 +3639,6 @@ dart_library.library('dart/async', null, /* Imports */[
constructors: () => ({_DelayedDone: [_DelayedDone, []]}),
methods: () => ({perform: [dart.void, [_EventDispatch]]})
});
- _PendingEvents._STATE_UNSCHEDULED = 0;
- _PendingEvents._STATE_SCHEDULED = 1;
- _PendingEvents._STATE_CANCELED = 3;
class _StreamImplEvents extends _PendingEvents {
_StreamImplEvents() {
this.firstPendingEvent = null;
@@ -3770,12 +3782,12 @@ dart_library.library('dart/async', null, /* Imports */[
[_sendDone]: [dart.void, []]
})
});
+ _DoneStreamSubscription._DONE_SENT = 1;
+ _DoneStreamSubscription._SCHEDULED = 2;
+ _DoneStreamSubscription._PAUSED = 4;
return _DoneStreamSubscription;
});
let _DoneStreamSubscription = _DoneStreamSubscription$();
- _DoneStreamSubscription._DONE_SENT = 1;
- _DoneStreamSubscription._SCHEDULED = 2;
- _DoneStreamSubscription._PAUSED = 4;
const _source = Symbol('_source');
const _onListenHandler = Symbol('_onListenHandler');
const _onCancelHandler = Symbol('_onCancelHandler');
@@ -4037,15 +4049,15 @@ dart_library.library('dart/async', null, /* Imports */[
[_onDone]: [dart.void, []]
})
});
+ _StreamIteratorImpl._STATE_FOUND = 0;
+ _StreamIteratorImpl._STATE_DONE = 1;
+ _StreamIteratorImpl._STATE_MOVING = 2;
+ _StreamIteratorImpl._STATE_EXTRA_DATA = 3;
+ _StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
+ _StreamIteratorImpl._STATE_EXTRA_DONE = 5;
return _StreamIteratorImpl;
});
let _StreamIteratorImpl = _StreamIteratorImpl$();
- _StreamIteratorImpl._STATE_FOUND = 0;
- _StreamIteratorImpl._STATE_DONE = 1;
- _StreamIteratorImpl._STATE_MOVING = 2;
- _StreamIteratorImpl._STATE_EXTRA_DATA = 3;
- _StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
- _StreamIteratorImpl._STATE_EXTRA_DONE = 5;
const __CastType20$ = dart.generic(function(T) {
const __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart.void, [T]));
return __CastType20;
@@ -4530,15 +4542,15 @@ dart_library.library('dart/async', null, /* Imports */[
constructors: () => ({_DistinctStream: [_DistinctStream$(T), [Stream$(T), dart.functionType(core.bool, [T, T])]]}),
methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
});
+ dart.defineLazyProperties(_DistinctStream, {
+ get _SENTINEL() {
+ return new core.Object();
+ },
+ set _SENTINEL(_) {}
+ });
return _DistinctStream;
});
let _DistinctStream = _DistinctStream$();
- dart.defineLazyProperties(_DistinctStream, {
- get _SENTINEL() {
- return new core.Object();
- },
- set _SENTINEL(_) {}
- });
const _EventSinkWrapper$ = dart.generic(function(T) {
class _EventSinkWrapper extends core.Object {
_EventSinkWrapper(sink) {
@@ -5019,18 +5031,23 @@ dart_library.library('dart/async', null, /* Imports */[
}),
names: ['_enter', '_leave']
});
- class _Zone extends core.Object {
- _Zone() {
- }
- inSameErrorZone(otherZone) {
- return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.identical(this.errorZone, otherZone.errorZone));
- }
- }
- _Zone[dart.implements] = () => [Zone];
- dart.setSignature(_Zone, {
- constructors: () => ({_Zone: [_Zone, []]}),
- methods: () => ({inSameErrorZone: [core.bool, [Zone]]})
+ dart.defineLazyProperties(Zone, {
+ get ROOT() {
+ return _ROOT_ZONE;
+ },
+ get _current() {
+ return _ROOT_ZONE;
+ },
+ set _current(_) {}
});
+ const _delegate = Symbol('_delegate');
+ function _parentDelegate(zone) {
+ if (zone.parent == null) return null;
+ return zone.parent[_delegate];
+ }
+ dart.fn(_parentDelegate, () => dart.definiteFunctionType(ZoneDelegate, [_Zone]));
+ const _delegationTarget = Symbol('_delegationTarget');
+ const _handleUncaughtError = Symbol('_handleUncaughtError');
const _run = Symbol('_run');
const _runUnary = Symbol('_runUnary');
const _runBinary = Symbol('_runBinary');
@@ -5043,207 +5060,6 @@ dart_library.library('dart/async', null, /* Imports */[
const _createPeriodicTimer = Symbol('_createPeriodicTimer');
const _print = Symbol('_print');
const _fork = Symbol('_fork');
- const _handleUncaughtError = Symbol('_handleUncaughtError');
- const _map = Symbol('_map');
- const _delegate = Symbol('_delegate');
- class _RootZone extends _Zone {
- _RootZone() {
- super._Zone();
- }
- get [_run]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun));
- }
- get [_runUnary]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary));
- }
- get [_runBinary]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary));
- }
- get [_registerCallback]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback));
- }
- get [_registerUnaryCallback]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback));
- }
- get [_registerBinaryCallback]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallback));
- }
- get [_errorCallback]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback));
- }
- get [_scheduleMicrotask]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask));
- }
- get [_createTimer]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer));
- }
- get [_createPeriodicTimer]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer));
- }
- get [_print]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint));
- }
- get [_fork]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork));
- }
- get [_handleUncaughtError]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError));
- }
- get parent() {
- return null;
- }
- get [_map]() {
- return _RootZone._rootMap;
- }
- get [_delegate]() {
- if (_RootZone._rootDelegate != null) return _RootZone._rootDelegate;
- return _RootZone._rootDelegate = new _ZoneDelegate(this);
- }
- get errorZone() {
- return this;
- }
- runGuarded(f) {
- try {
- if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
- return f();
- }
- return _rootRun(null, null, this, f);
- } catch (e) {
- let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
- }
-
- }
- runUnaryGuarded(f, arg) {
- try {
- if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
- return dart.dcall(f, arg);
- }
- return _rootRunUnary(null, null, this, f, arg);
- } catch (e) {
- let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
- }
-
- }
- runBinaryGuarded(f, arg1, arg2) {
- try {
- if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
- return dart.dcall(f, arg1, arg2);
- }
- return _rootRunBinary(null, null, this, f, arg1, arg2);
- } catch (e) {
- let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
- }
-
- }
- bindCallback(f, opts) {
- let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- if (dart.notNull(runGuarded)) {
- return dart.fn((() => this.runGuarded(f)).bind(this));
- } else {
- return dart.fn((() => this.run(f)).bind(this));
- }
- }
- bindUnaryCallback(f, opts) {
- let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- if (dart.notNull(runGuarded)) {
- return dart.fn((arg => this.runUnaryGuarded(f, arg)).bind(this));
- } else {
- return dart.fn((arg => this.runUnary(f, arg)).bind(this));
- }
- }
- bindBinaryCallback(f, opts) {
- let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- if (dart.notNull(runGuarded)) {
- return dart.fn(((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bind(this));
- } else {
- return dart.fn(((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this));
- }
- }
- get(key) {
- return null;
- }
- handleUncaughtError(error, stackTrace) {
- return _rootHandleUncaughtError(null, null, this, error, stackTrace);
- }
- fork(opts) {
- let specification = opts && 'specification' in opts ? opts.specification : null;
- let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
- return _rootFork(null, null, this, specification, zoneValues);
- }
- run(f) {
- if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return f();
- return _rootRun(null, null, this, f);
- }
- runUnary(f, arg) {
- if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.dcall(f, arg);
- return _rootRunUnary(null, null, this, f, arg);
- }
- runBinary(f, arg1, arg2) {
- if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.dcall(f, arg1, arg2);
- return _rootRunBinary(null, null, this, f, arg1, arg2);
- }
- registerCallback(f) {
- return f;
- }
- registerUnaryCallback(f) {
- return f;
- }
- registerBinaryCallback(f) {
- return f;
- }
- errorCallback(error, stackTrace) {
- return null;
- }
- scheduleMicrotask(f) {
- _rootScheduleMicrotask(null, null, this, f);
- }
- createTimer(duration, f) {
- return Timer._createTimer(duration, f);
- }
- createPeriodicTimer(duration, f) {
- return Timer._createPeriodicTimer(duration, f);
- }
- print(line) {
- _internal.printToConsole(line);
- }
- }
- dart.setSignature(_RootZone, {
- constructors: () => ({_RootZone: [_RootZone, []]}),
- methods: () => ({
- runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
- runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]],
- runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]],
- bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {runGuarded: core.bool}],
- bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic])], {runGuarded: core.bool}],
- bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])], {runGuarded: core.bool}],
- get: [dart.dynamic, [core.Object]],
- handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]],
- fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}],
- run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
- runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]],
- runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]],
- registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]],
- registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic])]],
- registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]],
- errorCallback: [AsyncError, [core.Object, core.StackTrace]],
- scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]],
- createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
- createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]],
- print: [dart.void, [core.String]]
- })
- });
- const _ROOT_ZONE = dart.const(new _RootZone());
- Zone.ROOT = _ROOT_ZONE;
- Zone._current = _ROOT_ZONE;
- function _parentDelegate(zone) {
- if (zone.parent == null) return null;
- return zone.parent[_delegate];
- }
- dart.fn(_parentDelegate, ZoneDelegate, [_Zone]);
- const _delegationTarget = Symbol('_delegationTarget');
class _ZoneDelegate extends core.Object {
_ZoneDelegate(delegationTarget) {
this[_delegationTarget] = delegationTarget;
@@ -5334,7 +5150,20 @@ dart_library.library('dart/async', null, /* Imports */[
fork: [Zone, [Zone, ZoneSpecification, core.Map]]
})
});
+ class _Zone extends core.Object {
+ _Zone() {
+ }
+ inSameErrorZone(otherZone) {
+ return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.identical(this.errorZone, otherZone.errorZone));
+ }
+ }
+ _Zone[dart.implements] = () => [Zone];
+ dart.setSignature(_Zone, {
+ constructors: () => ({_Zone: [_Zone, []]}),
+ methods: () => ({inSameErrorZone: [core.bool, [Zone]]})
+ });
const _delegateCache = Symbol('_delegateCache');
+ const _map = Symbol('_map');
class _CustomZone extends _Zone {
get [_delegate]() {
if (this[_delegateCache] != null) return this[_delegateCache];
@@ -5695,6 +5524,195 @@ dart_library.library('dart/async', null, /* Imports */[
}
}
_RootZoneSpecification[dart.implements] = () => [ZoneSpecification];
+ class _RootZone extends _Zone {
+ _RootZone() {
+ super._Zone();
+ }
+ get [_run]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun));
+ }
+ get [_runUnary]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary));
+ }
+ get [_runBinary]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary));
+ }
+ get [_registerCallback]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback));
+ }
+ get [_registerUnaryCallback]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback));
+ }
+ get [_registerBinaryCallback]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallback));
+ }
+ get [_errorCallback]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback));
+ }
+ get [_scheduleMicrotask]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask));
+ }
+ get [_createTimer]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer));
+ }
+ get [_createPeriodicTimer]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer));
+ }
+ get [_print]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint));
+ }
+ get [_fork]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork));
+ }
+ get [_handleUncaughtError]() {
+ return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError));
+ }
+ get parent() {
+ return null;
+ }
+ get [_map]() {
+ return _RootZone._rootMap;
+ }
+ get [_delegate]() {
+ if (_RootZone._rootDelegate != null) return _RootZone._rootDelegate;
+ return _RootZone._rootDelegate = new _ZoneDelegate(this);
+ }
+ get errorZone() {
+ return this;
+ }
+ runGuarded(f) {
+ try {
+ if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
+ return f();
+ }
+ return _rootRun(null, null, this, f);
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ return this.handleUncaughtError(e, s);
+ }
+
+ }
+ runUnaryGuarded(f, arg) {
+ try {
+ if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
+ return dart.dcall(f, arg);
+ }
+ return _rootRunUnary(null, null, this, f, arg);
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ return this.handleUncaughtError(e, s);
+ }
+
+ }
+ runBinaryGuarded(f, arg1, arg2) {
+ try {
+ if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
+ return dart.dcall(f, arg1, arg2);
+ }
+ return _rootRunBinary(null, null, this, f, arg1, arg2);
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ return this.handleUncaughtError(e, s);
+ }
+
+ }
+ bindCallback(f, opts) {
+ let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
+ if (dart.notNull(runGuarded)) {
+ return dart.fn((() => this.runGuarded(f)).bind(this));
+ } else {
+ return dart.fn((() => this.run(f)).bind(this));
+ }
+ }
+ bindUnaryCallback(f, opts) {
+ let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
+ if (dart.notNull(runGuarded)) {
+ return dart.fn((arg => this.runUnaryGuarded(f, arg)).bind(this));
+ } else {
+ return dart.fn((arg => this.runUnary(f, arg)).bind(this));
+ }
+ }
+ bindBinaryCallback(f, opts) {
+ let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
+ if (dart.notNull(runGuarded)) {
+ return dart.fn(((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bind(this));
+ } else {
+ return dart.fn(((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this));
+ }
+ }
+ get(key) {
+ return null;
+ }
+ handleUncaughtError(error, stackTrace) {
+ return _rootHandleUncaughtError(null, null, this, error, stackTrace);
+ }
+ fork(opts) {
+ let specification = opts && 'specification' in opts ? opts.specification : null;
+ let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
+ return _rootFork(null, null, this, specification, zoneValues);
+ }
+ run(f) {
+ if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return f();
+ return _rootRun(null, null, this, f);
+ }
+ runUnary(f, arg) {
+ if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.dcall(f, arg);
+ return _rootRunUnary(null, null, this, f, arg);
+ }
+ runBinary(f, arg1, arg2) {
+ if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE))) return dart.dcall(f, arg1, arg2);
+ return _rootRunBinary(null, null, this, f, arg1, arg2);
+ }
+ registerCallback(f) {
+ return f;
+ }
+ registerUnaryCallback(f) {
+ return f;
+ }
+ registerBinaryCallback(f) {
+ return f;
+ }
+ errorCallback(error, stackTrace) {
+ return null;
+ }
+ scheduleMicrotask(f) {
+ _rootScheduleMicrotask(null, null, this, f);
+ }
+ createTimer(duration, f) {
+ return Timer._createTimer(duration, f);
+ }
+ createPeriodicTimer(duration, f) {
+ return Timer._createPeriodicTimer(duration, f);
+ }
+ print(line) {
+ _internal.printToConsole(line);
+ }
+ }
+ dart.setSignature(_RootZone, {
+ constructors: () => ({_RootZone: [_RootZone, []]}),
+ methods: () => ({
+ runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
+ runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]],
+ runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]],
+ bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {runGuarded: core.bool}],
+ bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic])], {runGuarded: core.bool}],
+ bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])], {runGuarded: core.bool}],
+ get: [dart.dynamic, [core.Object]],
+ handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]],
+ fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}],
+ run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
+ runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]],
+ runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]],
+ registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]],
+ registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic])]],
+ registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]],
+ errorCallback: [AsyncError, [core.Object, core.StackTrace]],
+ scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]],
+ createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
+ createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]],
+ print: [dart.void, [core.String]]
+ })
+ });
_RootZone._rootDelegate = null;
dart.defineLazyProperties(_RootZone, {
get _rootMap() {
@@ -5702,6 +5720,7 @@ dart_library.library('dart/async', null, /* Imports */[
},
set _rootMap(_) {}
});
+ const _ROOT_ZONE = dart.const(new _RootZone());
function runZoned(body, opts) {
let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
let zoneSpecification = opts && 'zoneSpecification' in opts ? opts.zoneSpecification : null;
« 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