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

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: lib/runtime/dart/async.js

Issue 1111863002: fix static members in _emitMemberName (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: catch more cases Created 5 years, 8 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/_native_typed_data.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 593138eea21c011ec31b786e184cb44f6d15e54f..87d303157805445ad94a48adbc8fb590f11eb585 100644
--- a/lib/runtime/dart/async.js
+++ b/lib/runtime/dart/async.js
@@ -17,7 +17,6 @@ var async;
return zone.registerUnaryCallback(dart.as(errorHandler, __CastType0));
}
}
- let _getBestStackTrace = Symbol('_getBestStackTrace');
class AsyncError extends core.Object {
AsyncError(error, stackTrace) {
this.error = error;
@@ -30,9 +29,9 @@ var async;
AsyncError[dart.implements] = () => [core.Error];
class _UncaughtAsyncError extends AsyncError {
_UncaughtAsyncError(error, stackTrace) {
- super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, stackTrace));
+ super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stackTrace));
}
- static [_getBestStackTrace](error, stackTrace) {
+ static _getBestStackTrace(error, stackTrace) {
if (stackTrace != null)
return stackTrace;
if (dart.is(error, core.Error)) {
@@ -837,12 +836,9 @@ var async;
}
let _eventState = Symbol('_eventState');
let _expectsEvent = Symbol('_expectsEvent');
- let _STATE_EVENT_ID = Symbol('_STATE_EVENT_ID');
let _toggleEventId = Symbol('_toggleEventId');
let _isFiring = Symbol('_isFiring');
- let _STATE_FIRING = Symbol('_STATE_FIRING');
let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring');
- let _STATE_REMOVE_AFTER_FIRING = Symbol('_STATE_REMOVE_AFTER_FIRING');
let _removeAfterFiring = Symbol('_removeAfterFiring');
let _onPause = Symbol('_onPause');
let _onResume = Symbol('_onResume');
@@ -850,7 +846,6 @@ var async;
let _recordCancel = Symbol('_recordCancel');
let _recordPause = Symbol('_recordPause');
let _recordResume = Symbol('_recordResume');
- let _STATE_CANCEL_ON_ERROR = Symbol('_STATE_CANCEL_ON_ERROR');
let _zone = Symbol('_zone');
let _state = Symbol('_state');
let _onData = Symbol('_onData');
@@ -859,25 +854,18 @@ var async;
let _cancelFuture = Symbol('_cancelFuture');
let _pending = Symbol('_pending');
let _setPendingEvents = Symbol('_setPendingEvents');
- let _STATE_HAS_PENDING = Symbol('_STATE_HAS_PENDING');
let _extractPending = Symbol('_extractPending');
let _isCanceled = Symbol('_isCanceled');
let _isPaused = Symbol('_isPaused');
let _isInputPaused = Symbol('_isInputPaused');
- let _STATE_PAUSE_COUNT = Symbol('_STATE_PAUSE_COUNT');
- let _STATE_INPUT_PAUSED = Symbol('_STATE_INPUT_PAUSED');
let _inCallback = Symbol('_inCallback');
let _guardCallback = Symbol('_guardCallback');
let _decrementPauseCount = Symbol('_decrementPauseCount');
let _hasPending = Symbol('_hasPending');
let _mayResumeInput = Symbol('_mayResumeInput');
- let _STATE_WAIT_FOR_CANCEL = Symbol('_STATE_WAIT_FOR_CANCEL');
let _cancel = Symbol('_cancel');
let _isClosed = Symbol('_isClosed');
- let _STATE_CLOSED = Symbol('_STATE_CLOSED');
- let _STATE_CANCELED = Symbol('_STATE_CANCELED');
let _waitsForCancel = Symbol('_waitsForCancel');
- let _STATE_IN_CALLBACK = Symbol('_STATE_IN_CALLBACK');
let _canFire = Symbol('_canFire');
let _cancelOnError = Symbol('_cancelOnError');
let _incrementPauseCount = Symbol('_incrementPauseCount');
@@ -891,7 +879,7 @@ var async;
class _BufferingStreamSubscription extends core.Object {
_BufferingStreamSubscription(onData, onError, onDone, cancelOnError) {
this[_zone] = Zone.current;
- this[_state] = cancelOnError ? _BufferingStreamSubscription[_STATE_CANCEL_ON_ERROR] : 0;
+ this[_state] = cancelOnError ? _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR : 0;
this[_onData] = null;
this[_onError] = null;
this[_onDone] = null;
@@ -907,7 +895,7 @@ var async;
return;
this[_pending] = pendingEvents;
if (!dart.notNull(pendingEvents.isEmpty)) {
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_HAS_PENDING]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_HAS_PENDING);
this[_pending].schedule(this);
}
}
@@ -939,7 +927,7 @@ var async;
return;
let wasPaused = this[_isPaused];
let wasInputPaused = this[_isInputPaused];
- this[_state] = dart.notNull(this[_state]) + dart.notNull(_BufferingStreamSubscription[_STATE_PAUSE_COUNT]) | dart.notNull(_BufferingStreamSubscription[_STATE_INPUT_PAUSED]);
+ this[_state] = dart.notNull(this[_state]) + dart.notNull(_BufferingStreamSubscription._STATE_PAUSE_COUNT) | dart.notNull(_BufferingStreamSubscription._STATE_INPUT_PAUSED);
if (resumeSignal != null)
resumeSignal.whenComplete(this.resume.bind(this));
if (!dart.notNull(wasPaused) && dart.notNull(this[_pending] != null))
@@ -957,7 +945,7 @@ var async;
this[_pending].schedule(this);
} else {
dart.assert(this[_mayResumeInput]);
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_INPUT_PAUSED]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_INPUT_PAUSED);
if (!dart.notNull(this[_inCallback]))
this[_guardCallback](this[_onResume].bind(this));
}
@@ -965,7 +953,7 @@ var async;
}
}
cancel() {
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_WAIT_FOR_CANCEL]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL);
if (this[_isCanceled])
return this[_cancelFuture];
this[_cancel]();
@@ -985,40 +973,40 @@ var async;
return result;
}
get [_isInputPaused]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription[_STATE_INPUT_PAUSED])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription._STATE_INPUT_PAUSED)) != 0;
}
get [_isClosed]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription[_STATE_CLOSED])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription._STATE_CLOSED)) != 0;
}
get [_isCanceled]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription[_STATE_CANCELED])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription._STATE_CANCELED)) != 0;
}
get [_waitsForCancel]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription[_STATE_WAIT_FOR_CANCEL])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL)) != 0;
}
get [_inCallback]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK)) != 0;
}
get [_hasPending]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription[_STATE_HAS_PENDING])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription._STATE_HAS_PENDING)) != 0;
}
get [_isPaused]() {
- return dart.notNull(this[_state]) >= dart.notNull(_BufferingStreamSubscription[_STATE_PAUSE_COUNT]);
+ return dart.notNull(this[_state]) >= dart.notNull(_BufferingStreamSubscription._STATE_PAUSE_COUNT);
}
get [_canFire]() {
- return dart.notNull(this[_state]) < dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ return dart.notNull(this[_state]) < dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
}
get [_mayResumeInput]() {
return !dart.notNull(this[_isPaused]) && (dart.notNull(this[_pending] == null) || dart.notNull(this[_pending].isEmpty));
}
get [_cancelOnError]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription[_STATE_CANCEL_ON_ERROR])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription._STATE_CANCEL_ON_ERROR)) != 0;
}
get isPaused() {
return this[_isPaused];
}
[_cancel]() {
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_CANCELED]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_CANCELED);
if (this[_hasPending]) {
this[_pending].cancelSchedule();
}
@@ -1027,11 +1015,11 @@ var async;
this[_cancelFuture] = this[_onCancel]();
}
[_incrementPauseCount]() {
- this[_state] = dart.notNull(this[_state]) + dart.notNull(_BufferingStreamSubscription[_STATE_PAUSE_COUNT]) | dart.notNull(_BufferingStreamSubscription[_STATE_INPUT_PAUSED]);
+ this[_state] = dart.notNull(this[_state]) + dart.notNull(_BufferingStreamSubscription._STATE_PAUSE_COUNT) | dart.notNull(_BufferingStreamSubscription._STATE_INPUT_PAUSED);
}
[_decrementPauseCount]() {
dart.assert(this[_isPaused]);
- this[_state] = dart.notNull(this[_state]) - dart.notNull(_BufferingStreamSubscription[_STATE_PAUSE_COUNT]);
+ this[_state] = dart.notNull(this[_state]) - dart.notNull(_BufferingStreamSubscription._STATE_PAUSE_COUNT);
}
[_add](data) {
dart.assert(!dart.notNull(this[_isClosed]));
@@ -1056,7 +1044,7 @@ var async;
dart.assert(!dart.notNull(this[_isClosed]));
if (this[_isCanceled])
return;
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_CLOSED]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_CLOSED);
if (this[_canFire]) {
this[_sendDone]();
} else {
@@ -1079,7 +1067,7 @@ var async;
pending = this[_pending] = new _StreamImplEvents();
pending.add(event);
if (!dart.notNull(this[_hasPending])) {
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_HAS_PENDING]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_HAS_PENDING);
if (!dart.notNull(this[_isPaused])) {
this[_pending].schedule(this);
}
@@ -1090,9 +1078,9 @@ var async;
dart.assert(!dart.notNull(this[_isPaused]));
dart.assert(!dart.notNull(this[_inCallback]));
let wasInputPaused = this[_isInputPaused];
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
this[_zone].runUnaryGuarded(this[_onData], data);
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
this[_checkState](wasInputPaused);
}
[_sendError](error, stackTrace) {
@@ -1104,16 +1092,16 @@ var async;
function sendError() {
if (dart.notNull(this[_isCanceled]) && !dart.notNull(this[_waitsForCancel]))
return;
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
if (dart.is(this[_onError], ZoneBinaryCallback)) {
this[_zone].runBinaryGuarded(dart.as(this[_onError], __CastType24), error, stackTrace);
} else {
this[_zone].runUnaryGuarded(dart.as(this[_onError], __CastType27), error);
}
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
}
if (this[_cancelOnError]) {
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_WAIT_FOR_CANCEL]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL);
this[_cancel]();
if (dart.is(this[_cancelFuture], Future)) {
this[_cancelFuture].whenComplete(sendError);
@@ -1133,12 +1121,12 @@ var async;
function sendDone() {
if (!dart.notNull(this[_waitsForCancel]))
return;
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_CANCELED]) | dart.notNull(_BufferingStreamSubscription[_STATE_CLOSED]) | dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_CANCELED) | dart.notNull(_BufferingStreamSubscription._STATE_CLOSED) | dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
this[_zone].runGuarded(this[_onDone]);
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
}
this[_cancel]();
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_WAIT_FOR_CANCEL]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL);
if (dart.is(this[_cancelFuture], Future)) {
this[_cancelFuture].whenComplete(sendDone);
} else {
@@ -1148,17 +1136,17 @@ var async;
[_guardCallback](callback) {
dart.assert(!dart.notNull(this[_inCallback]));
let wasInputPaused = this[_isInputPaused];
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
dart.dcall(callback);
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
this[_checkState](wasInputPaused);
}
[_checkState](wasInputPaused) {
dart.assert(!dart.notNull(this[_inCallback]));
if (dart.notNull(this[_hasPending]) && dart.notNull(this[_pending].isEmpty)) {
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_HAS_PENDING]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_HAS_PENDING);
if (dart.notNull(this[_isInputPaused]) && dart.notNull(this[_mayResumeInput])) {
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_INPUT_PAUSED]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_INPUT_PAUSED);
}
}
while (true) {
@@ -1169,13 +1157,13 @@ var async;
let isInputPaused = this[_isInputPaused];
if (wasInputPaused == isInputPaused)
break;
- this[_state] = dart.notNull(this[_state]) ^ dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) ^ dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
if (isInputPaused) {
this[_onPause]();
} else {
this[_onResume]();
}
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CALLBACK]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription._STATE_IN_CALLBACK);
wasInputPaused = isInputPaused;
}
if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) {
@@ -1228,20 +1216,20 @@ var async;
return dart.as(super[_controller], _BroadcastStreamController);
}
[_expectsEvent](eventId) {
- return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscription[_STATE_EVENT_ID])) == eventId;
+ return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscription._STATE_EVENT_ID)) == eventId;
}
[_toggleEventId]() {
- this[_eventState] = dart.notNull(this[_eventState]) ^ dart.notNull(_BroadcastSubscription[_STATE_EVENT_ID]);
+ this[_eventState] = dart.notNull(this[_eventState]) ^ dart.notNull(_BroadcastSubscription._STATE_EVENT_ID);
}
get [_isFiring]() {
- return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscription[_STATE_FIRING])) != 0;
+ return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscription._STATE_FIRING)) != 0;
}
[_setRemoveAfterFiring]() {
dart.assert(this[_isFiring]);
- this[_eventState] = dart.notNull(this[_eventState]) | dart.notNull(_BroadcastSubscription[_STATE_REMOVE_AFTER_FIRING]);
+ this[_eventState] = dart.notNull(this[_eventState]) | dart.notNull(_BroadcastSubscription._STATE_REMOVE_AFTER_FIRING);
}
get [_removeAfterFiring]() {
- return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscription[_STATE_REMOVE_AFTER_FIRING])) != 0;
+ return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscription._STATE_REMOVE_AFTER_FIRING)) != 0;
}
[_onPause]() {}
[_onResume]() {}
@@ -1253,13 +1241,11 @@ var async;
return _BroadcastSubscription;
});
let _BroadcastSubscription = _BroadcastSubscription$();
- let _STATE_INITIAL = Symbol('_STATE_INITIAL');
let _addStreamState = Symbol('_addStreamState');
let _doneFuture = Symbol('_doneFuture');
let _isEmpty = Symbol('_isEmpty');
let _hasOneListener = Symbol('_hasOneListener');
let _isAddingStream = Symbol('_isAddingStream');
- let _STATE_ADDSTREAM = Symbol('_STATE_ADDSTREAM');
let _mayAddEvent = Symbol('_mayAddEvent');
let _ensureDoneFuture = Symbol('_ensureDoneFuture');
let _addListener = Symbol('_addListener');
@@ -1274,7 +1260,7 @@ var async;
_BroadcastStreamController(onListen, onCancel) {
this[_onListen] = onListen;
this[_onCancel] = onCancel;
- this[_state] = _BroadcastStreamController[_STATE_INITIAL];
+ this[_state] = _BroadcastStreamController._STATE_INITIAL;
this[_next] = null;
this[_previous] = null;
this[_addStreamState] = null;
@@ -1288,7 +1274,7 @@ var async;
return new (_StreamSinkWrapper$(T))(this);
}
get isClosed() {
- return (dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController[_STATE_CLOSED])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController._STATE_CLOSED)) != 0;
}
get isPaused() {
return false;
@@ -1301,13 +1287,13 @@ var async;
return core.identical(this[_next][_next], this);
}
get [_isFiring]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController[_STATE_FIRING])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController._STATE_FIRING)) != 0;
}
get [_isAddingStream]() {
- return (dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController[_STATE_ADDSTREAM])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController._STATE_ADDSTREAM)) != 0;
}
get [_mayAddEvent]() {
- return dart.notNull(this[_state]) < dart.notNull(_BroadcastStreamController[_STATE_CLOSED]);
+ return dart.notNull(this[_state]) < dart.notNull(_BroadcastStreamController._STATE_CLOSED);
}
[_ensureDoneFuture]() {
if (this[_doneFuture] != null)
@@ -1323,7 +1309,7 @@ var async;
subscription[_next] = this;
this[_previous][_next] = subscription;
this[_previous] = subscription;
- subscription[_eventState] = dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController[_STATE_EVENT_ID]);
+ subscription[_eventState] = dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController._STATE_EVENT_ID);
}
[_removeListener](subscription) {
dart.assert(core.identical(subscription[_controller], this));
@@ -1396,7 +1382,7 @@ var async;
}
if (!dart.notNull(this[_mayAddEvent]))
throw this[_addEventError]();
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController[_STATE_CLOSED]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController._STATE_CLOSED);
let doneFuture = this[_ensureDoneFuture]();
this[_sendDone]();
return doneFuture;
@@ -1408,7 +1394,7 @@ var async;
let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
if (!dart.notNull(this[_mayAddEvent]))
throw this[_addEventError]();
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController[_STATE_ADDSTREAM]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController._STATE_ADDSTREAM);
this[_addStreamState] = new (_AddStreamState$(T))(this, stream, cancelOnError);
return this[_addStreamState].addStreamFuture;
}
@@ -1422,7 +1408,7 @@ var async;
dart.assert(this[_isAddingStream]);
let addState = this[_addStreamState];
this[_addStreamState] = null;
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController[_STATE_ADDSTREAM]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController._STATE_ADDSTREAM);
addState.complete();
}
[_forEachListener](action) {
@@ -1431,25 +1417,25 @@ var async;
}
if (this[_isEmpty])
return;
- let id = dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController[_STATE_EVENT_ID]);
- this[_state] = dart.notNull(this[_state]) ^ (dart.notNull(_BroadcastStreamController[_STATE_EVENT_ID]) | dart.notNull(_BroadcastStreamController[_STATE_FIRING]));
+ let id = dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController._STATE_EVENT_ID);
+ this[_state] = dart.notNull(this[_state]) ^ (dart.notNull(_BroadcastStreamController._STATE_EVENT_ID) | dart.notNull(_BroadcastStreamController._STATE_FIRING));
let link = this[_next];
while (!dart.notNull(core.identical(link, this))) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
if (subscription[_expectsEvent](id)) {
- subscription[_eventState] = dart.notNull(subscription[_eventState]) | dart.notNull(_BroadcastSubscription[_STATE_FIRING]);
+ subscription[_eventState] = dart.notNull(subscription[_eventState]) | dart.notNull(_BroadcastSubscription._STATE_FIRING);
action(subscription);
subscription[_toggleEventId]();
link = subscription[_next];
if (subscription[_removeAfterFiring]) {
this[_removeListener](subscription);
}
- subscription[_eventState] = dart.notNull(subscription[_eventState]) & ~dart.notNull(_BroadcastSubscription[_STATE_FIRING]);
+ subscription[_eventState] = dart.notNull(subscription[_eventState]) & ~dart.notNull(_BroadcastSubscription._STATE_FIRING);
} else {
link = subscription[_next];
}
}
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController[_STATE_FIRING]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController._STATE_FIRING);
if (this[_isEmpty]) {
this[_callOnCancel]();
}
@@ -1480,10 +1466,10 @@ var async;
if (this[_isEmpty])
return;
if (this[_hasOneListener]) {
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController[_STATE_FIRING]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController._STATE_FIRING);
let subscription = dart.as(this[_next], _BroadcastSubscription);
subscription[_add](data);
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController[_STATE_FIRING]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController._STATE_FIRING);
if (this[_isEmpty]) {
this[_callOnCancel]();
}
@@ -1591,7 +1577,7 @@ var async;
close() {
if (!dart.notNull(this.isClosed) && dart.notNull(this[_isFiring])) {
this[_addPendingEvent](dart.const(new _DelayedDone()));
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController[_STATE_CLOSED]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController._STATE_CLOSED);
return super.done;
}
let result = super.close();
@@ -1677,7 +1663,6 @@ var async;
}
DeferredLoadException[dart.implements] = () => [core.Exception];
let _completeWithValue = Symbol('_completeWithValue');
- let _nullFuture = Symbol('_nullFuture');
let Future$ = dart.generic(function(T) {
class Future extends core.Object {
Future(computation) {
@@ -1837,7 +1822,7 @@ var async;
dart.defineNamedConstructor(Future, 'error');
dart.defineNamedConstructor(Future, 'delayed');
dart.defineLazyProperties(Future, {
- get [_nullFuture]() {
+ get _nullFuture() {
return new Future.value(null);
}
});
@@ -2032,38 +2017,28 @@ var async;
_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;
- let _INCOMPLETE = Symbol('_INCOMPLETE');
let _resultOrListeners = Symbol('_resultOrListeners');
let _isChained = Symbol('_isChained');
- let _CHAINED = Symbol('_CHAINED');
let _isComplete = Symbol('_isComplete');
- let _VALUE = Symbol('_VALUE');
let _hasValue = Symbol('_hasValue');
let _hasError = Symbol('_hasError');
- let _ERROR = Symbol('_ERROR');
let _markPendingCompletion = Symbol('_markPendingCompletion');
- let _PENDING_COMPLETE = Symbol('_PENDING_COMPLETE');
let _value = Symbol('_value');
let _error = Symbol('_error');
let _setValue = Symbol('_setValue');
let _setErrorObject = Symbol('_setErrorObject');
let _setError = Symbol('_setError');
- let _propagateToListeners = Symbol('_propagateToListeners');
let _removeListeners = Symbol('_removeListeners');
- let _chainForeignFuture = Symbol('_chainForeignFuture');
- let _chainCoreFuture = Symbol('_chainCoreFuture');
- let _enter = Symbol('_enter');
- let _leave = Symbol('_leave');
let _Future$ = dart.generic(function(T) {
class _Future extends core.Object {
_Future() {
this[_zone] = Zone.current;
- this[_state] = _Future[_INCOMPLETE];
+ this[_state] = _Future._INCOMPLETE;
this[_resultOrListeners] = null;
}
immediate(value) {
this[_zone] = Zone.current;
- this[_state] = _Future[_INCOMPLETE];
+ this[_state] = _Future._INCOMPLETE;
this[_resultOrListeners] = null;
this[_asyncComplete](value);
}
@@ -2071,32 +2046,32 @@ var async;
if (stackTrace === void 0)
stackTrace = null;
this[_zone] = Zone.current;
- this[_state] = _Future[_INCOMPLETE];
+ this[_state] = _Future._INCOMPLETE;
this[_resultOrListeners] = null;
this[_asyncCompleteError](error, stackTrace);
}
get [_mayComplete]() {
- return this[_state] == _Future[_INCOMPLETE];
+ return this[_state] == _Future._INCOMPLETE;
}
get [_isChained]() {
- return this[_state] == _Future[_CHAINED];
+ return this[_state] == _Future._CHAINED;
}
get [_isComplete]() {
- return dart.notNull(this[_state]) >= dart.notNull(_Future[_VALUE]);
+ return dart.notNull(this[_state]) >= dart.notNull(_Future._VALUE);
}
get [_hasValue]() {
- return this[_state] == _Future[_VALUE];
+ return this[_state] == _Future._VALUE;
}
get [_hasError]() {
- return this[_state] == _Future[_ERROR];
+ return this[_state] == _Future._ERROR;
}
set [_isChained](value) {
if (value) {
dart.assert(!dart.notNull(this[_isComplete]));
- this[_state] = _Future[_CHAINED];
+ this[_state] = _Future._CHAINED;
} else {
dart.assert(this[_isChained]);
- this[_state] = _Future[_INCOMPLETE];
+ this[_state] = _Future._INCOMPLETE;
}
}
then(f, opts) {
@@ -2136,7 +2111,7 @@ var async;
[_markPendingCompletion]() {
if (!dart.notNull(this[_mayComplete]))
throw new core.StateError("Future already completed");
- this[_state] = _Future[_PENDING_COMPLETE];
+ this[_state] = _Future._PENDING_COMPLETE;
}
get [_value]() {
dart.assert(dart.notNull(this[_isComplete]) && dart.notNull(this[_hasValue]));
@@ -2148,12 +2123,12 @@ var async;
}
[_setValue](value) {
dart.assert(!dart.notNull(this[_isComplete]));
- this[_state] = _Future[_VALUE];
+ this[_state] = _Future._VALUE;
this[_resultOrListeners] = value;
}
[_setErrorObject](error) {
dart.assert(!dart.notNull(this[_isComplete]));
- this[_state] = _Future[_ERROR];
+ this[_state] = _Future._ERROR;
this[_resultOrListeners] = error;
}
[_setError](error, stackTrace) {
@@ -2163,7 +2138,7 @@ var async;
dart.assert(listener[_nextListener] == null);
if (this[_isComplete]) {
this[_zone].scheduleMicrotask((() => {
- _Future[_propagateToListeners](this, listener);
+ _Future._propagateToListeners(this, listener);
}).bind(this));
} else {
listener[_nextListener] = dart.as(this[_resultOrListeners], _FutureListener);
@@ -2183,7 +2158,7 @@ var async;
}
return prev;
}
- static [_chainForeignFuture](source, target) {
+ static _chainForeignFuture(source, target) {
dart.assert(!dart.notNull(target[_isComplete]));
dart.assert(!dart.is(source, _Future));
target[_isChained] = true;
@@ -2199,13 +2174,13 @@ var async;
}
});
}
- static [_chainCoreFuture](source, target) {
+ static _chainCoreFuture(source, target) {
dart.assert(!dart.notNull(target[_isComplete]));
dart.assert(dart.is(source, _Future));
target[_isChained] = true;
let listener = new _FutureListener.chain(target);
if (source[_isComplete]) {
- _Future[_propagateToListeners](source, listener);
+ _Future._propagateToListeners(source, listener);
} else {
source[_addListener](listener);
}
@@ -2214,14 +2189,14 @@ var async;
dart.assert(!dart.notNull(this[_isComplete]));
if (dart.is(value, Future)) {
if (dart.is(value, _Future)) {
- _Future[_chainCoreFuture](dart.as(value, _Future), this);
+ _Future._chainCoreFuture(dart.as(value, _Future), this);
} else {
- _Future[_chainForeignFuture](dart.as(value, Future), this);
+ _Future._chainForeignFuture(dart.as(value, Future), this);
}
} else {
let listeners = this[_removeListeners]();
this[_setValue](dart.as(value, T));
- _Future[_propagateToListeners](this, listeners);
+ _Future._propagateToListeners(this, listeners);
}
}
[_completeWithValue](value) {
@@ -2229,7 +2204,7 @@ var async;
dart.assert(!dart.is(value, Future));
let listeners = this[_removeListeners]();
this[_setValue](dart.as(value, T));
- _Future[_propagateToListeners](this, listeners);
+ _Future._propagateToListeners(this, listeners);
}
[_completeError](error, stackTrace) {
if (stackTrace === void 0)
@@ -2237,7 +2212,7 @@ var async;
dart.assert(!dart.notNull(this[_isComplete]));
let listeners = this[_removeListeners]();
this[_setError](error, stackTrace);
- _Future[_propagateToListeners](this, listeners);
+ _Future._propagateToListeners(this, listeners);
}
[_asyncComplete](value) {
dart.assert(!dart.notNull(this[_isComplete]));
@@ -2249,13 +2224,13 @@ var async;
if (dart.notNull(coreFuture[_isComplete]) && dart.notNull(coreFuture[_hasError])) {
this[_markPendingCompletion]();
this[_zone].scheduleMicrotask((() => {
- _Future[_chainCoreFuture](coreFuture, this);
+ _Future._chainCoreFuture(coreFuture, this);
}).bind(this));
} else {
- _Future[_chainCoreFuture](coreFuture, this);
+ _Future._chainCoreFuture(coreFuture, this);
}
} else {
- _Future[_chainForeignFuture](typedFuture, this);
+ _Future._chainForeignFuture(typedFuture, this);
}
return;
} else {
@@ -2273,7 +2248,7 @@ var async;
this[_completeError](error, stackTrace);
}).bind(this));
}
- static [_propagateToListeners](source, listeners) {
+ static _propagateToListeners(source, listeners) {
while (true) {
dart.assert(source[_isComplete]);
let hasError = source[_hasError];
@@ -2288,7 +2263,7 @@ var async;
let listener = listeners;
listeners = listener[_nextListener];
listener[_nextListener] = null;
- _Future[_propagateToListeners](source, listener);
+ _Future._propagateToListeners(source, listener);
}
let listener = listeners;
let listenerHasValue = true;
@@ -2304,7 +2279,7 @@ var async;
}
let oldZone = null;
if (!dart.notNull(core.identical(Zone.current, zone))) {
- oldZone = Zone[_enter](zone);
+ oldZone = Zone._enter(zone);
}
// Function handleValueCallback: () → bool
function handleValueCallback() {
@@ -2376,7 +2351,7 @@ var async;
result[_isChained] = true;
isPropagationAborted = true;
dart.dsend(completeResult, 'then', ignored => {
- _Future[_propagateToListeners](source, new _FutureListener.chain(result));
+ _Future._propagateToListeners(source, new _FutureListener.chain(result));
}, {
onError: (error, stackTrace) => {
if (stackTrace === void 0)
@@ -2385,7 +2360,7 @@ var async;
completeResult = new _Future();
dart.dsend(completeResult, _setError, error, stackTrace);
}
- _Future[_propagateToListeners](dart.as(completeResult, _Future), new _FutureListener.chain(result));
+ _Future._propagateToListeners(dart.as(completeResult, _Future), new _FutureListener.chain(result));
}
});
}
@@ -2401,7 +2376,7 @@ var async;
handleWhenCompleteCallback();
}
if (oldZone != null)
- Zone[_leave](oldZone);
+ Zone._leave(oldZone);
if (isPropagationAborted)
return;
if (dart.notNull(listenerHasValue) && !dart.notNull(core.identical(sourceValue, listenerValueOrError)) && dart.is(listenerValueOrError, Future)) {
@@ -2414,10 +2389,10 @@ var async;
listeners = new _FutureListener.chain(result);
continue;
} else {
- _Future[_chainCoreFuture](chainSource, result);
+ _Future._chainCoreFuture(chainSource, result);
}
} else {
- _Future[_chainForeignFuture](chainSource, result);
+ _Future._chainForeignFuture(chainSource, result);
}
return;
}
@@ -2512,7 +2487,6 @@ var async;
entry.callback();
}
}
- let _scheduleImmediate = Symbol('_scheduleImmediate');
// Function _asyncRunCallback: () → void
function _asyncRunCallback() {
exports._isInCallbackLoop = true;
@@ -2522,7 +2496,7 @@ var async;
exports._lastPriorityCallback = null;
exports._isInCallbackLoop = false;
if (exports._nextCallback != null)
- _AsyncRun[_scheduleImmediate](_asyncRunCallback);
+ _AsyncRun._scheduleImmediate(_asyncRunCallback);
}
}
// Function _scheduleAsyncCallback: (dynamic) → void
@@ -2530,7 +2504,7 @@ var async;
if (exports._nextCallback == null) {
exports._nextCallback = exports._lastCallback = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback));
if (!dart.notNull(exports._isInCallbackLoop)) {
- _AsyncRun[_scheduleImmediate](_asyncRunCallback);
+ _AsyncRun._scheduleImmediate(_asyncRunCallback);
}
} else {
let newEntry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback));
@@ -2564,19 +2538,14 @@ var async;
}
Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuarded: true}));
}
- let _initializeScheduleImmediate = Symbol('_initializeScheduleImmediate');
- let _scheduleImmediateJsOverride = Symbol('_scheduleImmediateJsOverride');
- let _scheduleImmediateWithSetImmediate = Symbol('_scheduleImmediateWithSetImmediate');
- let _scheduleImmediateWithTimer = Symbol('_scheduleImmediateWithTimer');
- let _createTimer = Symbol('_createTimer');
class _AsyncRun extends core.Object {
- static [_scheduleImmediate](callback) {
+ static _scheduleImmediate(callback) {
dart.dcall(_AsyncRun.scheduleImmediateClosure, callback);
}
- static [_initializeScheduleImmediate]() {
+ static _initializeScheduleImmediate() {
_js_helper.requiresPreamble();
if (self.scheduleImmediate != null) {
- return _AsyncRun[_scheduleImmediateJsOverride];
+ return _AsyncRun._scheduleImmediateJsOverride;
}
if (dart.notNull(self.MutationObserver != null) && dart.notNull(self.document != null)) {
let div = self.document.createElement("div");
@@ -2599,11 +2568,11 @@ var async;
div.firstChild ? div.removeChild(span) : div.appendChild(span);
};
} else if (self.setImmediate != null) {
- return _AsyncRun[_scheduleImmediateWithSetImmediate];
+ return _AsyncRun._scheduleImmediateWithSetImmediate;
}
- return _AsyncRun[_scheduleImmediateWithTimer];
+ return _AsyncRun._scheduleImmediateWithTimer;
}
- static [_scheduleImmediateJsOverride](callback) {
+ static _scheduleImmediateJsOverride(callback) {
// Function internalCallback: () → dynamic
function internalCallback() {
_isolate_helper.leaveJsAsync();
@@ -2613,7 +2582,7 @@ var async;
_isolate_helper.enterJsAsync();
self.scheduleImmediate(_js_helper.convertDartClosureToJS(internalCallback, 0));
}
- static [_scheduleImmediateWithSetImmediate](callback) {
+ static _scheduleImmediateWithSetImmediate(callback) {
// Function internalCallback: () → dynamic
function internalCallback() {
_isolate_helper.leaveJsAsync();
@@ -2623,13 +2592,13 @@ var async;
_isolate_helper.enterJsAsync();
self.setImmediate(_js_helper.convertDartClosureToJS(internalCallback, 0));
}
- static [_scheduleImmediateWithTimer](callback) {
- Timer[_createTimer](core.Duration.ZERO, callback);
+ static _scheduleImmediateWithTimer(callback) {
+ Timer._createTimer(core.Duration.ZERO, callback);
}
}
dart.defineLazyProperties(_AsyncRun, {
get scheduleImmediateClosure() {
- return _AsyncRun[_initializeScheduleImmediate]();
+ return _AsyncRun._initializeScheduleImmediate();
}
});
let StreamSubscription$ = dart.generic(function(T) {
@@ -2768,9 +2737,7 @@ var async;
});
let _StreamControllerLifecycle = _StreamControllerLifecycle$();
let _varData = Symbol('_varData');
- let _STATE_SUBSCRIBED = Symbol('_STATE_SUBSCRIBED');
let _isInitialState = Symbol('_isInitialState');
- let _STATE_SUBSCRIPTION_MASK = Symbol('_STATE_SUBSCRIPTION_MASK');
let _subscription = Symbol('_subscription');
let _pendingEvents = Symbol('_pendingEvents');
let _ensurePendingEvents = Symbol('_ensurePendingEvents');
@@ -2779,7 +2746,7 @@ var async;
class _StreamController extends core.Object {
_StreamController() {
this[_varData] = null;
- this[_state] = _StreamController[_STATE_INITIAL];
+ this[_state] = _StreamController._STATE_INITIAL;
this[_doneFuture] = null;
}
get stream() {
@@ -2789,25 +2756,25 @@ var async;
return new (_StreamSinkWrapper$(T))(this);
}
get [_isCanceled]() {
- return (dart.notNull(this[_state]) & dart.notNull(_StreamController[_STATE_CANCELED])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_StreamController._STATE_CANCELED)) != 0;
}
get hasListener() {
- return (dart.notNull(this[_state]) & dart.notNull(_StreamController[_STATE_SUBSCRIBED])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_StreamController._STATE_SUBSCRIBED)) != 0;
}
get [_isInitialState]() {
- return (dart.notNull(this[_state]) & dart.notNull(_StreamController[_STATE_SUBSCRIPTION_MASK])) == _StreamController[_STATE_INITIAL];
+ return (dart.notNull(this[_state]) & dart.notNull(_StreamController._STATE_SUBSCRIPTION_MASK)) == _StreamController._STATE_INITIAL;
}
get isClosed() {
- return (dart.notNull(this[_state]) & dart.notNull(_StreamController[_STATE_CLOSED])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_StreamController._STATE_CLOSED)) != 0;
}
get isPaused() {
return this.hasListener ? this[_subscription][_isInputPaused] : !dart.notNull(this[_isCanceled]);
}
get [_isAddingStream]() {
- return (dart.notNull(this[_state]) & dart.notNull(_StreamController[_STATE_ADDSTREAM])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_StreamController._STATE_ADDSTREAM)) != 0;
}
get [_mayAddEvent]() {
- return dart.notNull(this[_state]) < dart.notNull(_StreamController[_STATE_CLOSED]);
+ return dart.notNull(this[_state]) < dart.notNull(_StreamController._STATE_CLOSED);
}
get [_pendingEvents]() {
dart.assert(this[_isInitialState]);
@@ -2852,7 +2819,7 @@ var async;
return new _Future.immediate(null);
let addState = new _StreamControllerAddStreamState(this, this[_varData], source, cancelOnError);
this[_varData] = addState;
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController[_STATE_ADDSTREAM]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController._STATE_ADDSTREAM);
return addState.addStreamFuture;
}
get done() {
@@ -2860,7 +2827,7 @@ var async;
}
[_ensureDoneFuture]() {
if (this[_doneFuture] == null) {
- this[_doneFuture] = this[_isCanceled] ? Future[_nullFuture] : new _Future();
+ this[_doneFuture] = this[_isCanceled] ? Future._nullFuture : new _Future();
}
return this[_doneFuture];
}
@@ -2892,7 +2859,7 @@ var async;
return this[_ensureDoneFuture]();
}
[_closeUnchecked]() {
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController[_STATE_CLOSED]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController._STATE_CLOSED);
if (this.hasListener) {
this[_sendDone]();
} else if (this[_isInitialState]) {
@@ -2917,7 +2884,7 @@ var async;
dart.assert(this[_isAddingStream]);
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
this[_varData] = addState.varData;
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_StreamController[_STATE_ADDSTREAM]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_StreamController._STATE_ADDSTREAM);
addState.complete();
}
[_subscribe](onData, onError, onDone, cancelOnError) {
@@ -2926,7 +2893,7 @@ var async;
}
let subscription = new _ControllerSubscription(this, onData, onError, onDone, cancelOnError);
let pendingEvents = this[_pendingEvents];
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController[_STATE_SUBSCRIBED]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController._STATE_SUBSCRIBED);
if (this[_isAddingStream]) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
addState.varData = subscription;
@@ -2947,7 +2914,7 @@ var async;
result = addState.cancel();
}
this[_varData] = null;
- this[_state] = dart.notNull(this[_state]) & ~(dart.notNull(_StreamController[_STATE_SUBSCRIBED]) | dart.notNull(_StreamController[_STATE_ADDSTREAM])) | dart.notNull(_StreamController[_STATE_CANCELED]);
+ this[_state] = dart.notNull(this[_state]) & ~(dart.notNull(_StreamController._STATE_SUBSCRIBED) | dart.notNull(_StreamController._STATE_ADDSTREAM)) | dart.notNull(_StreamController._STATE_CANCELED);
if (this[_onCancel] != null) {
if (result == null) {
try {
@@ -3198,40 +3165,38 @@ var async;
});
let _GeneratedStreamImpl = _GeneratedStreamImpl$();
let _iterator = Symbol('_iterator');
- let _STATE_UNSCHEDULED = Symbol('_STATE_UNSCHEDULED');
- let _STATE_SCHEDULED = Symbol('_STATE_SCHEDULED');
let _eventScheduled = Symbol('_eventScheduled');
class _PendingEvents extends core.Object {
_PendingEvents() {
- this[_state] = _PendingEvents[_STATE_UNSCHEDULED];
+ this[_state] = _PendingEvents._STATE_UNSCHEDULED;
}
get isScheduled() {
- return this[_state] == _PendingEvents[_STATE_SCHEDULED];
+ return this[_state] == _PendingEvents._STATE_SCHEDULED;
}
get [_eventScheduled]() {
- return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents[_STATE_SCHEDULED]);
+ return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents._STATE_SCHEDULED);
}
schedule(dispatch) {
if (this.isScheduled)
return;
dart.assert(!dart.notNull(this.isEmpty));
if (this[_eventScheduled]) {
- dart.assert(this[_state] == _PendingEvents[_STATE_CANCELED]);
- this[_state] = _PendingEvents[_STATE_SCHEDULED];
+ dart.assert(this[_state] == _PendingEvents._STATE_CANCELED);
+ this[_state] = _PendingEvents._STATE_SCHEDULED;
return;
}
scheduleMicrotask((() => {
let oldState = this[_state];
- this[_state] = _PendingEvents[_STATE_UNSCHEDULED];
- if (oldState == _PendingEvents[_STATE_CANCELED])
+ this[_state] = _PendingEvents._STATE_UNSCHEDULED;
+ if (oldState == _PendingEvents._STATE_CANCELED)
return;
this.handleNext(dispatch);
}).bind(this));
- this[_state] = _PendingEvents[_STATE_SCHEDULED];
+ this[_state] = _PendingEvents._STATE_SCHEDULED;
}
cancelSchedule() {
if (this.isScheduled)
- this[_state] = _PendingEvents[_STATE_CANCELED];
+ this[_state] = _PendingEvents._STATE_CANCELED;
}
}
_PendingEvents._STATE_UNSCHEDULED = 0;
@@ -3390,10 +3355,7 @@ var async;
let _broadcastCallback = dart.typedef('_broadcastCallback', () => dart.functionType(dart.void, [StreamSubscription]));
let _schedule = Symbol('_schedule');
let _isSent = Symbol('_isSent');
- let _DONE_SENT = Symbol('_DONE_SENT');
let _isScheduled = Symbol('_isScheduled');
- let _SCHEDULED = Symbol('_SCHEDULED');
- let _PAUSED = Symbol('_PAUSED');
let _DoneStreamSubscription$ = dart.generic(function(T) {
class _DoneStreamSubscription extends core.Object {
_DoneStreamSubscription(onDone) {
@@ -3403,19 +3365,19 @@ var async;
this[_schedule]();
}
get [_isSent]() {
- return (dart.notNull(this[_state]) & dart.notNull(_DoneStreamSubscription[_DONE_SENT])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_DoneStreamSubscription._DONE_SENT)) != 0;
}
get [_isScheduled]() {
- return (dart.notNull(this[_state]) & dart.notNull(_DoneStreamSubscription[_SCHEDULED])) != 0;
+ return (dart.notNull(this[_state]) & dart.notNull(_DoneStreamSubscription._SCHEDULED)) != 0;
}
get isPaused() {
- return dart.notNull(this[_state]) >= dart.notNull(_DoneStreamSubscription[_PAUSED]);
+ return dart.notNull(this[_state]) >= dart.notNull(_DoneStreamSubscription._PAUSED);
}
[_schedule]() {
if (this[_isScheduled])
return;
this[_zone].scheduleMicrotask(this[_sendDone].bind(this));
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubscription[_SCHEDULED]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubscription._SCHEDULED);
}
onData(handleData) {}
onError(handleError) {}
@@ -3425,13 +3387,13 @@ var async;
pause(resumeSignal) {
if (resumeSignal === void 0)
resumeSignal = null;
- this[_state] = dart.notNull(this[_state]) + dart.notNull(_DoneStreamSubscription[_PAUSED]);
+ this[_state] = dart.notNull(this[_state]) + dart.notNull(_DoneStreamSubscription._PAUSED);
if (resumeSignal != null)
resumeSignal.whenComplete(this.resume.bind(this));
}
resume() {
if (this.isPaused) {
- this[_state] = dart.notNull(this[_state]) - dart.notNull(_DoneStreamSubscription[_PAUSED]);
+ this[_state] = dart.notNull(this[_state]) - dart.notNull(_DoneStreamSubscription._PAUSED);
if (!dart.notNull(this.isPaused) && !dart.notNull(this[_isSent])) {
this[_schedule]();
}
@@ -3450,10 +3412,10 @@ var async;
return result;
}
[_sendDone]() {
- this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_DoneStreamSubscription[_SCHEDULED]);
+ this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_DoneStreamSubscription._SCHEDULED);
if (this.isPaused)
return;
- this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubscription[_DONE_SENT]);
+ this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubscription._DONE_SENT);
if (this[_onDone] != null)
this[_zone].runGuarded(this[_onDone]);
}
@@ -3583,57 +3545,51 @@ var async;
return _BroadcastSubscriptionWrapper;
});
let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$();
- let _STATE_FOUND = Symbol('_STATE_FOUND');
let _current = Symbol('_current');
let _futureOrPrefetch = Symbol('_futureOrPrefetch');
- let _STATE_DONE = Symbol('_STATE_DONE');
- let _STATE_MOVING = Symbol('_STATE_MOVING');
- let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA');
- let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR');
let _clear = Symbol('_clear');
- let _STATE_EXTRA_DONE = Symbol('_STATE_EXTRA_DONE');
let _StreamIteratorImpl$ = dart.generic(function(T) {
class _StreamIteratorImpl extends core.Object {
_StreamIteratorImpl(stream) {
this[_subscription] = null;
this[_current] = null;
this[_futureOrPrefetch] = null;
- this[_state] = _StreamIteratorImpl[_STATE_FOUND];
+ this[_state] = _StreamIteratorImpl._STATE_FOUND;
this[_subscription] = stream.listen(this[_onData].bind(this), {onError: this[_onError].bind(this), onDone: this[_onDone].bind(this), cancelOnError: true});
}
get current() {
return this[_current];
}
moveNext() {
- if (this[_state] == _StreamIteratorImpl[_STATE_DONE]) {
+ if (this[_state] == _StreamIteratorImpl._STATE_DONE) {
return new _Future$(core.bool).immediate(false);
}
- if (this[_state] == _StreamIteratorImpl[_STATE_MOVING]) {
+ if (this[_state] == _StreamIteratorImpl._STATE_MOVING) {
throw new core.StateError("Already waiting for next.");
}
- if (this[_state] == _StreamIteratorImpl[_STATE_FOUND]) {
- this[_state] = _StreamIteratorImpl[_STATE_MOVING];
+ if (this[_state] == _StreamIteratorImpl._STATE_FOUND) {
+ this[_state] = _StreamIteratorImpl._STATE_MOVING;
this[_current] = null;
this[_futureOrPrefetch] = new (_Future$(core.bool))();
return dart.as(this[_futureOrPrefetch], Future$(core.bool));
} else {
- dart.assert(dart.notNull(this[_state]) >= dart.notNull(_StreamIteratorImpl[_STATE_EXTRA_DATA]));
+ dart.assert(dart.notNull(this[_state]) >= dart.notNull(_StreamIteratorImpl._STATE_EXTRA_DATA));
switch (this[_state]) {
- case _StreamIteratorImpl[_STATE_EXTRA_DATA]:
+ case _StreamIteratorImpl._STATE_EXTRA_DATA:
{
- this[_state] = _StreamIteratorImpl[_STATE_FOUND];
+ this[_state] = _StreamIteratorImpl._STATE_FOUND;
this[_current] = dart.as(this[_futureOrPrefetch], T);
this[_futureOrPrefetch] = null;
this[_subscription].resume();
return new _Future$(core.bool).immediate(true);
}
- case _StreamIteratorImpl[_STATE_EXTRA_ERROR]:
+ case _StreamIteratorImpl._STATE_EXTRA_ERROR:
{
let prefetch = dart.as(this[_futureOrPrefetch], AsyncError);
this[_clear]();
return new _Future$(core.bool).immediateError(prefetch.error, prefetch.stackTrace);
}
- case _StreamIteratorImpl[_STATE_EXTRA_DONE]:
+ case _StreamIteratorImpl._STATE_EXTRA_DONE:
{
this[_clear]();
return new _Future$(core.bool).immediate(false);
@@ -3645,11 +3601,11 @@ var async;
this[_subscription] = null;
this[_futureOrPrefetch] = null;
this[_current] = null;
- this[_state] = _StreamIteratorImpl[_STATE_DONE];
+ this[_state] = _StreamIteratorImpl._STATE_DONE;
}
cancel() {
let subscription = this[_subscription];
- if (this[_state] == _StreamIteratorImpl[_STATE_MOVING]) {
+ if (this[_state] == _StreamIteratorImpl._STATE_MOVING) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_clear]();
hasNext[_complete](false);
@@ -3659,23 +3615,23 @@ var async;
return subscription.cancel();
}
[_onData](data) {
- if (this[_state] == _StreamIteratorImpl[_STATE_MOVING]) {
+ if (this[_state] == _StreamIteratorImpl._STATE_MOVING) {
this[_current] = data;
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_futureOrPrefetch] = null;
- this[_state] = _StreamIteratorImpl[_STATE_FOUND];
+ this[_state] = _StreamIteratorImpl._STATE_FOUND;
hasNext[_complete](true);
return;
}
this[_subscription].pause();
dart.assert(this[_futureOrPrefetch] == null);
this[_futureOrPrefetch] = data;
- this[_state] = _StreamIteratorImpl[_STATE_EXTRA_DATA];
+ this[_state] = _StreamIteratorImpl._STATE_EXTRA_DATA;
}
[_onError](error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- if (this[_state] == _StreamIteratorImpl[_STATE_MOVING]) {
+ if (this[_state] == _StreamIteratorImpl._STATE_MOVING) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_clear]();
hasNext[_completeError](error, stackTrace);
@@ -3684,10 +3640,10 @@ var async;
this[_subscription].pause();
dart.assert(this[_futureOrPrefetch] == null);
this[_futureOrPrefetch] = new AsyncError(error, stackTrace);
- this[_state] = _StreamIteratorImpl[_STATE_EXTRA_ERROR];
+ this[_state] = _StreamIteratorImpl._STATE_EXTRA_ERROR;
}
[_onDone]() {
- if (this[_state] == _StreamIteratorImpl[_STATE_MOVING]) {
+ if (this[_state] == _StreamIteratorImpl._STATE_MOVING) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_clear]();
hasNext[_complete](false);
@@ -3695,7 +3651,7 @@ var async;
}
this[_subscription].pause();
this[_futureOrPrefetch] = null;
- this[_state] = _StreamIteratorImpl[_STATE_EXTRA_DONE];
+ this[_state] = _StreamIteratorImpl._STATE_EXTRA_DONE;
}
}
_StreamIteratorImpl[dart.implements] = () => [StreamIterator$(T)];
@@ -4083,17 +4039,16 @@ var async;
return _Equality;
});
let _Equality = _Equality$();
- let _SENTINEL = Symbol('_SENTINEL');
let _equals = Symbol('_equals');
let _DistinctStream$ = dart.generic(function(T) {
class _DistinctStream extends _ForwardingStream$(T, T) {
_DistinctStream(source, equals) {
- this[_previous] = _DistinctStream[_SENTINEL];
+ this[_previous] = _DistinctStream._SENTINEL;
this[_equals] = equals;
super._ForwardingStream(source);
}
[_handleData](inputEvent, sink) {
- if (core.identical(this[_previous], _DistinctStream[_SENTINEL])) {
+ if (core.identical(this[_previous], _DistinctStream._SENTINEL)) {
this[_previous] = inputEvent;
return sink[_add](inputEvent);
} else {
@@ -4118,10 +4073,10 @@ var async;
}
}
dart.defineLazyProperties(_DistinctStream, {
- get [_SENTINEL]() {
+ get _SENTINEL() {
return new core.Object();
},
- set [_SENTINEL](_) {}
+ set _SENTINEL(_) {}
});
return _DistinctStream;
});
@@ -4314,9 +4269,6 @@ var async;
return _HandlerEventSink;
});
let _HandlerEventSink = _HandlerEventSink$();
- let _defaultHandleData = Symbol('_defaultHandleData');
- let _defaultHandleError = Symbol('_defaultHandleError');
- let _defaultHandleDone = Symbol('_defaultHandleDone');
let _StreamHandlerTransformer$ = dart.generic(function(S, T) {
class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) {
_StreamHandlerTransformer(opts) {
@@ -4325,24 +4277,24 @@ var async;
let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null;
super._StreamSinkTransformer(dart.as(outputSink => {
if (handleData == null)
- handleData = dart.as(_StreamHandlerTransformer[_defaultHandleData], __CastType29);
+ handleData = dart.as(_StreamHandlerTransformer._defaultHandleData, __CastType29);
if (handleError == null)
- handleError = dart.as(_StreamHandlerTransformer[_defaultHandleError], __CastType32);
+ handleError = dart.as(_StreamHandlerTransformer._defaultHandleError, __CastType32);
if (handleDone == null)
- handleDone = _StreamHandlerTransformer[_defaultHandleDone];
+ handleDone = _StreamHandlerTransformer._defaultHandleDone;
return new (_HandlerEventSink$(S, T))(handleData, handleError, handleDone, outputSink);
}, _SinkMapper$(S, T)));
}
bind(stream) {
return super.bind(stream);
}
- static [_defaultHandleData](data, sink) {
+ static _defaultHandleData(data, sink) {
sink.add(data);
}
- static [_defaultHandleError](error, stackTrace, sink) {
+ static _defaultHandleError(error, stackTrace, sink) {
sink.addError(error);
}
- static [_defaultHandleDone](sink) {
+ static _defaultHandleDone(sink) {
sink.close();
}
}
@@ -4400,7 +4352,6 @@ var async;
return __CastType32;
});
let __CastType32 = __CastType32$();
- let _createPeriodicTimer = Symbol('_createPeriodicTimer');
class Timer extends core.Object {
Timer(duration, callback) {
if (dart.equals(Zone.current, Zone.ROOT)) {
@@ -4417,13 +4368,13 @@ var async;
static run(callback) {
new Timer(core.Duration.ZERO, callback);
}
- static [_createTimer](duration, callback) {
+ static _createTimer(duration, callback) {
let milliseconds = duration.inMilliseconds;
if (dart.notNull(milliseconds) < 0)
milliseconds = 0;
return new _isolate_helper.TimerImpl(milliseconds, callback);
}
- static [_createPeriodicTimer](duration, callback) {
+ static _createPeriodicTimer(duration, callback) {
let milliseconds = duration.inMilliseconds;
if (dart.notNull(milliseconds) < 0)
milliseconds = 0;
@@ -4508,26 +4459,25 @@ var async;
}
_ZoneSpecification[dart.implements] = () => [ZoneSpecification];
class ZoneDelegate extends core.Object {}
- let _ = Symbol('_');
class Zone extends core.Object {
- [_]() {
+ _() {
}
static get current() {
- return Zone[_current];
+ return Zone._current;
}
- static [_enter](zone) {
+ static _enter(zone) {
dart.assert(zone != null);
- dart.assert(!dart.notNull(core.identical(zone, Zone[_current])));
- let previous = Zone[_current];
- Zone[_current] = zone;
+ dart.assert(!dart.notNull(core.identical(zone, Zone._current)));
+ let previous = Zone._current;
+ Zone._current = zone;
return previous;
}
- static [_leave](previous) {
+ static _leave(previous) {
dart.assert(previous != null);
- Zone[_current] = previous;
+ Zone._current = previous;
}
}
- dart.defineNamedConstructor(Zone, _);
+ dart.defineNamedConstructor(Zone, '_');
Zone.ROOT = _ROOT_ZONE;
Zone._current = _ROOT_ZONE;
let _delegate = Symbol('_delegate');
@@ -4547,6 +4497,8 @@ var async;
let _registerBinaryCallback = Symbol('_registerBinaryCallback');
let _errorCallback = Symbol('_errorCallback');
let _scheduleMicrotask = Symbol('_scheduleMicrotask');
+ let _createTimer = Symbol('_createTimer');
+ let _createPeriodicTimer = Symbol('_createPeriodicTimer');
let _print = Symbol('_print');
let _fork = Symbol('_fork');
class _ZoneDelegate extends core.Object {
@@ -4834,35 +4786,35 @@ var async;
}
// Function _rootRun: (Zone, ZoneDelegate, Zone, () → dynamic) → dynamic
function _rootRun(self, parent, zone, f) {
- if (dart.equals(Zone[_current], zone))
+ if (dart.equals(Zone._current, zone))
return f();
- let old = Zone[_enter](zone);
+ let old = Zone._enter(zone);
try {
return f();
} finally {
- Zone[_leave](old);
+ Zone._leave(old);
}
}
// Function _rootRunUnary: (Zone, ZoneDelegate, Zone, (dynamic) → dynamic, dynamic) → dynamic
function _rootRunUnary(self, parent, zone, f, arg) {
- if (dart.equals(Zone[_current], zone))
+ if (dart.equals(Zone._current, zone))
return dart.dcall(f, arg);
- let old = Zone[_enter](zone);
+ let old = Zone._enter(zone);
try {
return dart.dcall(f, arg);
} finally {
- Zone[_leave](old);
+ Zone._leave(old);
}
}
// Function _rootRunBinary: (Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic, dynamic, dynamic) → dynamic
function _rootRunBinary(self, parent, zone, f, arg1, arg2) {
- if (dart.equals(Zone[_current], zone))
+ if (dart.equals(Zone._current, zone))
return dart.dcall(f, arg1, arg2);
- let old = Zone[_enter](zone);
+ let old = Zone._enter(zone);
try {
return dart.dcall(f, arg1, arg2);
} finally {
- Zone[_leave](old);
+ Zone._leave(old);
}
}
// Function _rootRegisterCallback: (Zone, ZoneDelegate, Zone, () → dynamic) → ZoneCallback
@@ -4894,14 +4846,14 @@ var async;
if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) {
callback = zone.bindCallback(callback);
}
- return Timer[_createTimer](duration, callback);
+ return Timer._createTimer(duration, callback);
}
// Function _rootCreatePeriodicTimer: (Zone, ZoneDelegate, Zone, Duration, (Timer) → void) → Timer
function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) {
if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) {
callback = dart.as(zone.bindUnaryCallback(callback), __CastType118);
}
- return Timer[_createPeriodicTimer](duration, callback);
+ return Timer._createPeriodicTimer(duration, callback);
}
// Function _rootPrint: (Zone, ZoneDelegate, Zone, String) → void
function _rootPrint(self, parent, zone, line) {
@@ -4973,8 +4925,6 @@ var async;
}
}
_RootZoneSpecification[dart.implements] = () => [ZoneSpecification];
- let _rootMap = Symbol('_rootMap');
- let _rootDelegate = Symbol('_rootDelegate');
class _RootZone extends _Zone {
_RootZone() {
super._Zone();
@@ -5022,19 +4972,19 @@ var async;
return null;
}
get [_map]() {
- return _RootZone[_rootMap];
+ return _RootZone._rootMap;
}
get [_delegate]() {
- if (_RootZone[_rootDelegate] != null)
- return _RootZone[_rootDelegate];
- return _RootZone[_rootDelegate] = new _ZoneDelegate(this);
+ if (_RootZone._rootDelegate != null)
+ return _RootZone._rootDelegate;
+ return _RootZone._rootDelegate = new _ZoneDelegate(this);
}
get errorZone() {
return this;
}
runGuarded(f) {
try {
- if (core.identical(_ROOT_ZONE, Zone[_current])) {
+ if (core.identical(_ROOT_ZONE, Zone._current)) {
return f();
}
return _rootRun(null, null, this, f);
@@ -5046,7 +4996,7 @@ var async;
}
runUnaryGuarded(f, arg) {
try {
- if (core.identical(_ROOT_ZONE, Zone[_current])) {
+ if (core.identical(_ROOT_ZONE, Zone._current)) {
return dart.dcall(f, arg);
}
return _rootRunUnary(null, null, this, f, arg);
@@ -5058,7 +5008,7 @@ var async;
}
runBinaryGuarded(f, arg1, arg2) {
try {
- if (core.identical(_ROOT_ZONE, Zone[_current])) {
+ if (core.identical(_ROOT_ZONE, Zone._current)) {
return dart.dcall(f, arg1, arg2);
}
return _rootRunBinary(null, null, this, f, arg1, arg2);
@@ -5104,17 +5054,17 @@ var async;
return _rootFork(null, null, this, specification, zoneValues);
}
run(f) {
- if (core.identical(Zone[_current], _ROOT_ZONE))
+ if (core.identical(Zone._current, _ROOT_ZONE))
return f();
return _rootRun(null, null, this, f);
}
runUnary(f, arg) {
- if (core.identical(Zone[_current], _ROOT_ZONE))
+ if (core.identical(Zone._current, _ROOT_ZONE))
return dart.dcall(f, arg);
return _rootRunUnary(null, null, this, f, arg);
}
runBinary(f, arg1, arg2) {
- if (core.identical(Zone[_current], _ROOT_ZONE))
+ if (core.identical(Zone._current, _ROOT_ZONE))
return dart.dcall(f, arg1, arg2);
return _rootRunBinary(null, null, this, f, arg1, arg2);
}
@@ -5134,10 +5084,10 @@ var async;
_rootScheduleMicrotask(null, null, this, f);
}
createTimer(duration, f) {
- return Timer[_createTimer](duration, f);
+ return Timer._createTimer(duration, f);
}
createPeriodicTimer(duration, f) {
- return Timer[_createPeriodicTimer](duration, f);
+ return Timer._createPeriodicTimer(duration, f);
}
print(line) {
_internal.printToConsole(line);
@@ -5145,10 +5095,10 @@ var async;
}
_RootZone._rootDelegate = null;
dart.defineLazyProperties(_RootZone, {
- get [_rootMap]() {
+ get _rootMap() {
return new collection.HashMap();
},
- set [_rootMap](_) {}
+ set _rootMap(_) {}
});
let _ROOT_ZONE = dart.const(new _RootZone());
// Function runZoned: (() → dynamic, {zoneValues: Map<dynamic, dynamic>, zoneSpecification: ZoneSpecification, onError: Function}) → dynamic
« no previous file with comments | « lib/runtime/dart/_native_typed_data.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698