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

Issues Search
    My Issues | Starred     Open | Closed | All

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

Issue 1147143007: fixes #206, add checking for unary ops (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: merged Created 5 years, 6 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 f6198151b0e98b895843d26a7ce710d060845a10..8a226ac94581add794b5302a26563b43a152cd8e 100644
--- a/lib/runtime/dart/async.js
+++ b/lib/runtime/dart/async.js
@@ -184,7 +184,7 @@ var collection = dart.import(collection);
}, core.Object, [T]), {onError: dart.as(addError, core.Function), onDone: dart.bind(controller, 'close')});
};
dart.fn(onListen, dart.void, []);
- if (this.isBroadcast) {
+ if (dart.notNull(this.isBroadcast)) {
controller = StreamController.broadcast({onListen: onListen, onCancel: dart.fn(() => {
subscription.cancel();
}), sync: true});
@@ -224,7 +224,7 @@ var collection = dart.import(collection);
}, core.Object, [T]), {onError: dart.as(eventSink[_addError], core.Function), onDone: dart.bind(controller, 'close')});
};
dart.fn(onListen, dart.void, []);
- if (this.isBroadcast) {
+ if (dart.notNull(this.isBroadcast)) {
controller = StreamController.broadcast({onListen: onListen, onCancel: dart.fn(() => {
subscription.cancel();
}), sync: true});
@@ -264,7 +264,7 @@ var collection = dart.import(collection);
let subscription = null;
subscription = this.listen(dart.fn(element => {
dart.as(element, T);
- if (seenFirst) {
+ if (dart.notNull(seenFirst)) {
_runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(newValue => {
dart.as(newValue, T);
value = newValue;
@@ -338,7 +338,7 @@ var collection = dart.import(collection);
subscription = this.listen(dart.fn(element => {
dart.as(element, T);
_runUserCode(dart.fn(() => dart.equals(element, needle), core.bool, []), dart.fn(isMatch => {
- if (isMatch) {
+ if (dart.notNull(isMatch)) {
_cancelAndValue(subscription, future, true);
}
}, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace])));
@@ -383,7 +383,7 @@ var collection = dart.import(collection);
subscription = this.listen(dart.fn(element => {
dart.as(element, T);
_runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMatch => {
- if (isMatch) {
+ if (dart.notNull(isMatch)) {
_cancelAndValue(subscription, future, true);
}
}, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace])));
@@ -486,7 +486,7 @@ var collection = dart.import(collection);
foundResult = true;
result = value;
}, core.Object, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- if (foundResult) {
+ if (dart.notNull(foundResult)) {
future[_complete](result);
return;
}
@@ -507,7 +507,7 @@ var collection = dart.import(collection);
let subscription = null;
subscription = this.listen(dart.fn(value => {
dart.as(value, T);
- if (foundResult) {
+ if (dart.notNull(foundResult)) {
try {
throw _internal.IterableElementError.tooMany();
} catch (e) {
@@ -520,7 +520,7 @@ var collection = dart.import(collection);
foundResult = true;
result = value;
}, core.Object, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- if (foundResult) {
+ if (dart.notNull(foundResult)) {
future[_complete](result);
return;
}
@@ -543,7 +543,7 @@ var collection = dart.import(collection);
subscription = this.listen(dart.fn(value => {
dart.as(value, T);
_runUserCode(dart.fn(() => test(value), core.bool, []), dart.fn(isMatch => {
- if (isMatch) {
+ if (dart.notNull(isMatch)) {
_cancelAndValue(subscription, future, value);
}
}, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace])));
@@ -573,13 +573,13 @@ var collection = dart.import(collection);
subscription = this.listen(dart.fn(value => {
dart.as(value, T);
_runUserCode(dart.fn(() => true == test(value), core.bool, []), dart.fn(isMatch => {
- if (isMatch) {
+ if (dart.notNull(isMatch)) {
foundResult = true;
result = value;
}
}, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace])));
}, core.Object, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- if (foundResult) {
+ if (dart.notNull(foundResult)) {
future[_complete](result);
return;
}
@@ -606,8 +606,8 @@ var collection = dart.import(collection);
subscription = this.listen(dart.fn(value => {
dart.as(value, T);
_runUserCode(dart.fn(() => true == test(value), core.bool, []), dart.fn(isMatch => {
- if (isMatch) {
- if (foundResult) {
+ if (dart.notNull(isMatch)) {
+ if (dart.notNull(foundResult)) {
try {
throw _internal.IterableElementError.tooMany();
} catch (e) {
@@ -622,7 +622,7 @@ var collection = dart.import(collection);
}
}, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace])));
}, core.Object, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- if (foundResult) {
+ if (dart.notNull(foundResult)) {
future[_complete](result);
return;
}
@@ -708,7 +708,7 @@ var collection = dart.import(collection);
return result;
};
dart.fn(onCancel, Future, []);
- controller = this.isBroadcast ? new _SyncBroadcastStreamController(onListen, onCancel) : new _SyncStreamController(onListen, dart.fn(() => {
+ controller = dart.notNull(this.isBroadcast) ? new _SyncBroadcastStreamController(onListen, onCancel) : new _SyncStreamController(onListen, dart.fn(() => {
timer.cancel();
subscription.pause();
}), dart.fn(() => {
@@ -812,7 +812,7 @@ var collection = dart.import(collection);
return dart.notNull(dart.hashCode(this[_controller])) ^ 892482866;
}
['=='](other) {
- if (core.identical(this, other))
+ if (dart.notNull(core.identical(this, other)))
return true;
if (!dart.is(other, _ControllerStream$()))
return false;
@@ -889,7 +889,7 @@ var collection = dart.import(collection);
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] = dart.notNull(cancelOnError) ? _BufferingStreamSubscription$()._STATE_CANCEL_ON_ERROR : 0;
this[_onData] = null;
this[_onError] = null;
this[_onDone] = null;
@@ -935,22 +935,22 @@ var collection = dart.import(collection);
pause(resumeSignal) {
if (resumeSignal === void 0)
resumeSignal = null;
- if (this[_isCanceled])
+ if (dart.notNull(this[_isCanceled]))
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);
if (resumeSignal != null)
resumeSignal.whenComplete(dart.bind(this, 'resume'));
- if (!dart.notNull(wasPaused) && dart.notNull(this[_pending] != null))
+ if (!dart.notNull(wasPaused) && this[_pending] != null)
this[_pending].cancelSchedule();
if (!dart.notNull(wasInputPaused) && !dart.notNull(this[_inCallback]))
this[_guardCallback](dart.bind(this, _onPause));
}
resume() {
- if (this[_isCanceled])
+ if (dart.notNull(this[_isCanceled]))
return;
- if (this[_isPaused]) {
+ if (dart.notNull(this[_isPaused])) {
this[_decrementPauseCount]();
if (!dart.notNull(this[_isPaused])) {
if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_pending].isEmpty)) {
@@ -966,7 +966,7 @@ var collection = dart.import(collection);
}
cancel() {
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription$()._STATE_WAIT_FOR_CANCEL);
- if (this[_isCanceled])
+ if (dart.notNull(this[_isCanceled]))
return this[_cancelFuture];
this[_cancel]();
return this[_cancelFuture];
@@ -1009,7 +1009,7 @@ var collection = dart.import(collection);
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));
+ return !dart.notNull(this[_isPaused]) && (this[_pending] == null || dart.notNull(this[_pending].isEmpty));
}
get [_cancelOnError]() {
return (dart.notNull(this[_state]) & dart.notNull(_BufferingStreamSubscription$()._STATE_CANCEL_ON_ERROR)) != 0;
@@ -1019,7 +1019,7 @@ var collection = dart.import(collection);
}
[_cancel]() {
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_CANCELED);
- if (this[_hasPending]) {
+ if (dart.notNull(this[_hasPending])) {
this[_pending].cancelSchedule();
}
if (!dart.notNull(this[_inCallback]))
@@ -1036,18 +1036,18 @@ var collection = dart.import(collection);
[_add](data) {
dart.as(data, T);
dart.assert(!dart.notNull(this[_isClosed]));
- if (this[_isCanceled])
+ if (dart.notNull(this[_isCanceled]))
return;
- if (this[_canFire]) {
+ if (dart.notNull(this[_canFire])) {
this[_sendData](data);
} else {
this[_addPending](new _DelayedData(data));
}
}
[_addError](error, stackTrace) {
- if (this[_isCanceled])
+ if (dart.notNull(this[_isCanceled]))
return;
- if (this[_canFire]) {
+ if (dart.notNull(this[_canFire])) {
this[_sendError](error, stackTrace);
} else {
this[_addPending](new _DelayedError(error, stackTrace));
@@ -1055,10 +1055,10 @@ var collection = dart.import(collection);
}
[_close]() {
dart.assert(!dart.notNull(this[_isClosed]));
- if (this[_isCanceled])
+ if (dart.notNull(this[_isCanceled]))
return;
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_CLOSED);
- if (this[_canFire]) {
+ if (dart.notNull(this[_canFire])) {
this[_sendDone]();
} else {
this[_addPending](dart.const(new _DelayedDone()));
@@ -1114,7 +1114,7 @@ var collection = dart.import(collection);
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription$()._STATE_IN_CALLBACK);
};
dart.fn(sendError, dart.void, []);
- if (this[_cancelOnError]) {
+ if (dart.notNull(this[_cancelOnError])) {
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_WAIT_FOR_CANCEL);
this[_cancel]();
if (dart.is(this[_cancelFuture], Future)) {
@@ -1164,7 +1164,7 @@ var collection = dart.import(collection);
}
}
while (true) {
- if (this[_isCanceled]) {
+ if (dart.notNull(this[_isCanceled])) {
this[_pending] = null;
return;
}
@@ -1172,7 +1172,7 @@ var collection = dart.import(collection);
if (wasInputPaused == isInputPaused)
break;
this[_state] = dart.notNull(this[_state]) ^ dart.notNull(_BufferingStreamSubscription$()._STATE_IN_CALLBACK);
- if (isInputPaused) {
+ if (dart.notNull(isInputPaused)) {
this[_onPause]();
} else {
this[_onResume]();
@@ -1379,24 +1379,24 @@ var collection = dart.import(collection);
[_subscribe](onData, onError, onDone, cancelOnError) {
dart.as(onData, dart.functionType(dart.void, [T]));
dart.as(onDone, dart.functionType(dart.void, []));
- if (this.isClosed) {
+ if (dart.notNull(this.isClosed)) {
if (onDone == null)
onDone = _nullDoneHandler;
return new (_DoneStreamSubscription$(T))(onDone);
}
let subscription = new (_BroadcastSubscription$(T))(this, onData, onError, onDone, cancelOnError);
this[_addListener](dart.as(subscription, _BroadcastSubscription$(T)));
- if (core.identical(this[_next], this[_previous])) {
+ if (dart.notNull(core.identical(this[_next], this[_previous]))) {
_runGuarded(this[_onListen]);
}
return dart.as(subscription, StreamSubscription$(T));
}
[_recordCancel](subscription) {
dart.as(subscription, StreamSubscription$(T));
- if (core.identical(subscription[_next], subscription))
+ if (dart.notNull(core.identical(subscription[_next], subscription)))
return null;
dart.assert(!dart.notNull(core.identical(subscription[_next], subscription)));
- if (subscription[_isFiring]) {
+ if (dart.notNull(dart.as(subscription[_isFiring], core.bool))) {
dart.dcall(subscription[_setRemoveAfterFiring]);
} else {
dart.assert(!dart.notNull(core.identical(subscription[_next], subscription)));
@@ -1414,7 +1414,7 @@ var collection = dart.import(collection);
dart.as(subscription, StreamSubscription$(T));
}
[_addEventError]() {
- if (this.isClosed) {
+ if (dart.notNull(this.isClosed)) {
return new core.StateError("Cannot add new events after calling close");
}
dart.assert(this[_isAddingStream]);
@@ -1440,7 +1440,7 @@ var collection = dart.import(collection);
this[_sendError](error, stackTrace);
}
close() {
- if (this.isClosed) {
+ if (dart.notNull(this.isClosed)) {
dart.assert(this[_doneFuture] != null);
return this[_doneFuture];
}
@@ -1479,22 +1479,22 @@ var collection = dart.import(collection);
}
[_forEachListener](action) {
dart.as(action, dart.functionType(dart.void, [_BufferingStreamSubscription$(T)]));
- if (this[_isFiring]) {
+ if (dart.notNull(this[_isFiring])) {
throw new core.StateError("Cannot fire new event. Controller is already firing an event");
}
- if (this[_isEmpty])
+ if (dart.notNull(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 link = this[_next];
while (!dart.notNull(core.identical(link, this))) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- if (subscription[_expectsEvent](id)) {
+ if (dart.notNull(subscription[_expectsEvent](id))) {
subscription[_eventState] = dart.notNull(subscription[_eventState]) | dart.notNull(_BroadcastSubscription._STATE_FIRING);
action(subscription);
subscription[_toggleEventId]();
link = subscription[_next];
- if (subscription[_removeAfterFiring]) {
+ if (dart.notNull(subscription[_removeAfterFiring])) {
this[_removeListener](subscription);
}
subscription[_eventState] = dart.notNull(subscription[_eventState]) & ~dart.notNull(_BroadcastSubscription._STATE_FIRING);
@@ -1503,7 +1503,7 @@ var collection = dart.import(collection);
}
}
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController$()._STATE_FIRING);
- if (this[_isEmpty]) {
+ if (dart.notNull(this[_isEmpty])) {
this[_callOnCancel]();
}
}
@@ -1553,14 +1553,14 @@ var collection = dart.import(collection);
}
[_sendData](data) {
dart.as(data, T);
- if (this[_isEmpty])
+ if (dart.notNull(this[_isEmpty]))
return;
- if (this[_hasOneListener]) {
+ if (dart.notNull(this[_hasOneListener])) {
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);
- if (this[_isEmpty]) {
+ if (dart.notNull(this[_isEmpty])) {
this[_callOnCancel]();
}
return;
@@ -1571,7 +1571,7 @@ var collection = dart.import(collection);
}, core.Object, [_BufferingStreamSubscription$(T)]));
}
[_sendError](error, stackTrace) {
- if (this[_isEmpty])
+ if (dart.notNull(this[_isEmpty]))
return;
this[_forEachListener](dart.fn(subscription => {
dart.as(subscription, _BufferingStreamSubscription$(T));
@@ -1652,7 +1652,7 @@ var collection = dart.import(collection);
super._SyncBroadcastStreamController(onListen, onCancel);
}
get [_hasPending]() {
- return dart.notNull(this[_pending] != null) && !dart.notNull(this[_pending].isEmpty);
+ return this[_pending] != null && !dart.notNull(this[_pending].isEmpty);
}
[_addPendingEvent](event) {
if (this[_pending] == null) {
@@ -1667,7 +1667,7 @@ var collection = dart.import(collection);
return;
}
super.add(data);
- while (this[_hasPending]) {
+ while (dart.notNull(this[_hasPending])) {
this[_pending].handleNext(this);
}
}
@@ -1681,7 +1681,7 @@ var collection = dart.import(collection);
if (!dart.notNull(this[_mayAddEvent]))
throw this[_addEventError]();
this[_sendError](error, stackTrace);
- while (this[_hasPending]) {
+ while (dart.notNull(this[_hasPending])) {
this[_pending].handleNext(this);
}
}
@@ -1696,7 +1696,7 @@ var collection = dart.import(collection);
return result;
}
[_callOnCancel]() {
- if (this[_hasPending]) {
+ if (dart.notNull(this[_hasPending])) {
this[_pending].clear();
this[_pending] = null;
}
@@ -1919,7 +1919,7 @@ var collection = dart.import(collection);
result[_completeWithValue](values);
}
} else {
- if (dart.notNull(cleanUp != null) && dart.notNull(value != null)) {
+ if (cleanUp != null && value != null) {
Future$().sync(dart.fn(() => {
dart.dcall(cleanUp, value);
}));
@@ -1950,7 +1950,7 @@ var collection = dart.import(collection);
let doneSignal = new _Future();
let nextIteration = null;
nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => {
- if (keepGoing) {
+ if (dart.notNull(keepGoing)) {
Future$().sync(f).then(dart.as(nextIteration, __CastType4), {onError: dart.bind(doneSignal, _completeError)});
} else {
doneSignal[_complete](null);
@@ -2258,7 +2258,7 @@ var collection = dart.import(collection);
return this[_state] == _Future$()._ERROR;
}
set [_isChained](value) {
- if (value) {
+ if (dart.notNull(value)) {
dart.assert(!dart.notNull(this[_isComplete]));
this[_state] = _Future$()._CHAINED;
} else {
@@ -2332,7 +2332,7 @@ var collection = dart.import(collection);
}
[_addListener](listener) {
dart.assert(listener[_nextListener] == null);
- if (this[_isComplete]) {
+ if (dart.notNull(this[_isComplete])) {
this[_zone].scheduleMicrotask(dart.fn(() => {
_Future$()._propagateToListeners(this, listener);
}));
@@ -2373,7 +2373,7 @@ var collection = dart.import(collection);
dart.assert(dart.is(source, _Future$()));
target[_isChained] = true;
let listener = new _FutureListener.chain(target);
- if (source[_isComplete]) {
+ if (dart.notNull(source[_isComplete])) {
_Future$()._propagateToListeners(source, listener);
} else {
source[_addListener](listener);
@@ -2447,7 +2447,7 @@ var collection = dart.import(collection);
dart.assert(source[_isComplete]);
let hasError = source[_hasError];
if (listeners == null) {
- if (hasError) {
+ if (dart.notNull(hasError)) {
let asyncError = source[_error];
source[_zone].handleUncaughtError(asyncError.error, asyncError.stackTrace);
}
@@ -2461,7 +2461,7 @@ var collection = dart.import(collection);
}
let listener = listeners;
let listenerHasValue = true;
- let sourceValue = hasError ? null : source[_value];
+ let sourceValue = dart.notNull(hasError) ? null : source[_value];
let listenerValueOrError = sourceValue;
let isPropagationAborted = false;
if (dart.notNull(hasError) || dart.notNull(listener.handlesValue) || dart.notNull(listener.handlesComplete)) {
@@ -2490,20 +2490,20 @@ var collection = dart.import(collection);
let handleError = () => {
let asyncError = source[_error];
let matchesTest = true;
- if (listener.hasErrorTest) {
+ if (dart.notNull(listener.hasErrorTest)) {
let test = listener[_errorTest];
try {
matchesTest = dart.as(zone.runUnary(test, asyncError.error), core.bool);
} catch (e) {
let s = dart.stackTrace(e);
- listenerValueOrError = core.identical(asyncError.error, e) ? asyncError : new AsyncError(e, s);
+ listenerValueOrError = dart.notNull(core.identical(asyncError.error, e)) ? asyncError : new AsyncError(e, s);
listenerHasValue = false;
return;
}
}
let errorCallback = listener[_onError];
- if (dart.notNull(matchesTest) && dart.notNull(errorCallback != null)) {
+ if (dart.notNull(matchesTest) && errorCallback != null) {
try {
if (dart.is(errorCallback, ZoneBinaryCallback)) {
listenerValueOrError = zone.runBinary(errorCallback, asyncError.error, asyncError.stackTrace);
@@ -2512,7 +2512,7 @@ var collection = dart.import(collection);
}
} catch (e) {
let s = dart.stackTrace(e);
- listenerValueOrError = core.identical(asyncError.error, e) ? asyncError : new AsyncError(e, s);
+ listenerValueOrError = dart.notNull(core.identical(asyncError.error, e)) ? asyncError : new AsyncError(e, s);
listenerHasValue = false;
return;
}
@@ -2558,24 +2558,24 @@ var collection = dart.import(collection);
};
dart.fn(handleWhenCompleteCallback, dart.void, []);
if (!dart.notNull(hasError)) {
- if (listener.handlesValue) {
+ if (dart.notNull(listener.handlesValue)) {
listenerHasValue = handleValueCallback();
}
} else {
handleError();
}
- if (listener.handlesComplete) {
+ if (dart.notNull(listener.handlesComplete)) {
handleWhenCompleteCallback();
}
if (oldZone != null)
Zone._leave(oldZone);
- if (isPropagationAborted)
+ if (dart.notNull(isPropagationAborted))
return;
if (dart.notNull(listenerHasValue) && !dart.notNull(core.identical(sourceValue, listenerValueOrError)) && dart.is(listenerValueOrError, Future)) {
let chainSource = dart.as(listenerValueOrError, Future);
let result = listener.result;
if (dart.is(chainSource, _Future$())) {
- if (chainSource[_isComplete]) {
+ if (dart.notNull(chainSource[_isComplete])) {
result[_isChained] = true;
source = chainSource;
listeners = new _FutureListener.chain(result);
@@ -2591,7 +2591,7 @@ var collection = dart.import(collection);
}
let result = listener.result;
listeners = result[_removeListeners]();
- if (listenerHasValue) {
+ if (dart.notNull(listenerHasValue)) {
result[_setValue](listenerValueOrError);
} else {
let asyncError = dart.as(listenerValueOrError, AsyncError);
@@ -2603,7 +2603,7 @@ var collection = dart.import(collection);
timeout(timeLimit, opts) {
let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null;
dart.as(onTimeout, dart.functionType(core.Object, []));
- if (this[_isComplete])
+ if (dart.notNull(this[_isComplete]))
return new (_Future$()).immediate(this);
let result = new (_Future$())();
let timer = null;
@@ -2626,12 +2626,12 @@ var collection = dart.import(collection);
}
this.then(dart.fn(v => {
dart.as(v, T);
- if (timer.isActive) {
+ if (dart.notNull(timer.isActive)) {
timer.cancel();
result[_completeWithValue](v);
}
}, core.Object, [T]), {onError: dart.fn((e, s) => {
- if (timer.isActive) {
+ if (dart.notNull(timer.isActive)) {
timer.cancel();
result[_completeError](e, dart.as(s, core.StackTrace));
}
@@ -2757,7 +2757,7 @@ var collection = dart.import(collection);
}
dart.fn(_schedulePriorityAsyncCallback, dart.void, [core.Object]);
function scheduleMicrotask(callback) {
- if (core.identical(_ROOT_ZONE, Zone.current)) {
+ if (dart.notNull(core.identical(_ROOT_ZONE, Zone.current))) {
_rootScheduleMicrotask(null, null, _ROOT_ZONE, callback);
return;
}
@@ -2772,7 +2772,7 @@ var collection = dart.import(collection);
if (self.scheduleImmediate != null) {
return _AsyncRun._scheduleImmediateJsOverride;
}
- if (dart.notNull(self.MutationObserver != null) && dart.notNull(self.document != null)) {
+ if (self.MutationObserver != null && self.document != null) {
let div = self.document.createElement("div");
let span = self.document.createElement("span");
let storedCallback = null;
@@ -2966,16 +2966,16 @@ var collection = dart.import(collection);
let onResume = opts && 'onResume' in opts ? opts.onResume : null;
let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
let sync = opts && 'sync' in opts ? opts.sync : false;
- if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && dart.notNull(onResume == null) && dart.notNull(onCancel == null)) {
- return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController(), StreamController$(T));
+ if (onListen == null && onPause == null && onResume == null && onCancel == null) {
+ return dart.as(dart.notNull(sync) ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController(), StreamController$(T));
}
- return sync ? new (_SyncStreamController$(T))(onListen, onPause, onResume, onCancel) : new (_AsyncStreamController$(T))(onListen, onPause, onResume, onCancel);
+ return dart.notNull(sync) ? new (_SyncStreamController$(T))(onListen, onPause, onResume, onCancel) : new (_AsyncStreamController$(T))(onListen, onPause, onResume, onCancel);
}
static broadcast(opts) {
let onListen = opts && 'onListen' in opts ? opts.onListen : null;
let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
let sync = opts && 'sync' in opts ? opts.sync : false;
- return sync ? new (_SyncBroadcastStreamController$(T))(onListen, onCancel) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel);
+ return dart.notNull(sync) ? new (_SyncBroadcastStreamController$(T))(onListen, onCancel) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel);
}
}
StreamController[dart.implements] = () => [StreamSink$(T)];
@@ -3043,7 +3043,7 @@ var collection = dart.import(collection);
return (dart.notNull(this[_state]) & dart.notNull(_StreamController$()._STATE_CLOSED)) != 0;
}
get isPaused() {
- return this.hasListener ? this[_subscription][_isInputPaused] : !dart.notNull(this[_isCanceled]);
+ return dart.notNull(this.hasListener) ? this[_subscription][_isInputPaused] : !dart.notNull(this[_isCanceled]);
}
get [_isAddingStream]() {
return (dart.notNull(this[_state]) & dart.notNull(_StreamController$()._STATE_ADDSTREAM)) != 0;
@@ -3073,14 +3073,14 @@ var collection = dart.import(collection);
}
get [_subscription]() {
dart.assert(this.hasListener);
- if (this[_isAddingStream]) {
+ if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
return dart.as(addState.varData, _ControllerSubscription);
}
return dart.as(this[_varData], _ControllerSubscription);
}
[_badEventState]() {
- if (this.isClosed) {
+ if (dart.notNull(this.isClosed)) {
return new core.StateError("Cannot add event after closing");
}
dart.assert(this[_isAddingStream]);
@@ -3091,7 +3091,7 @@ var collection = dart.import(collection);
let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
if (!dart.notNull(this[_mayAddEvent]))
throw this[_badEventState]();
- if (this[_isCanceled])
+ if (dart.notNull(this[_isCanceled]))
return new _Future.immediate(null);
let addState = new _StreamControllerAddStreamState(this, this[_varData], source, cancelOnError);
this[_varData] = addState;
@@ -3103,7 +3103,7 @@ var collection = dart.import(collection);
}
[_ensureDoneFuture]() {
if (this[_doneFuture] == null) {
- this[_doneFuture] = this[_isCanceled] ? Future._nullFuture : new _Future();
+ this[_doneFuture] = dart.notNull(this[_isCanceled]) ? Future._nullFuture : new _Future();
}
return this[_doneFuture];
}
@@ -3127,7 +3127,7 @@ var collection = dart.import(collection);
this[_addError](error, stackTrace);
}
close() {
- if (this.isClosed) {
+ if (dart.notNull(this.isClosed)) {
return this[_ensureDoneFuture]();
}
if (!dart.notNull(this[_mayAddEvent]))
@@ -3137,24 +3137,24 @@ var collection = dart.import(collection);
}
[_closeUnchecked]() {
this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController$()._STATE_CLOSED);
- if (this.hasListener) {
+ if (dart.notNull(this.hasListener)) {
this[_sendDone]();
- } else if (this[_isInitialState]) {
+ } else if (dart.notNull(this[_isInitialState])) {
this[_ensurePendingEvents]().add(dart.const(new _DelayedDone()));
}
}
[_add](value) {
dart.as(value, T);
- if (this.hasListener) {
+ if (dart.notNull(this.hasListener)) {
this[_sendData](value);
- } else if (this[_isInitialState]) {
+ } else if (dart.notNull(this[_isInitialState])) {
this[_ensurePendingEvents]().add(new (_DelayedData$(T))(value));
}
}
[_addError](error, stackTrace) {
- if (this.hasListener) {
+ if (dart.notNull(this.hasListener)) {
this[_sendError](error, stackTrace);
- } else if (this[_isInitialState]) {
+ } else if (dart.notNull(this[_isInitialState])) {
this[_ensurePendingEvents]().add(new _DelayedError(error, stackTrace));
}
}
@@ -3174,7 +3174,7 @@ var collection = dart.import(collection);
let subscription = new _ControllerSubscription(this, onData, onError, onDone, cancelOnError);
let pendingEvents = this[_pendingEvents];
this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController$()._STATE_SUBSCRIBED);
- if (this[_isAddingStream]) {
+ if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
addState.varData = subscription;
addState.resume();
@@ -3190,7 +3190,7 @@ var collection = dart.import(collection);
[_recordCancel](subscription) {
dart.as(subscription, StreamSubscription$(T));
let result = null;
- if (this[_isAddingStream]) {
+ if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
result = addState.cancel();
}
@@ -3211,7 +3211,7 @@ var collection = dart.import(collection);
}
}
let complete = () => {
- if (dart.notNull(this[_doneFuture] != null) && dart.notNull(this[_doneFuture][_mayComplete])) {
+ if (this[_doneFuture] != null && dart.notNull(this[_doneFuture][_mayComplete])) {
this[_doneFuture][_asyncComplete](null);
}
};
@@ -3225,7 +3225,7 @@ var collection = dart.import(collection);
}
[_recordPause](subscription) {
dart.as(subscription, StreamSubscription$(T));
- if (this[_isAddingStream]) {
+ if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
addState.pause();
}
@@ -3233,7 +3233,7 @@ var collection = dart.import(collection);
}
[_recordResume](subscription) {
dart.as(subscription, StreamSubscription$(T));
- if (this[_isAddingStream]) {
+ if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
addState.resume();
}
@@ -3426,7 +3426,7 @@ var collection = dart.import(collection);
class _AddStreamState extends core.Object {
_AddStreamState(controller, source, cancelOnError) {
this.addStreamFuture = new _Future();
- this.addSubscription = source.listen(dart.bind(controller, _add), {onError: cancelOnError ? dart.as(_AddStreamState$().makeErrorHandler(controller), core.Function) : dart.bind(controller, _addError), onDone: dart.bind(controller, _close), cancelOnError: cancelOnError});
+ this.addSubscription = source.listen(dart.bind(controller, _add), {onError: dart.notNull(cancelOnError) ? dart.as(_AddStreamState$().makeErrorHandler(controller), core.Function) : dart.bind(controller, _addError), onDone: dart.bind(controller, _close), cancelOnError: cancelOnError});
}
static makeErrorHandler(controller) {
return dart.fn((e, s) => {
@@ -3473,7 +3473,7 @@ var collection = dart.import(collection);
_StreamControllerAddStreamState(controller, varData, source, cancelOnError) {
this.varData = varData;
super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cancelOnError);
- if (controller.isPaused) {
+ if (dart.notNull(controller.isPaused)) {
this.addSubscription.pause();
}
}
@@ -3514,7 +3514,7 @@ var collection = dart.import(collection);
[_createSubscription](onData, onError, onDone, cancelOnError) {
dart.as(onData, dart.functionType(dart.void, [T]));
dart.as(onDone, dart.functionType(dart.void, []));
- if (this[_isUsed])
+ if (dart.notNull(this[_isUsed]))
throw new core.StateError("Stream has already been listened to.");
this[_isUsed] = true;
return dart.as((() => {
@@ -3543,10 +3543,10 @@ var collection = dart.import(collection);
return dart.notNull(this[_state]) >= dart.notNull(_PendingEvents._STATE_SCHEDULED);
}
schedule(dispatch) {
- if (this.isScheduled)
+ if (dart.notNull(this.isScheduled))
return;
dart.assert(!dart.notNull(this.isEmpty));
- if (this[_eventScheduled]) {
+ if (dart.notNull(this[_eventScheduled])) {
dart.assert(this[_state] == _PendingEvents._STATE_CANCELED);
this[_state] = _PendingEvents._STATE_SCHEDULED;
return;
@@ -3561,7 +3561,7 @@ var collection = dart.import(collection);
this[_state] = _PendingEvents._STATE_SCHEDULED;
}
cancelSchedule() {
- if (this.isScheduled)
+ if (dart.notNull(this.isScheduled))
this[_state] = _PendingEvents._STATE_CANCELED;
}
}
@@ -3603,7 +3603,7 @@ var collection = dart.import(collection);
}
}
clear() {
- if (this.isScheduled)
+ if (dart.notNull(this.isScheduled))
this.cancelSchedule();
this[_iterator] = null;
}
@@ -3724,7 +3724,7 @@ var collection = dart.import(collection);
event.perform(dispatch);
}
clear() {
- if (this.isScheduled)
+ if (dart.notNull(this.isScheduled))
this.cancelSchedule();
this.firstPendingEvent = this.lastPendingEvent = null;
}
@@ -3784,7 +3784,7 @@ var collection = dart.import(collection);
return dart.notNull(this[_state]) >= dart.notNull(_DoneStreamSubscription$()._PAUSED);
}
[_schedule]() {
- if (this[_isScheduled])
+ if (dart.notNull(this[_isScheduled]))
return;
this[_zone].scheduleMicrotask(dart.bind(this, _sendDone));
this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubscription$()._SCHEDULED);
@@ -3805,7 +3805,7 @@ var collection = dart.import(collection);
resumeSignal.whenComplete(dart.bind(this, 'resume'));
}
resume() {
- if (this.isPaused) {
+ if (dart.notNull(this.isPaused)) {
this[_state] = dart.notNull(this[_state]) - dart.notNull(_DoneStreamSubscription$()._PAUSED);
if (!dart.notNull(this.isPaused) && !dart.notNull(this[_isSent])) {
this[_schedule]();
@@ -3826,7 +3826,7 @@ var collection = dart.import(collection);
}
[_sendDone]() {
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_DoneStreamSubscription$()._SCHEDULED);
- if (this.isPaused)
+ if (dart.notNull(this.isPaused))
return;
this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubscription$()._DONE_SENT);
if (this[_onDone] != null)
@@ -3882,7 +3882,7 @@ var collection = dart.import(collection);
let onDone = opts && 'onDone' in opts ? opts.onDone : null;
dart.as(onDone, dart.functionType(dart.void, []));
let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
- if (dart.notNull(this[_controller] == null) || dart.notNull(this[_controller].isClosed)) {
+ if (this[_controller] == null || dart.notNull(this[_controller].isClosed)) {
return new (_DoneStreamSubscription$(T))(onDone);
}
if (this[_subscription] == null) {
@@ -3892,11 +3892,11 @@ var collection = dart.import(collection);
return this[_controller][_subscribe](onData, onError, onDone, cancelOnError);
}
[_onCancel]() {
- let shutdown = dart.notNull(this[_controller] == null) || dart.notNull(this[_controller].isClosed);
+ let shutdown = this[_controller] == null || dart.notNull(this[_controller].isClosed);
if (this[_onCancelHandler] != null) {
this[_zone].runUnary(this[_onCancelHandler], new _BroadcastSubscriptionWrapper(this));
}
- if (shutdown) {
+ if (dart.notNull(shutdown)) {
if (this[_subscription] != null) {
this[_subscription].cancel();
this[_subscription] = null;
@@ -4249,12 +4249,12 @@ var collection = dart.import(collection);
}
[_add](data) {
dart.as(data, T);
- if (this[_isClosed])
+ if (dart.notNull(this[_isClosed]))
return;
super[_add](data);
}
[_addError](error, stackTrace) {
- if (this[_isClosed])
+ if (dart.notNull(this[_isClosed]))
return;
super[_addError](error, stackTrace);
}
@@ -4332,7 +4332,7 @@ var collection = dart.import(collection);
return;
}
- if (satisfies) {
+ if (dart.notNull(satisfies)) {
sink[_add](inputEvent);
}
}
@@ -4427,12 +4427,12 @@ var collection = dart.import(collection);
}
}
- if (matches) {
+ if (dart.notNull(matches)) {
try {
_invokeErrorHandler(this[_transform], error, stackTrace);
} catch (e) {
let s = dart.stackTrace(e);
- if (core.identical(e, error)) {
+ if (dart.notNull(core.identical(e, error))) {
sink[_addError](error, stackTrace);
} else {
_addErrorWithReplacement(sink, e, s);
@@ -4499,7 +4499,7 @@ var collection = dart.import(collection);
return;
}
- if (satisfies) {
+ if (dart.notNull(satisfies)) {
sink[_add](inputEvent);
} else {
sink[_close]();
@@ -4549,7 +4549,7 @@ var collection = dart.import(collection);
[_handleData](inputEvent, sink) {
dart.as(inputEvent, T);
dart.as(sink, _EventSink$(T));
- if (this[_hasFailed]) {
+ if (dart.notNull(this[_hasFailed])) {
sink[_add](inputEvent);
return;
}
@@ -4592,7 +4592,7 @@ var collection = dart.import(collection);
[_handleData](inputEvent, sink) {
dart.as(inputEvent, T);
dart.as(sink, _EventSink$(T));
- if (core.identical(this[_previous], _DistinctStream$()._SENTINEL)) {
+ if (dart.notNull(core.identical(this[_previous], _DistinctStream$()._SENTINEL))) {
this[_previous] = inputEvent;
return sink[_add](inputEvent);
} else {
@@ -4676,33 +4676,33 @@ var collection = dart.import(collection);
}
[_add](data) {
dart.as(data, T);
- if (this[_isClosed]) {
+ if (dart.notNull(this[_isClosed])) {
throw new core.StateError("Stream is already closed");
}
super[_add](data);
}
[_addError](error, stackTrace) {
- if (this[_isClosed]) {
+ if (dart.notNull(this[_isClosed])) {
throw new core.StateError("Stream is already closed");
}
super[_addError](error, stackTrace);
}
[_close]() {
- if (this[_isClosed]) {
+ if (dart.notNull(this[_isClosed])) {
throw new core.StateError("Stream is already closed");
}
super[_close]();
}
[_onPause]() {
- if (this[_isSubscribed])
+ if (dart.notNull(this[_isSubscribed]))
this[_subscription].pause();
}
[_onResume]() {
- if (this[_isSubscribed])
+ if (dart.notNull(this[_isSubscribed]))
this[_subscription].resume();
}
[_onCancel]() {
- if (this[_isSubscribed]) {
+ if (dart.notNull(this[_isSubscribed])) {
let subscription = this[_subscription];
this[_subscription] = null;
subscription.cancel();
@@ -4726,7 +4726,7 @@ var collection = dart.import(collection);
this[_transformerSink].addError(error, dart.as(stackTrace, core.StackTrace));
} catch (e) {
let s = dart.stackTrace(e);
- if (core.identical(e, error)) {
+ if (dart.notNull(core.identical(e, error))) {
this[_addError](error, dart.as(stackTrace, core.StackTrace));
} else {
this[_addError](e, s);
@@ -5205,7 +5205,7 @@ var collection = dart.import(collection);
}
runGuarded(f) {
try {
- if (core.identical(_ROOT_ZONE, Zone._current)) {
+ if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
return f();
}
return _rootRun(null, null, this, f);
@@ -5217,7 +5217,7 @@ var collection = dart.import(collection);
}
runUnaryGuarded(f, arg) {
try {
- if (core.identical(_ROOT_ZONE, Zone._current)) {
+ if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
return dart.dcall(f, arg);
}
return _rootRunUnary(null, null, this, f, arg);
@@ -5229,7 +5229,7 @@ var collection = dart.import(collection);
}
runBinaryGuarded(f, arg1, arg2) {
try {
- if (core.identical(_ROOT_ZONE, Zone._current)) {
+ if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
return dart.dcall(f, arg1, arg2);
}
return _rootRunBinary(null, null, this, f, arg1, arg2);
@@ -5241,7 +5241,7 @@ var collection = dart.import(collection);
}
bindCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- if (runGuarded) {
+ if (dart.notNull(runGuarded)) {
return dart.fn(() => this.runGuarded(f));
} else {
return dart.fn(() => this.run(f));
@@ -5249,7 +5249,7 @@ var collection = dart.import(collection);
}
bindUnaryCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- if (runGuarded) {
+ if (dart.notNull(runGuarded)) {
return dart.fn(arg => this.runUnaryGuarded(f, arg));
} else {
return dart.fn(arg => this.runUnary(f, arg));
@@ -5257,7 +5257,7 @@ var collection = dart.import(collection);
}
bindBinaryCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- if (runGuarded) {
+ if (dart.notNull(runGuarded)) {
return dart.fn((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2));
} else {
return dart.fn((arg1, arg2) => this.runBinary(f, arg1, arg2));
@@ -5275,17 +5275,17 @@ var collection = dart.import(collection);
return _rootFork(null, null, this, specification, zoneValues);
}
run(f) {
- if (core.identical(Zone._current, _ROOT_ZONE))
+ if (dart.notNull(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 (dart.notNull(core.identical(Zone._current, _ROOT_ZONE)))
return dart.dcall(f, arg);
return _rootRunUnary(null, null, this, f, arg);
}
runBinary(f, arg1, arg2) {
- if (core.identical(Zone._current, _ROOT_ZONE))
+ if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE)))
return dart.dcall(f, arg1, arg2);
return _rootRunBinary(null, null, this, f, arg1, arg2);
}
@@ -5391,7 +5391,7 @@ var collection = dart.import(collection);
errorCallback(zone, error, stackTrace) {
let implementation = this[_delegationTarget][_errorCallback];
let implZone = implementation.zone;
- if (core.identical(implZone, _ROOT_ZONE))
+ if (dart.notNull(core.identical(implZone, _ROOT_ZONE)))
return null;
return dart.as(dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, error, stackTrace), AsyncError);
}
@@ -5513,7 +5513,7 @@ var collection = dart.import(collection);
bindCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
let registered = this.registerCallback(f);
- if (runGuarded) {
+ if (dart.notNull(runGuarded)) {
return dart.fn(() => this.runGuarded(registered));
} else {
return dart.fn(() => this.run(registered));
@@ -5522,7 +5522,7 @@ var collection = dart.import(collection);
bindUnaryCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
let registered = this.registerUnaryCallback(f);
- if (runGuarded) {
+ if (dart.notNull(runGuarded)) {
return dart.fn(arg => this.runUnaryGuarded(registered, arg));
} else {
return dart.fn(arg => this.runUnary(registered, arg));
@@ -5531,7 +5531,7 @@ var collection = dart.import(collection);
bindBinaryCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
let registered = this.registerBinaryCallback(f);
- if (runGuarded) {
+ if (dart.notNull(runGuarded)) {
return dart.fn((arg1, arg2) => this.runBinaryGuarded(registered, arg1, arg2));
} else {
return dart.fn((arg1, arg2) => this.runBinary(registered, arg1, arg2));
@@ -5539,7 +5539,7 @@ var collection = dart.import(collection);
}
get(key) {
let result = this[_map].get(key);
- if (dart.notNull(result != null) || dart.notNull(this[_map].containsKey(key)))
+ if (result != null || dart.notNull(this[_map].containsKey(key)))
return result;
if (this.parent != null) {
let value = this.parent.get(key);
@@ -5605,7 +5605,7 @@ var collection = dart.import(collection);
let implementation = this[_errorCallback];
dart.assert(implementation != null);
let implementationZone = implementation.zone;
- if (core.identical(implementationZone, _ROOT_ZONE))
+ if (dart.notNull(core.identical(implementationZone, _ROOT_ZONE)))
return null;
let parentDelegate = _parentDelegate(dart.as(implementationZone, _Zone));
return dart.as(dart.dcall(implementation.function, implementationZone, parentDelegate, this, error, stackTrace), AsyncError);
@@ -5828,7 +5828,7 @@ var collection = dart.import(collection);
return self.parent.runUnary(dart.as(onError, __CastType38), error);
} catch (e) {
let s = dart.stackTrace(e);
- if (core.identical(e, error)) {
+ if (dart.notNull(core.identical(e, error))) {
return parent.handleUncaughtError(zone, error, stackTrace);
} else {
return parent.handleUncaughtError(zone, e, s);
« 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