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

Issues Search
    My Issues | Starred     Open | Closed | All

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

Issue 1059583002: Extension method support to move us closer to a valid List implementation. (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: done Created 5 years, 9 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 31e448b72d84a7cbb065b712f2d4fc564a766c65..251b93847e888366b0e3fc39da0b900b5814a856 100644
--- a/lib/runtime/dart/async.js
+++ b/lib/runtime/dart/async.js
@@ -50,7 +50,10 @@ var async;
}
let _controller = Symbol('_controller');
let _createSubscription = Symbol('_createSubscription');
+ let _subscribe = Symbol('_subscribe');
let _onListen = Symbol('_onListen');
+ let _add = Symbol('_add');
+ let _closeUnchecked = Symbol('_closeUnchecked');
let _addError = Symbol('_addError');
let _completeError = Symbol('_completeError');
let _complete = Symbol('_complete');
@@ -62,11 +65,11 @@ var async;
fromFuture(future) {
let controller = new (StreamController$(T))({sync: true});
future.then(dart.closureWrap(((value) => {
- controller._add(dart.as(value, T));
- controller._closeUnchecked();
+ controller[_add](dart.as(value, T));
+ controller[_closeUnchecked]();
}).bind(this), "(T) → dynamic"), {onError: ((error, stackTrace) => {
- controller._addError(error, dart.as(stackTrace, core.StackTrace));
- controller._closeUnchecked();
+ controller[_addError](error, dart.as(stackTrace, core.StackTrace));
+ controller[_closeUnchecked]();
}).bind(this)});
return controller.stream;
}
@@ -252,7 +255,7 @@ var async;
}
} else {
- result._complete(value);
+ result[_complete](value);
}
}).bind(this), cancelOnError: true});
return result;
@@ -266,9 +269,9 @@ var async;
value = newValue;
}, dart.as(_cancelAndErrorClosure(subscription, result), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: ((e, st) => {
- result._completeError(e, dart.as(st, core.StackTrace));
+ result[_completeError](e, dart.as(st, core.StackTrace));
}).bind(this), onDone: (() => {
- result._complete(value);
+ result[_complete](value);
}).bind(this), cancelOnError: true});
return result;
}
@@ -292,9 +295,9 @@ var async;
}
}).bind(this), {onError: ((e) => {
- result._completeError(e);
+ result[_completeError](e);
}).bind(this), onDone: (() => {
- result._complete(buffer.toString());
+ result[_complete](buffer.toString());
}).bind(this), cancelOnError: true});
return result;
}
@@ -308,7 +311,7 @@ var async;
}
}, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future[_completeError], onDone: (() => {
- future._complete(false);
+ future[_complete](false);
}).bind(this), cancelOnError: true});
return future;
}
@@ -319,7 +322,7 @@ var async;
_runUserCode(() => action(element), (_) => {
}, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future[_completeError], onDone: (() => {
- future._complete(null);
+ future[_complete](null);
}).bind(this), cancelOnError: true});
return future;
}
@@ -333,7 +336,7 @@ var async;
}
}, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future[_completeError], onDone: (() => {
- future._complete(true);
+ future[_complete](true);
}).bind(this), cancelOnError: true});
return future;
}
@@ -347,7 +350,7 @@ var async;
}
}, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future[_completeError], onDone: (() => {
- future._complete(false);
+ future[_complete](false);
}).bind(this), cancelOnError: true});
return future;
}
@@ -357,7 +360,7 @@ var async;
this.listen(dart.closureWrap((_) => {
count = dart.notNull(count) + 1;
}, "(T) → void"), {onError: future[_completeError], onDone: (() => {
- future._complete(count);
+ future[_complete](count);
}).bind(this), cancelOnError: true});
return future;
}
@@ -367,7 +370,7 @@ var async;
subscription = this.listen(dart.closureWrap((_) => {
_cancelAndValue(subscription, future, false);
}, "(T) → void"), {onError: future[_completeError], onDone: (() => {
- future._complete(true);
+ future[_complete](true);
}).bind(this), cancelOnError: true});
return future;
}
@@ -375,9 +378,9 @@ var async;
let result = new core.List$(T).from([]);
let future = new (_Future$(core.List$(T)))();
this.listen(((data) => {
- result.add(data);
+ result[core.$add](data);
}).bind(this), {onError: future[_completeError], onDone: (() => {
- future._complete(result);
+ future[_complete](result);
}).bind(this), cancelOnError: true});
return future;
}
@@ -387,7 +390,7 @@ var async;
this.listen(((data) => {
result.add(data);
}).bind(this), {onError: future[_completeError], onDone: (() => {
- future._complete(result);
+ future[_complete](result);
}).bind(this), cancelOnError: true});
return future;
}
@@ -443,7 +446,7 @@ var async;
result = value;
}, {onError: future[_completeError], onDone: (() => {
if (foundResult) {
- future._complete(result);
+ future[_complete](result);
return;
}
try {
@@ -476,7 +479,7 @@ var async;
result = value;
}, {onError: future[_completeError], onDone: (() => {
if (foundResult) {
- future._complete(result);
+ future[_complete](result);
return;
}
try {
@@ -529,7 +532,7 @@ var async;
}, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future[_completeError], onDone: (() => {
if (foundResult) {
- future._complete(result);
+ future[_complete](result);
return;
}
if (defaultValue != null) {
@@ -570,7 +573,7 @@ var async;
}, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future[_completeError], onDone: (() => {
if (foundResult) {
- future._complete(result);
+ future[_complete](result);
return;
}
try {
@@ -596,7 +599,7 @@ var async;
}
elementIndex = 1;
}, {onError: future[_completeError], onDone: (() => {
- future._completeError(new core.RangeError.index(index, this, "index", null, elementIndex));
+ future[_completeError](new core.RangeError.index(index, this, "index", null, elementIndex));
}).bind(this), cancelOnError: true});
return future;
}
@@ -695,7 +698,7 @@ var async;
super._StreamImpl();
}
[_createSubscription](onData, onError, onDone, cancelOnError) {
- return this[_controller]._subscribe(onData, onError, onDone, cancelOnError);
+ return this[_controller][_subscribe](onData, onError, onDone, cancelOnError);
}
get hashCode() {
return dart.notNull(this[_controller].hashCode) ^ 892482866;
@@ -744,6 +747,9 @@ var async;
let _onPause = Symbol('_onPause');
let _onResume = Symbol('_onResume');
let _onCancel = Symbol('_onCancel');
+ let _recordCancel = Symbol('_recordCancel');
+ let _recordPause = Symbol('_recordPause');
+ let _recordResume = Symbol('_recordResume');
let _zone = Symbol('_zone');
let _state = Symbol('_state');
let _STATE_CANCEL_ON_ERROR = Symbol('_STATE_CANCEL_ON_ERROR');
@@ -775,7 +781,6 @@ var async;
let _canFire = Symbol('_canFire');
let _cancelOnError = Symbol('_cancelOnError');
let _incrementPauseCount = Symbol('_incrementPauseCount');
- let _add = Symbol('_add');
let _sendData = Symbol('_sendData');
let _addPending = Symbol('_addPending');
let _sendError = Symbol('_sendError');
@@ -871,11 +876,11 @@ var async;
futureValue = null;
let result = new (_Future$(T))();
this[_onDone] = (() => {
- result._complete(futureValue);
+ result[_complete](futureValue);
}).bind(this);
this[_onError] = ((error, stackTrace) => {
this.cancel();
- result._completeError(error, dart.as(stackTrace, core.StackTrace));
+ result[_completeError](error, dart.as(stackTrace, core.StackTrace));
}).bind(this);
return result;
}
@@ -1098,13 +1103,13 @@ var async;
super._BufferingStreamSubscription(onData, onError, onDone, cancelOnError);
}
[_onCancel]() {
- return this[_controller]._recordCancel(this);
+ return this[_controller][_recordCancel](this);
}
[_onPause]() {
- this[_controller]._recordPause(this);
+ this[_controller][_recordPause](this);
}
[_onResume]() {
- this[_controller]._recordResume(this);
+ this[_controller][_recordResume](this);
}
}
return _ControllerSubscription;
@@ -1159,14 +1164,11 @@ var async;
let _ensureDoneFuture = Symbol('_ensureDoneFuture');
let _addListener = Symbol('_addListener');
let _removeListener = Symbol('_removeListener');
- let _subscribe = Symbol('_subscribe');
- let _recordCancel = Symbol('_recordCancel');
let _callOnCancel = Symbol('_callOnCancel');
- let _recordPause = Symbol('_recordPause');
- let _recordResume = Symbol('_recordResume');
let _addEventError = Symbol('_addEventError');
let _forEachListener = Symbol('_forEachListener');
let _mayComplete = Symbol('_mayComplete');
+ let _asyncComplete = Symbol('_asyncComplete');
let _BroadcastStreamController$ = dart.generic(function(T) {
class _BroadcastStreamController extends core.Object {
_BroadcastStreamController(onListen$, onCancel$) {
@@ -1250,7 +1252,7 @@ var async;
return null;
dart.assert(!dart.notNull(core.identical(subscription[_next], subscription)));
if (subscription[_isFiring]) {
- subscription._setRemoveAfterFiring();
+ subscription[_setRemoveAfterFiring]();
} else {
dart.assert(!dart.notNull(core.identical(subscription[_next], subscription)));
this[_removeListener](subscription);
@@ -1334,10 +1336,10 @@ var async;
let link = this[_next];
while (!dart.notNull(core.identical(link, this))) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- if (subscription._expectsEvent(id)) {
+ if (subscription[_expectsEvent](id)) {
subscription[_eventState] = _BroadcastSubscription[_STATE_FIRING];
action(subscription);
- subscription._toggleEventId();
+ subscription[_toggleEventId]();
link = subscription[_next];
if (subscription[_removeAfterFiring]) {
this[_removeListener](subscription);
@@ -1355,7 +1357,7 @@ var async;
[_callOnCancel]() {
dart.assert(this[_isEmpty]);
if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayComplete])) {
- this[_doneFuture]._asyncComplete(null);
+ this[_doneFuture][_asyncComplete](null);
}
_runGuarded(this[_onCancel]);
}
@@ -1380,7 +1382,7 @@ var async;
if (this[_hasOneListener]) {
this[_state] = _BroadcastStreamController[_STATE_FIRING];
let subscription = dart.as(this[_next], _BroadcastSubscription);
- subscription._add(data);
+ subscription[_add](data);
this[_state] = ~dart.notNull(_BroadcastStreamController[_STATE_FIRING]);
if (this[_isEmpty]) {
this[_callOnCancel]();
@@ -1388,25 +1390,25 @@ var async;
return;
}
this[_forEachListener](((subscription) => {
- subscription._add(data);
+ subscription[_add](data);
}).bind(this));
}
[_sendError](error, stackTrace) {
if (this[_isEmpty])
return;
this[_forEachListener](((subscription) => {
- subscription._addError(error, stackTrace);
+ subscription[_addError](error, stackTrace);
}).bind(this));
}
[_sendDone]() {
if (!dart.notNull(this[_isEmpty])) {
this[_forEachListener](dart.closureWrap(((subscription) => {
- subscription._close();
+ subscription[_close]();
}).bind(this), "(_BufferingStreamSubscription<T>) → void"));
} else {
dart.assert(this[_doneFuture] != null);
dart.assert(this[_doneFuture][_mayComplete]);
- this[_doneFuture]._asyncComplete(null);
+ this[_doneFuture][_asyncComplete](null);
}
}
}
@@ -1421,25 +1423,25 @@ var async;
[_sendData](data) {
for (let link = this[_next]; !dart.notNull(core.identical(link, this)); link = link[_next]) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- subscription._addPending(new _DelayedData(data));
+ subscription[_addPending](new _DelayedData(data));
}
}
[_sendError](error, stackTrace) {
for (let link = this[_next]; !dart.notNull(core.identical(link, this)); link = link[_next]) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- subscription._addPending(new _DelayedError(error, stackTrace));
+ subscription[_addPending](new _DelayedError(error, stackTrace));
}
}
[_sendDone]() {
if (!dart.notNull(this[_isEmpty])) {
for (let link = this[_next]; !dart.notNull(core.identical(link, this)); link = link[_next]) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- subscription._addPending(new _DelayedDone());
+ subscription[_addPending](new _DelayedDone());
}
} else {
dart.assert(this[_doneFuture] != null);
dart.assert(this[_doneFuture][_mayComplete]);
- this[_doneFuture]._asyncComplete(null);
+ this[_doneFuture][_asyncComplete](null);
}
}
}
@@ -1501,7 +1503,7 @@ var async;
this[_pending].clear();
this[_pending] = null;
}
- super._callOnCancel();
+ super[_callOnCancel]();
}
}
_AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)];
@@ -1568,13 +1570,14 @@ var async;
}
}
DeferredLoadException[dart.implements] = () => [core.Exception];
+ let _completeWithValue = Symbol('_completeWithValue');
let Future$ = dart.generic(function(T) {
class Future extends core.Object {
Future(computation) {
let result = new (_Future$(T))();
Timer.run((() => {
try {
- result._complete(computation());
+ result[_complete](computation());
} catch (e) {
let s = dart.stackTrace(e);
_completeWithErrorCallback(result, e, s);
@@ -1587,7 +1590,7 @@ var async;
let result = new (_Future$(T))();
scheduleMicrotask((() => {
try {
- result._complete(computation());
+ result[_complete](computation());
} catch (e) {
let s = dart.stackTrace(e);
_completeWithErrorCallback(result, e, s);
@@ -1630,7 +1633,7 @@ var async;
let result = new (_Future$(T))();
new Timer(duration, (() => {
try {
- result._complete(computation == null ? null : computation());
+ result[_complete](computation == null ? null : computation());
} catch (e) {
let s = dart.stackTrace(e);
_completeWithErrorCallback(result, e, s);
@@ -1662,13 +1665,13 @@ var async;
}
values = null;
if (remaining == 0 || dart.notNull(eagerError)) {
- result._completeError(theError, dart.as(theStackTrace, core.StackTrace));
+ result[_completeError](theError, dart.as(theStackTrace, core.StackTrace));
} else {
error = theError;
stackTrace = dart.as(theStackTrace, core.StackTrace);
}
} else if (remaining == 0 && !dart.notNull(eagerError)) {
- result._completeError(error, stackTrace);
+ result[_completeError](error, stackTrace);
}
}
for (let future of futures) {
@@ -1676,9 +1679,9 @@ var async;
future.then(((value) => {
remaining = dart.notNull(remaining) - 1;
if (values != null) {
- values.set(pos, value);
+ values[core.$set](pos, value);
if (remaining == 0) {
- result._completeWithValue(values);
+ result[_completeWithValue](values);
}
} else {
if (dart.notNull(cleanUp != null) && dart.notNull(value != null)) {
@@ -1687,7 +1690,7 @@ var async;
});
}
if (remaining == 0 && !dart.notNull(eagerError)) {
- result._completeError(error, stackTrace);
+ result[_completeError](error, stackTrace);
}
}
}).bind(this), {onError: handleError});
@@ -1699,7 +1702,7 @@ var async;
return result;
}
static forEach(input, f) {
- let iterator = input.iterator;
+ let iterator = input[core.$iterator];
return Future.doWhile((() => {
if (!dart.notNull(iterator.moveNext()))
return false;
@@ -1713,7 +1716,7 @@ var async;
if (keepGoing) {
new Future.sync(f).then(dart.as(nextIteration, dart.throw_("Unimplemented type (dynamic) → dynamic")), {onError: doneSignal[_completeError]});
} else {
- doneSignal._complete(null);
+ doneSignal[_complete](null);
}
}).bind(this), {runGuarded: true});
dart.dinvokef(nextIteration, true);
@@ -1770,7 +1773,7 @@ var async;
error = _nonNullError(replacement.error);
stackTrace = replacement.stackTrace;
}
- result._completeError(error, dart.as(stackTrace, core.StackTrace));
+ result[_completeError](error, dart.as(stackTrace, core.StackTrace));
}
// Function _nonNullError: (Object) → Object
function _nonNullError(error) {
@@ -1802,6 +1805,7 @@ var async;
return _Completer;
});
let _Completer = _Completer$(dart.dynamic);
+ let _asyncCompleteError = Symbol('_asyncCompleteError');
let _AsyncCompleter$ = dart.generic(function(T) {
class _AsyncCompleter extends _Completer$(T) {
complete(value) {
@@ -1809,10 +1813,10 @@ var async;
value = null;
if (!dart.notNull(this.future[_mayComplete]))
throw new core.StateError("Future already completed");
- this.future._asyncComplete(value);
+ this.future[_asyncComplete](value);
}
[_completeError](error, stackTrace) {
- this.future._asyncCompleteError(error, stackTrace);
+ this.future[_asyncCompleteError](error, stackTrace);
}
}
return _AsyncCompleter;
@@ -1825,10 +1829,10 @@ var async;
value = null;
if (!dart.notNull(this.future[_mayComplete]))
throw new core.StateError("Future already completed");
- this.future._complete(value);
+ this.future[_complete](value);
}
[_completeError](error, stackTrace) {
- this.future._completeError(error, stackTrace);
+ this.future[_completeError](error, stackTrace);
}
}
return _SyncCompleter;
@@ -1914,8 +1918,6 @@ var async;
_FutureListener.STATE_WHENCOMPLETE = _FutureListener.MASK_WHENCOMPLETE;
let _INCOMPLETE = Symbol('_INCOMPLETE');
let _resultOrListeners = Symbol('_resultOrListeners');
- let _asyncComplete = Symbol('_asyncComplete');
- let _asyncCompleteError = Symbol('_asyncCompleteError');
let _isChained = Symbol('_isChained');
let _CHAINED = Symbol('_CHAINED');
let _isComplete = Symbol('_isComplete');
@@ -1934,7 +1936,8 @@ var async;
let _removeListeners = Symbol('_removeListeners');
let _chainForeignFuture = Symbol('_chainForeignFuture');
let _chainCoreFuture = Symbol('_chainCoreFuture');
- let _completeWithValue = Symbol('_completeWithValue');
+ let _enter = Symbol('_enter');
+ let _leave = Symbol('_leave');
let _Future$ = dart.generic(function(T) {
class _Future extends core.Object {
_Future() {
@@ -2070,12 +2073,12 @@ var async;
target[_isChained] = true;
source.then(((value) => {
dart.assert(target[_isChained]);
- target._completeWithValue(value);
+ target[_completeWithValue](value);
}).bind(this), {onError: ((error, stackTrace) => {
if (stackTrace === void 0)
stackTrace = null;
dart.assert(target[_isChained]);
- target._completeError(error, dart.as(stackTrace, core.StackTrace));
+ target[_completeError](error, dart.as(stackTrace, core.StackTrace));
}).bind(this)});
}
static [_chainCoreFuture](source, target) {
@@ -2086,7 +2089,7 @@ var async;
if (source[_isComplete]) {
_Future[_propagateToListeners](source, listener);
} else {
- source._addListener(listener);
+ source[_addListener](listener);
}
}
[_complete](value) {
@@ -2183,7 +2186,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() {
@@ -2280,7 +2283,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.notNull(dart.is(listenerValueOrError, Future))) {
@@ -2302,12 +2305,12 @@ var async;
}
}
let result = listener.result;
- listeners = result._removeListeners();
+ listeners = result[_removeListeners]();
if (listenerHasValue) {
- result._setValue(listenerValueOrError);
+ result[_setValue](listenerValueOrError);
} else {
let asyncError = dart.as(listenerValueOrError, AsyncError);
- result._setErrorObject(asyncError);
+ result[_setErrorObject](asyncError);
}
source = result;
}
@@ -2320,17 +2323,17 @@ var async;
let timer = null;
if (onTimeout == null) {
timer = new Timer(timeLimit, (() => {
- result._completeError(new TimeoutException("Future not completed", timeLimit));
+ result[_completeError](new TimeoutException("Future not completed", timeLimit));
}).bind(this));
} else {
let zone = Zone.current;
onTimeout = zone.registerCallback(onTimeout);
timer = new Timer(timeLimit, (() => {
try {
- result._complete(zone.run(onTimeout));
+ result[_complete](zone.run(onTimeout));
} catch (e) {
let s = dart.stackTrace(e);
- result._completeError(e, s);
+ result[_completeError](e, s);
}
}).bind(this));
@@ -2338,12 +2341,12 @@ var async;
this.then(((v) => {
if (timer.isActive) {
timer.cancel();
- result._completeWithValue(v);
+ result[_completeWithValue](v);
}
}).bind(this), {onError: ((e, s) => {
if (timer.isActive) {
timer.cancel();
- result._completeError(e, dart.as(s, core.StackTrace));
+ result[_completeError](e, dart.as(s, core.StackTrace));
}
}).bind(this)});
return result;
@@ -2381,6 +2384,7 @@ var async;
entry.callback();
}
}
+ let _scheduleImmediate = Symbol('_scheduleImmediate');
// Function _asyncRunCallback: () → void
function _asyncRunCallback() {
exports._isInCallbackLoop = true;
@@ -2390,7 +2394,7 @@ var async;
exports._lastPriorityCallback = null;
exports._isInCallbackLoop = false;
if (exports._nextCallback != null)
- _AsyncRun._scheduleImmediate(_asyncRunCallback);
+ _AsyncRun[_scheduleImmediate](_asyncRunCallback);
}
}
// Function _scheduleAsyncCallback: (dynamic) → void
@@ -2398,7 +2402,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));
@@ -2432,11 +2436,11 @@ var async;
}
Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuarded: true}));
}
- let _scheduleImmediate = Symbol('_scheduleImmediate');
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) {
dart.dinvokef(_AsyncRun.scheduleImmediateClosure, callback);
@@ -2492,7 +2496,7 @@ var async;
self.setImmediate(_js_helper.convertDartClosureToJS(internalCallback, 0));
}
static [_scheduleImmediateWithTimer](callback) {
- Timer._createTimer(core.Duration.ZERO, callback);
+ Timer[_createTimer](core.Duration.ZERO, callback);
}
}
dart.defineLazyProperties(_AsyncRun, {
@@ -2639,7 +2643,6 @@ var async;
let _ensurePendingEvents = Symbol('_ensurePendingEvents');
let _badEventState = Symbol('_badEventState');
let _nullFuture = Symbol('_nullFuture');
- let _closeUnchecked = Symbol('_closeUnchecked');
let _StreamController$ = dart.generic(function(T) {
class _StreamController extends core.Object {
_StreamController() {
@@ -2799,8 +2802,8 @@ var async;
} else {
this[_varData] = subscription;
}
- subscription._setPendingEvents(pendingEvents);
- subscription._guardCallback((() => {
+ subscription[_setPendingEvents](pendingEvents);
+ subscription[_guardCallback]((() => {
_runGuarded(this[_onListen]);
}).bind(this));
return dart.as(subscription, StreamSubscription$(T));
@@ -2820,7 +2823,7 @@ var async;
} catch (e) {
let s = dart.stackTrace(e);
result = ((_$) => {
- _$._asyncCompleteError(e, s);
+ _$[_asyncCompleteError](e, s);
return _$;
}).bind(this)(new _Future());
}
@@ -2832,7 +2835,7 @@ var async;
// Function complete: () → void
function complete() {
if (dart.notNull(this[_doneFuture] != null) && dart.notNull(this[_doneFuture][_mayComplete])) {
- this[_doneFuture]._asyncComplete(null);
+ this[_doneFuture][_asyncComplete](null);
}
}
if (result != null) {
@@ -2870,13 +2873,13 @@ var async;
let _SyncStreamControllerDispatch$ = dart.generic(function(T) {
class _SyncStreamControllerDispatch extends core.Object {
[_sendData](data) {
- this[_subscription]._add(data);
+ this[_subscription][_add](data);
}
[_sendError](error, stackTrace) {
- this[_subscription]._addError(error, stackTrace);
+ this[_subscription][_addError](error, stackTrace);
}
[_sendDone]() {
- this[_subscription]._close();
+ this[_subscription][_close]();
}
}
_SyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(T)];
@@ -2886,13 +2889,13 @@ var async;
let _AsyncStreamControllerDispatch$ = dart.generic(function(T) {
class _AsyncStreamControllerDispatch extends core.Object {
[_sendData](data) {
- this[_subscription]._addPending(new _DelayedData(data));
+ this[_subscription][_addPending](new _DelayedData(data));
}
[_sendError](error, stackTrace) {
- this[_subscription]._addPending(new _DelayedError(error, stackTrace));
+ this[_subscription][_addPending](new _DelayedError(error, stackTrace));
}
[_sendDone]() {
- this[_subscription]._addPending(new _DelayedDone());
+ this[_subscription][_addPending](new _DelayedDone());
}
}
_AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(T)];
@@ -2995,8 +2998,8 @@ var async;
}
static makeErrorHandler(controller) {
return ((e, s) => {
- controller._addError(e, s);
- controller._close();
+ controller[_addError](e, s);
+ controller[_close]();
}).bind(this);
}
pause() {
@@ -3008,15 +3011,15 @@ var async;
cancel() {
let cancel = this.addSubscription.cancel();
if (cancel == null) {
- this.addStreamFuture._asyncComplete(null);
+ this.addStreamFuture[_asyncComplete](null);
return null;
}
return cancel.whenComplete((() => {
- this.addStreamFuture._asyncComplete(null);
+ this.addStreamFuture[_asyncComplete](null);
}).bind(this));
}
complete() {
- this.addStreamFuture._asyncComplete(null);
+ this.addStreamFuture[_asyncComplete](null);
}
}
return _AddStreamState;
@@ -3060,7 +3063,7 @@ var async;
throw new core.StateError("Stream has already been listened to.");
this[_isUsed] = true;
return ((_$) => {
- _$._setPendingEvents(this[_pending]());
+ _$[_setPendingEvents](this[_pending]());
return _$;
}).bind(this)(new _BufferingStreamSubscription(onData, onError, onDone, cancelOnError));
}
@@ -3111,7 +3114,7 @@ var async;
let _IterablePendingEvents$ = dart.generic(function(T) {
class _IterablePendingEvents extends _PendingEvents {
_IterablePendingEvents(data) {
- this[_iterator] = data.iterator;
+ this[_iterator] = data[core.$iterator];
super._PendingEvents();
}
get isEmpty() {
@@ -3127,15 +3130,15 @@ var async;
} catch (e) {
let s = dart.stackTrace(e);
this[_iterator] = null;
- dispatch._sendError(e, s);
+ dispatch[_sendError](e, s);
return;
}
if (!dart.notNull(isDone)) {
- dispatch._sendData(this[_iterator].current);
+ dispatch[_sendData](this[_iterator].current);
} else {
this[_iterator] = null;
- dispatch._sendDone();
+ dispatch[_sendDone]();
}
}
clear() {
@@ -3171,7 +3174,7 @@ var async;
super._DelayedEvent();
}
perform(dispatch) {
- dispatch._sendData(this.value);
+ dispatch[_sendData](this.value);
}
}
return _DelayedData;
@@ -3184,14 +3187,14 @@ var async;
super._DelayedEvent();
}
perform(dispatch) {
- dispatch._sendError(this.error, this.stackTrace);
+ dispatch[_sendError](this.error, this.stackTrace);
}
}
class _DelayedDone extends core.Object {
_DelayedDone() {
}
perform(dispatch) {
- dispatch._sendDone();
+ dispatch[_sendDone]();
}
get next() {
return null;
@@ -3309,7 +3312,7 @@ var async;
futureValue = null;
let result = new _Future();
this[_onDone] = (() => {
- result._completeWithValue(null);
+ result[_completeWithValue](null);
}).bind(this);
return result;
}
@@ -3362,7 +3365,7 @@ var async;
this[_subscription] = this[_source].listen(this[_controller].add, {onError: this[_controller].addError, onDone: this[_controller].close});
}
cancelOnError = core.identical(true, cancelOnError);
- return this[_controller]._subscribe(onData, onError, onDone, cancelOnError);
+ return this[_controller][_subscribe](onData, onError, onDone, cancelOnError);
}
[_onCancel]() {
let shutdown = dart.notNull(this[_controller] == null) || dart.notNull(this[_controller].isClosed);
@@ -3425,13 +3428,13 @@ var async;
pause(resumeSignal) {
if (resumeSignal === void 0)
resumeSignal = null;
- this[_stream]._pauseSubscription(resumeSignal);
+ this[_stream][_pauseSubscription](resumeSignal);
}
resume() {
- this[_stream]._resumeSubscription();
+ this[_stream][_resumeSubscription]();
}
cancel() {
- this[_stream]._cancelSubscription();
+ this[_stream][_cancelSubscription]();
return null;
}
get isPaused() {
@@ -3516,7 +3519,7 @@ var async;
if (this[_state] == _StreamIteratorImpl[_STATE_MOVING]) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_clear]();
- hasNext._complete(false);
+ hasNext[_complete](false);
} else {
this[_clear]();
}
@@ -3528,7 +3531,7 @@ var async;
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_futureOrPrefetch] = null;
this[_state] = _StreamIteratorImpl[_STATE_FOUND];
- hasNext._complete(true);
+ hasNext[_complete](true);
return;
}
this[_subscription].pause();
@@ -3542,7 +3545,7 @@ var async;
if (this[_state] == _StreamIteratorImpl[_STATE_MOVING]) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_clear]();
- hasNext._completeError(error, stackTrace);
+ hasNext[_completeError](error, stackTrace);
return;
}
this[_subscription].pause();
@@ -3554,7 +3557,7 @@ var async;
if (this[_state] == _StreamIteratorImpl[_STATE_MOVING]) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_clear]();
- hasNext._complete(false);
+ hasNext[_complete](false);
return;
}
this[_subscription].pause();
@@ -3593,9 +3596,9 @@ var async;
function _cancelAndError(subscription, future, error, stackTrace) {
let cancelFuture = subscription.cancel();
if (dart.is(cancelFuture, Future)) {
- cancelFuture.whenComplete(() => future._completeError(error, stackTrace));
+ cancelFuture.whenComplete(() => future[_completeError](error, stackTrace));
} else {
- future._completeError(error, stackTrace);
+ future[_completeError](error, stackTrace);
}
}
// Function _cancelAndErrorWithReplacement: (StreamSubscription<dynamic>, _Future<dynamic>, dynamic, StackTrace) → void
@@ -3615,9 +3618,9 @@ var async;
function _cancelAndValue(subscription, future, value) {
let cancelFuture = subscription.cancel();
if (dart.is(cancelFuture, Future)) {
- cancelFuture.whenComplete(() => future._complete(value));
+ cancelFuture.whenComplete(() => future[_complete](value));
} else {
- future._complete(value);
+ future[_complete](value);
}
}
let _handleData = Symbol('_handleData');
@@ -3644,13 +3647,13 @@ var async;
}
[_handleData](data, sink) {
let outputData = data;
- sink._add(outputData);
+ sink[_add](outputData);
}
[_handleError](error, stackTrace, sink) {
- sink._addError(error, stackTrace);
+ sink[_addError](error, stackTrace);
}
[_handleDone](sink) {
- sink._close();
+ sink[_close]();
}
}
return _ForwardingStream;
@@ -3667,12 +3670,12 @@ var async;
[_add](data) {
if (this[_isClosed])
return;
- super._add(data);
+ super[_add](data);
}
[_addError](error, stackTrace) {
if (this[_isClosed])
return;
- super._addError(error, stackTrace);
+ super[_addError](error, stackTrace);
}
[_onPause]() {
if (this[_subscription] == null)
@@ -3693,13 +3696,13 @@ var async;
return null;
}
[_handleData](data) {
- this[_stream]._handleData(data, this);
+ this[_stream][_handleData](data, this);
}
[_handleError](error, stackTrace) {
- this[_stream]._handleError(error, stackTrace, this);
+ this[_stream][_handleError](error, stackTrace, this);
}
[_handleDone]() {
- this[_stream]._handleDone(this);
+ this[_stream][_handleDone](this);
}
}
return _ForwardingStreamSubscription;
@@ -3712,7 +3715,7 @@ var async;
error = _nonNullError(replacement.error);
stackTrace = replacement.stackTrace;
}
- sink._addError(error, dart.as(stackTrace, core.StackTrace));
+ sink[_addError](error, dart.as(stackTrace, core.StackTrace));
}
let _test = Symbol('_test');
let _WhereStream$ = dart.generic(function(T) {
@@ -3732,7 +3735,7 @@ var async;
}
if (satisfies) {
- sink._add(inputEvent);
+ sink[_add](inputEvent);
}
}
}
@@ -3756,7 +3759,7 @@ var async;
return;
}
- sink._add(outputEvent);
+ sink[_add](outputEvent);
}
}
return _MapStream;
@@ -3772,7 +3775,7 @@ var async;
[_handleData](inputEvent, sink) {
try {
for (let value of this[_expand](inputEvent)) {
- sink._add(value);
+ sink[_add](value);
}
} catch (e) {
let s = dart.stackTrace(e);
@@ -3809,7 +3812,7 @@ var async;
} catch (e) {
let s = dart.stackTrace(e);
if (core.identical(e, error)) {
- sink._addError(error, stackTrace);
+ sink[_addError](error, stackTrace);
} else {
_addErrorWithReplacement(sink, e, s);
}
@@ -3817,7 +3820,7 @@ var async;
}
} else {
- sink._addError(error, stackTrace);
+ sink[_addError](error, stackTrace);
}
}
}
@@ -3835,10 +3838,10 @@ var async;
}
[_handleData](inputEvent, sink) {
if (dart.notNull(this[_remaining]) > 0) {
- sink._add(inputEvent);
+ sink[_add](inputEvent);
this[_remaining] = 1;
if (this[_remaining] == 0) {
- sink._close();
+ sink[_close]();
}
}
}
@@ -3859,14 +3862,14 @@ var async;
} catch (e) {
let s = dart.stackTrace(e);
_addErrorWithReplacement(sink, e, s);
- sink._close();
+ sink[_close]();
return;
}
if (satisfies) {
- sink._add(inputEvent);
+ sink[_add](inputEvent);
} else {
- sink._close();
+ sink[_close]();
}
}
}
@@ -3886,7 +3889,7 @@ var async;
this[_remaining] = dart.notNull(this[_remaining]) - 1;
return;
}
- sink._add(inputEvent);
+ sink[_add](inputEvent);
}
}
return _SkipStream;
@@ -3902,7 +3905,7 @@ var async;
}
[_handleData](inputEvent, sink) {
if (this[_hasFailed]) {
- sink._add(inputEvent);
+ sink[_add](inputEvent);
return;
}
let satisfies = null;
@@ -3917,7 +3920,7 @@ var async;
if (!dart.notNull(satisfies)) {
this[_hasFailed] = true;
- sink._add(inputEvent);
+ sink[_add](inputEvent);
}
}
}
@@ -3936,7 +3939,7 @@ var async;
[_handleData](inputEvent, sink) {
if (core.identical(this[_previous], _DistinctStream[_SENTINEL])) {
this[_previous] = inputEvent;
- return sink._add(inputEvent);
+ return sink[_add](inputEvent);
} else {
let isEqual = null;
try {
@@ -3952,7 +3955,7 @@ var async;
}
if (!dart.notNull(isEqual)) {
- sink._add(inputEvent);
+ sink[_add](inputEvent);
this[_previous] = inputEvent;
}
}
@@ -3973,15 +3976,15 @@ var async;
this[_sink] = sink$;
}
add(data) {
- this[_sink]._add(data);
+ this[_sink][_add](data);
}
addError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- this[_sink]._addError(error, stackTrace);
+ this[_sink][_addError](error, stackTrace);
}
close() {
- this[_sink]._close();
+ this[_sink][_close]();
}
}
_EventSinkWrapper[dart.implements] = () => [EventSink$(T)];
@@ -4007,19 +4010,19 @@ var async;
if (this[_isClosed]) {
throw new core.StateError("Stream is already closed");
}
- super._add(data);
+ super[_add](data);
}
[_addError](error, stackTrace) {
if (this[_isClosed]) {
throw new core.StateError("Stream is already closed");
}
- super._addError(error, stackTrace);
+ super[_addError](error, stackTrace);
}
[_close]() {
if (this[_isClosed]) {
throw new core.StateError("Stream is already closed");
}
- super._close();
+ super[_close]();
}
[_onPause]() {
if (this[_isSubscribed])
@@ -4206,7 +4209,6 @@ var async;
return _BoundSubscriptionStream;
});
let _BoundSubscriptionStream = _BoundSubscriptionStream$(dart.dynamic, dart.dynamic);
- let _createTimer = Symbol('_createTimer');
let _createPeriodicTimer = Symbol('_createPeriodicTimer');
class Timer extends core.Object {
Timer(duration, callback) {
@@ -4300,8 +4302,6 @@ var async;
class ZoneDelegate extends core.Object {
}
let _$ = Symbol('_');
- let _enter = Symbol('_enter');
- let _leave = Symbol('_leave');
class Zone extends core.Object {
[_$]() {
}
@@ -4629,33 +4629,33 @@ var async;
function _rootRun(self, parent, zone, f) {
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))
return dart.dinvokef(f, arg);
- let old = Zone._enter(zone);
+ let old = Zone[_enter](zone);
try {
return dart.dinvokef(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))
return dart.dinvokef(f, arg1, arg2);
- let old = Zone._enter(zone);
+ let old = Zone[_enter](zone);
try {
return dart.dinvokef(f, arg1, arg2);
} finally {
- Zone._leave(old);
+ Zone[_leave](old);
}
}
// Function _rootRegisterCallback: (Zone, ZoneDelegate, Zone, () → dynamic) → ZoneCallback
@@ -4687,14 +4687,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.closureWrap(zone.bindUnaryCallback(callback), "(Timer) → void");
}
- return Timer._createPeriodicTimer(duration, callback);
+ return Timer[_createPeriodicTimer](duration, callback);
}
// Function _rootPrint: (Zone, ZoneDelegate, Zone, String) → void
function _rootPrint(self, parent, zone, line) {
@@ -4927,10 +4927,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);
« 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