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

Issues Search
    My Issues | Starred     Open | Closed | All

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

Issue 1355893003: Rewire DDC to use the analyzer task model (Closed) Base URL: https://github.com/dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 3 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
« lib/runtime/dart/_foreign_helper.js ('K') | « lib/runtime/dart/_native_typed_data.js ('k') | lib/runtime/dart/collection.js » ('j') | pubspec.yaml » ('J')
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 a351b5f60e7f5c7cfd78646e21eb3a81ab1b928c..3b1ababefebf543d6202cce394ff8a107000e8ea 100644
--- a/lib/runtime/dart/async.js
+++ b/lib/runtime/dart/async.js
@@ -18,9 +18,9 @@ dart_library.library('dart/async', null, /* Imports */[
dart.fn(_invokeErrorHandler, dart.dynamic, [core.Function, core.Object, core.StackTrace]);
function _registerErrorHandler(errorHandler, zone) {
if (dart.is(errorHandler, ZoneBinaryCallback)) {
- return zone.registerBinaryCallback(errorHandler);
+ return dart.dcall(zone.registerBinaryCallback, errorHandler);
} else {
- return zone.registerUnaryCallback(dart.as(errorHandler, __CastType0));
+ return dart.dcall(zone.registerUnaryCallback, errorHandler);
}
}
dart.fn(_registerErrorHandler, () => dart.definiteFunctionType(core.Function, [core.Function, Zone]));
@@ -30,7 +30,7 @@ dart_library.library('dart/async', null, /* Imports */[
this.stackTrace = stackTrace;
}
toString() {
- return dart.toString(this.error);
+ return dart.as(dart.dsend(this.error, 'toString'), core.String);
}
}
AsyncError[dart.implements] = () => [core.Error];
@@ -39,7 +39,7 @@ dart_library.library('dart/async', null, /* Imports */[
});
class _UncaughtAsyncError extends AsyncError {
_UncaughtAsyncError(error, stackTrace) {
- super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stackTrace));
+ super.AsyncError(error, dart.dcall(_UncaughtAsyncError._getBestStackTrace, error, stackTrace));
}
static _getBestStackTrace(error, stackTrace) {
if (stackTrace != null)
@@ -62,7 +62,6 @@ dart_library.library('dart/async', null, /* Imports */[
statics: () => ({_getBestStackTrace: [core.StackTrace, [dart.dynamic, core.StackTrace]]}),
names: ['_getBestStackTrace']
});
- let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dynamic, [dart.dynamic]));
let _add = Symbol('_add');
let _closeUnchecked = Symbol('_closeUnchecked');
let _addError = Symbol('_addError');
@@ -75,12 +74,12 @@ dart_library.library('dart/async', null, /* Imports */[
}
static fromFuture(future) {
let controller = dart.as(StreamController$(T).new({sync: true}), _StreamController$(T));
- future.then(dart.fn(value => {
- controller[_add](dart.as(value, T));
- controller[_closeUnchecked]();
+ dart.dcall(future.then, dart.fn(value => {
+ dart.dcall(controller[_add], value);
+ dart.dcall(controller[_closeUnchecked]);
}), {onError: dart.fn((error, stackTrace) => {
- controller[_addError](error, dart.as(stackTrace, core.StackTrace));
- controller[_closeUnchecked]();
+ dart.dcall(controller[_addError], error, stackTrace);
+ dart.dcall(controller[_closeUnchecked]);
})});
return controller.stream;
}
@@ -97,41 +96,41 @@ dart_library.library('dart/async', null, /* Imports */[
let controller = null;
let watch = new core.Stopwatch();
function sendEvent() {
- watch.reset();
+ dart.dcall(watch.reset);
let data = computation((() => {
let x = computationCount;
computationCount = dart.notNull(x) + 1;
return x;
})());
- controller.add(data);
+ dart.dcall(controller.add, data);
}
dart.fn(sendEvent, dart.void, []);
function startPeriodicTimer() {
dart.assert(timer == null);
timer = Timer.periodic(period, dart.fn(timer => {
- sendEvent();
+ dart.dcall(sendEvent);
}, dart.dynamic, [Timer]));
}
dart.fn(startPeriodicTimer, dart.void, []);
controller = StreamController$(T).new({sync: true, onListen: dart.fn(() => {
- watch.start();
- startPeriodicTimer();
+ dart.dcall(watch.start);
+ dart.dcall(startPeriodicTimer);
}), onPause: dart.fn(() => {
- timer.cancel();
+ dart.dcall(timer.cancel);
timer = null;
- watch.stop();
+ dart.dcall(watch.stop);
}), onResume: dart.fn(() => {
dart.assert(timer == null);
let elapsed = watch.elapsed;
- watch.start();
+ dart.dcall(watch.start);
timer = Timer.new(period['-'](elapsed), dart.fn(() => {
timer = null;
- startPeriodicTimer();
- sendEvent();
+ dart.dcall(startPeriodicTimer);
+ dart.dcall(sendEvent);
}));
}), onCancel: dart.fn(() => {
if (timer != null)
- timer.cancel();
+ dart.dcall(timer.cancel);
timer = null;
})});
return controller.stream;
@@ -147,7 +146,7 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)]));
let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)]));
- return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType12), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription])));
+ return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType4), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription])));
}
where(test) {
dart.as(test, dart.functionType(core.bool, [T]));
@@ -165,38 +164,38 @@ dart_library.library('dart/async', null, /* Imports */[
let add = dart.bind(controller, 'add');
dart.assert(dart.is(controller, _StreamController) || dart.is(controller, _BroadcastStreamController));
let eventSink = controller;
- let addError = eventSink[_addError];
- subscription = this.listen(dart.fn(event => {
+ let addError = dart.dload(eventSink, _addError);
+ subscription = dart.dcall(this.listen, dart.fn(event => {
dart.as(event, T);
let newValue = null;
try {
newValue = convert(event);
} catch (e) {
let s = dart.stackTrace(e);
- controller.addError(e, s);
+ dart.dcall(controller.addError, e, s);
return;
}
if (dart.is(newValue, Future)) {
- subscription.pause();
+ dart.dcall(subscription.pause);
dart.dsend(dart.dsend(newValue, 'then', add, {onError: addError}), 'whenComplete', dart.bind(subscription, 'resume'));
} else {
- controller.add(newValue);
+ dart.dcall(controller.add, newValue);
}
- }, dart.dynamic, [T]), {onError: dart.as(addError, core.Function), onDone: dart.bind(controller, 'close')});
+ }, dart.dynamic, [T]), {onError: addError, onDone: dart.bind(controller, 'close')});
}).bind(this);
dart.fn(onListen, dart.void, []);
if (dart.notNull(this.isBroadcast)) {
controller = StreamController.broadcast({onListen: onListen, onCancel: dart.fn(() => {
- subscription.cancel();
+ dart.dcall(subscription.cancel);
}), sync: true});
} else {
controller = StreamController.new({onListen: onListen, onPause: dart.fn(() => {
- subscription.pause();
+ dart.dcall(subscription.pause);
}), onResume: dart.fn(() => {
- subscription.resume();
+ dart.dcall(subscription.resume);
}), onCancel: dart.fn(() => {
- subscription.cancel();
+ dart.dcall(subscription.cancel);
}), sync: true});
}
return controller.stream;
@@ -208,35 +207,35 @@ dart_library.library('dart/async', null, /* Imports */[
let onListen = (function() {
dart.assert(dart.is(controller, _StreamController) || dart.is(controller, _BroadcastStreamController));
let eventSink = controller;
- subscription = this.listen(dart.fn(event => {
+ subscription = dart.dcall(this.listen, dart.fn(event => {
dart.as(event, T);
let newStream = null;
try {
newStream = convert(event);
} catch (e) {
let s = dart.stackTrace(e);
- controller.addError(e, s);
+ dart.dcall(controller.addError, e, s);
return;
}
if (newStream != null) {
- subscription.pause();
- controller.addStream(newStream).whenComplete(dart.bind(subscription, 'resume'));
+ dart.dcall(subscription.pause);
+ dart.dcall(dart.dcall(controller.addStream, newStream).whenComplete, dart.bind(subscription, 'resume'));
}
- }, dart.dynamic, [T]), {onError: dart.as(eventSink[_addError], core.Function), onDone: dart.bind(controller, 'close')});
+ }, dart.dynamic, [T]), {onError: dart.dload(eventSink, _addError), onDone: dart.bind(controller, 'close')});
}).bind(this);
dart.fn(onListen, dart.void, []);
if (dart.notNull(this.isBroadcast)) {
controller = StreamController.broadcast({onListen: onListen, onCancel: dart.fn(() => {
- subscription.cancel();
+ dart.dcall(subscription.cancel);
}), sync: true});
} else {
controller = StreamController.new({onListen: onListen, onPause: dart.fn(() => {
- subscription.pause();
+ dart.dcall(subscription.pause);
}), onResume: dart.fn(() => {
- subscription.resume();
+ dart.dcall(subscription.resume);
}), onCancel: dart.fn(() => {
- subscription.cancel();
+ dart.dcall(subscription.cancel);
}), sync: true});
}
return controller.stream;
@@ -252,11 +251,11 @@ dart_library.library('dart/async', null, /* Imports */[
}
pipe(streamConsumer) {
dart.as(streamConsumer, StreamConsumer$(T));
- return streamConsumer.addStream(this).then(dart.fn(_ => streamConsumer.close(), Future, [dart.dynamic]));
+ return dart.dcall(dart.dcall(streamConsumer.addStream, this).then, dart.fn(_ => dart.dcall(streamConsumer.close), Future, [dart.dynamic]));
}
transform(streamTransformer) {
dart.as(streamTransformer, StreamTransformer$(T, dart.dynamic));
- return streamTransformer.bind(this);
+ return dart.dcall(streamTransformer.bind, this);
}
reduce(combine) {
dart.as(combine, dart.functionType(T, [T, T]));
@@ -264,13 +263,13 @@ dart_library.library('dart/async', null, /* Imports */[
let seenFirst = false;
let value = null;
let subscription = null;
- subscription = this.listen(dart.fn(element => {
+ subscription = dart.dcall(this.listen, dart.fn(element => {
dart.as(element, T);
if (dart.notNull(seenFirst)) {
- _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(newValue => {
+ dart.dcall(_runUserCode, dart.fn(() => combine(value, element), T, []), dart.fn(newValue => {
dart.as(newValue, T);
value = newValue;
- }, dart.dynamic, [T]), dart.as(_cancelAndErrorClosure(subscription, result), __CastType14));
+ }, dart.dynamic, [T]), dart.dcall(_cancelAndErrorClosure, subscription, result));
} else {
value = element;
seenFirst = true;
@@ -278,14 +277,14 @@ dart_library.library('dart/async', null, /* Imports */[
}, dart.dynamic, [T]), {onError: dart.bind(result, _completeError), onDone: dart.fn(() => {
if (!dart.notNull(seenFirst)) {
try {
- dart.throw(_internal.IterableElementError.noElement());
+ dart.throw(dart.dcall(_internal.IterableElementError.noElement));
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(result, e, s);
+ dart.dcall(_completeWithErrorCallback, result, e, s);
}
} else {
- result[_complete](value);
+ dart.dcall(result[_complete], value);
}
}), cancelOnError: true});
return result;
@@ -295,15 +294,15 @@ dart_library.library('dart/async', null, /* Imports */[
let result = new _Future();
let value = initialValue;
let subscription = null;
- subscription = this.listen(dart.fn(element => {
+ subscription = dart.dcall(this.listen, dart.fn(element => {
dart.as(element, T);
- _runUserCode(dart.fn(() => dart.dcall(combine, value, element)), dart.fn(newValue => {
+ dart.dcall(_runUserCode, dart.fn(() => dart.dcall(combine, value, element)), dart.fn(newValue => {
value = newValue;
- }), dart.as(_cancelAndErrorClosure(subscription, result), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])));
+ }), dart.dcall(_cancelAndErrorClosure, subscription, result));
}, dart.dynamic, [T]), {onError: dart.fn((e, st) => {
- result[_completeError](e, dart.as(st, core.StackTrace));
+ dart.dcall(result[_completeError], e, st);
}), onDone: dart.fn(() => {
- result[_complete](value);
+ dart.dcall(result[_complete], value);
}), cancelOnError: true});
return result;
}
@@ -314,38 +313,38 @@ dart_library.library('dart/async', null, /* Imports */[
let buffer = new core.StringBuffer();
let subscription = null;
let first = true;
- subscription = this.listen(dart.fn(element => {
+ subscription = dart.dcall(this.listen, dart.fn(element => {
dart.as(element, T);
if (!dart.notNull(first)) {
- buffer.write(separator);
+ dart.dcall(buffer.write, separator);
}
first = false;
try {
- buffer.write(element);
+ dart.dcall(buffer.write, element);
} catch (e) {
let s = dart.stackTrace(e);
- _cancelAndErrorWithReplacement(subscription, result, e, s);
+ dart.dcall(_cancelAndErrorWithReplacement, subscription, result, e, s);
}
}, dart.dynamic, [T]), {onError: dart.fn(e => {
- result[_completeError](e);
+ dart.dcall(result[_completeError], e);
}), onDone: dart.fn(() => {
- result[_complete](dart.toString(buffer));
+ dart.dcall(result[_complete], dart.dcall(buffer.toString));
}), cancelOnError: true});
return result;
}
contains(needle) {
let future = new (_Future$(core.bool))();
let subscription = null;
- subscription = this.listen(dart.fn(element => {
+ subscription = dart.dcall(this.listen, dart.fn(element => {
dart.as(element, T);
- _runUserCode(dart.fn(() => dart.equals(element, needle), core.bool, []), dart.fn(isMatch => {
+ dart.dcall(_runUserCode, dart.fn(() => dart.equals(element, needle), core.bool, []), dart.fn(isMatch => {
if (dart.notNull(isMatch)) {
- _cancelAndValue(subscription, future, true);
+ dart.dcall(_cancelAndValue, subscription, future, true);
}
- }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])));
+ }, dart.dynamic, [core.bool]), dart.dcall(_cancelAndErrorClosure, subscription, future));
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- future[_complete](false);
+ dart.dcall(future[_complete], false);
}), cancelOnError: true});
return future;
}
@@ -353,12 +352,12 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(action, dart.functionType(dart.void, [T]));
let future = new _Future();
let subscription = null;
- subscription = this.listen(dart.fn(element => {
+ subscription = dart.dcall(this.listen, dart.fn(element => {
dart.as(element, T);
- _runUserCode(dart.fn(() => action(element), dart.void, []), dart.fn(_ => {
- }), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])));
+ dart.dcall(_runUserCode, dart.fn(() => action(element), dart.void, []), dart.fn(_ => {
+ }), dart.dcall(_cancelAndErrorClosure, subscription, future));
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- future[_complete](null);
+ dart.dcall(future[_complete], null);
}), cancelOnError: true});
return future;
}
@@ -366,15 +365,15 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(test, dart.functionType(core.bool, [T]));
let future = new (_Future$(core.bool))();
let subscription = null;
- subscription = this.listen(dart.fn(element => {
+ subscription = dart.dcall(this.listen, dart.fn(element => {
dart.as(element, T);
- _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMatch => {
+ dart.dcall(_runUserCode, dart.fn(() => test(element), core.bool, []), dart.fn(isMatch => {
if (!dart.notNull(isMatch)) {
- _cancelAndValue(subscription, future, false);
+ dart.dcall(_cancelAndValue, subscription, future, false);
}
- }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])));
+ }, dart.dynamic, [core.bool]), dart.dcall(_cancelAndErrorClosure, subscription, future));
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- future[_complete](true);
+ dart.dcall(future[_complete], true);
}), cancelOnError: true});
return future;
}
@@ -382,64 +381,64 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(test, dart.functionType(core.bool, [T]));
let future = new (_Future$(core.bool))();
let subscription = null;
- subscription = this.listen(dart.fn(element => {
+ subscription = dart.dcall(this.listen, dart.fn(element => {
dart.as(element, T);
- _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMatch => {
+ dart.dcall(_runUserCode, dart.fn(() => test(element), core.bool, []), dart.fn(isMatch => {
if (dart.notNull(isMatch)) {
- _cancelAndValue(subscription, future, true);
+ dart.dcall(_cancelAndValue, subscription, future, true);
}
- }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])));
+ }, dart.dynamic, [core.bool]), dart.dcall(_cancelAndErrorClosure, subscription, future));
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- future[_complete](false);
+ dart.dcall(future[_complete], false);
}), cancelOnError: true});
return future;
}
get length() {
let future = new (_Future$(core.int))();
let count = 0;
- this.listen(dart.fn(_ => {
+ dart.dcall(this.listen, dart.fn(_ => {
count = dart.notNull(count) + 1;
}), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- future[_complete](count);
+ dart.dcall(future[_complete], count);
}), cancelOnError: true});
return future;
}
get isEmpty() {
let future = new (_Future$(core.bool))();
let subscription = null;
- subscription = this.listen(dart.fn(_ => {
- _cancelAndValue(subscription, future, false);
+ subscription = dart.dcall(this.listen, dart.fn(_ => {
+ dart.dcall(_cancelAndValue, subscription, future, false);
}), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- future[_complete](true);
+ dart.dcall(future[_complete], true);
}), cancelOnError: true});
return future;
}
toList() {
let result = dart.list([], T);
let future = new (_Future$(core.List$(T)))();
- this.listen(dart.fn(data => {
+ dart.dcall(this.listen, dart.fn(data => {
dart.as(data, T);
- result[dartx.add](data);
+ dart.dcall(result[dartx.add], data);
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- future[_complete](result);
+ dart.dcall(future[_complete], result);
}), cancelOnError: true});
return future;
}
toSet() {
let result = core.Set$(T).new();
let future = new (_Future$(core.Set$(T)))();
- this.listen(dart.fn(data => {
+ dart.dcall(this.listen, dart.fn(data => {
dart.as(data, T);
- result.add(data);
+ dart.dcall(result.add, data);
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
- future[_complete](result);
+ dart.dcall(future[_complete], result);
}), cancelOnError: true});
return future;
}
drain(futureValue) {
if (futureValue === void 0)
futureValue = null;
- return this.listen(null, {cancelOnError: true}).asFuture(futureValue);
+ return dart.dcall(dart.dcall(this.listen, null, {cancelOnError: true}).asFuture, futureValue);
}
take(count) {
return new (_TakeStream$(T))(this, count);
@@ -464,15 +463,15 @@ dart_library.library('dart/async', null, /* Imports */[
get first() {
let future = new (_Future$(T))();
let subscription = null;
- subscription = this.listen(dart.fn(value => {
+ subscription = dart.dcall(this.listen, dart.fn(value => {
dart.as(value, T);
- _cancelAndValue(subscription, future, value);
+ dart.dcall(_cancelAndValue, subscription, future, value);
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
try {
- dart.throw(_internal.IterableElementError.noElement());
+ dart.throw(dart.dcall(_internal.IterableElementError.noElement));
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
+ dart.dcall(_completeWithErrorCallback, future, e, s);
}
}), cancelOnError: true});
@@ -483,20 +482,20 @@ dart_library.library('dart/async', null, /* Imports */[
let result = null;
let foundResult = false;
let subscription = null;
- subscription = this.listen(dart.fn(value => {
+ subscription = dart.dcall(this.listen, dart.fn(value => {
dart.as(value, T);
foundResult = true;
result = value;
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
if (dart.notNull(foundResult)) {
- future[_complete](result);
+ dart.dcall(future[_complete], result);
return;
}
try {
- dart.throw(_internal.IterableElementError.noElement());
+ dart.throw(dart.dcall(_internal.IterableElementError.noElement));
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
+ dart.dcall(_completeWithErrorCallback, future, e, s);
}
}), cancelOnError: true});
@@ -507,14 +506,14 @@ dart_library.library('dart/async', null, /* Imports */[
let result = null;
let foundResult = false;
let subscription = null;
- subscription = this.listen(dart.fn(value => {
+ subscription = dart.dcall(this.listen, dart.fn(value => {
dart.as(value, T);
if (dart.notNull(foundResult)) {
try {
- dart.throw(_internal.IterableElementError.tooMany());
+ dart.throw(dart.dcall(_internal.IterableElementError.tooMany));
} catch (e) {
let s = dart.stackTrace(e);
- _cancelAndErrorWithReplacement(subscription, future, e, s);
+ dart.dcall(_cancelAndErrorWithReplacement, subscription, future, e, s);
}
return;
@@ -523,14 +522,14 @@ dart_library.library('dart/async', null, /* Imports */[
result = value;
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
if (dart.notNull(foundResult)) {
- future[_complete](result);
+ dart.dcall(future[_complete], result);
return;
}
try {
- dart.throw(_internal.IterableElementError.noElement());
+ dart.throw(dart.dcall(_internal.IterableElementError.noElement));
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
+ dart.dcall(_completeWithErrorCallback, future, e, s);
}
}), cancelOnError: true});
@@ -542,23 +541,23 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(defaultValue, dart.functionType(core.Object, []));
let future = new _Future();
let subscription = null;
- subscription = this.listen(dart.fn(value => {
+ subscription = dart.dcall(this.listen, dart.fn(value => {
dart.as(value, T);
- _runUserCode(dart.fn(() => test(value), core.bool, []), dart.fn(isMatch => {
+ dart.dcall(_runUserCode, dart.fn(() => test(value), core.bool, []), dart.fn(isMatch => {
if (dart.notNull(isMatch)) {
- _cancelAndValue(subscription, future, value);
+ dart.dcall(_cancelAndValue, subscription, future, value);
}
- }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])));
+ }, dart.dynamic, [core.bool]), dart.dcall(_cancelAndErrorClosure, subscription, future));
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
if (defaultValue != null) {
- _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind(future, _completeError));
+ dart.dcall(_runUserCode, defaultValue, dart.bind(future, _complete), dart.bind(future, _completeError));
return;
}
try {
- dart.throw(_internal.IterableElementError.noElement());
+ dart.throw(dart.dcall(_internal.IterableElementError.noElement));
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
+ dart.dcall(_completeWithErrorCallback, future, e, s);
}
}), cancelOnError: true});
@@ -572,28 +571,28 @@ dart_library.library('dart/async', null, /* Imports */[
let result = null;
let foundResult = false;
let subscription = null;
- subscription = this.listen(dart.fn(value => {
+ subscription = dart.dcall(this.listen, dart.fn(value => {
dart.as(value, T);
- _runUserCode(dart.fn(() => true == test(value), core.bool, []), dart.fn(isMatch => {
+ dart.dcall(_runUserCode, dart.fn(() => true == test(value), core.bool, []), dart.fn(isMatch => {
if (dart.notNull(isMatch)) {
foundResult = true;
result = value;
}
- }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])));
+ }, dart.dynamic, [core.bool]), dart.dcall(_cancelAndErrorClosure, subscription, future));
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
if (dart.notNull(foundResult)) {
- future[_complete](result);
+ dart.dcall(future[_complete], result);
return;
}
if (defaultValue != null) {
- _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind(future, _completeError));
+ dart.dcall(_runUserCode, defaultValue, dart.bind(future, _complete), dart.bind(future, _completeError));
return;
}
try {
- dart.throw(_internal.IterableElementError.noElement());
+ dart.throw(dart.dcall(_internal.IterableElementError.noElement));
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
+ dart.dcall(_completeWithErrorCallback, future, e, s);
}
}), cancelOnError: true});
@@ -605,16 +604,16 @@ dart_library.library('dart/async', null, /* Imports */[
let result = null;
let foundResult = false;
let subscription = null;
- subscription = this.listen(dart.fn(value => {
+ subscription = dart.dcall(this.listen, dart.fn(value => {
dart.as(value, T);
- _runUserCode(dart.fn(() => true == test(value), core.bool, []), dart.fn(isMatch => {
+ dart.dcall(_runUserCode, dart.fn(() => true == test(value), core.bool, []), dart.fn(isMatch => {
if (dart.notNull(isMatch)) {
if (dart.notNull(foundResult)) {
try {
- dart.throw(_internal.IterableElementError.tooMany());
+ dart.throw(dart.dcall(_internal.IterableElementError.tooMany));
} catch (e) {
let s = dart.stackTrace(e);
- _cancelAndErrorWithReplacement(subscription, future, e, s);
+ dart.dcall(_cancelAndErrorWithReplacement, subscription, future, e, s);
}
return;
@@ -622,17 +621,17 @@ dart_library.library('dart/async', null, /* Imports */[
foundResult = true;
result = value;
}
- }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscription, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])));
+ }, dart.dynamic, [core.bool]), dart.dcall(_cancelAndErrorClosure, subscription, future));
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => {
if (dart.notNull(foundResult)) {
- future[_complete](result);
+ dart.dcall(future[_complete], result);
return;
}
try {
- dart.throw(_internal.IterableElementError.noElement());
+ dart.throw(dart.dcall(_internal.IterableElementError.noElement));
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
+ dart.dcall(_completeWithErrorCallback, future, e, s);
}
}), cancelOnError: true});
@@ -644,15 +643,15 @@ dart_library.library('dart/async', null, /* Imports */[
let future = new (_Future$(T))();
let subscription = null;
let elementIndex = 0;
- subscription = this.listen(dart.fn(value => {
+ subscription = dart.dcall(this.listen, dart.fn(value => {
dart.as(value, T);
if (index == elementIndex) {
- _cancelAndValue(subscription, future, value);
+ dart.dcall(_cancelAndValue, subscription, future, value);
return;
}
elementIndex = dart.notNull(elementIndex) + 1;
}, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDone: dart.fn((() => {
- future[_completeError](core.RangeError.index(index, this, "index", null, elementIndex));
+ dart.dcall(future[_completeError], core.RangeError.index(index, this, "index", null, elementIndex));
}).bind(this)), cancelOnError: true});
return future;
}
@@ -666,56 +665,56 @@ dart_library.library('dart/async', null, /* Imports */[
let timeout = null;
function onData(event) {
dart.as(event, T);
- timer.cancel();
- controller.add(event);
- timer = zone.createTimer(timeLimit, dart.as(timeout, __CastType17));
+ dart.dcall(timer.cancel);
+ dart.dcall(controller.add, event);
+ timer = dart.dcall(zone.createTimer, timeLimit, timeout);
}
dart.fn(onData, dart.void, [T]);
function onError(error, stackTrace) {
- timer.cancel();
+ dart.dcall(timer.cancel);
dart.assert(dart.is(controller, _StreamController) || dart.is(controller, _BroadcastStreamController));
let eventSink = controller;
- dart.dcall(eventSink[_addError], error, stackTrace);
- timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType(dart.void, [])));
+ dart.dsend(eventSink, _addError, error, stackTrace);
+ timer = dart.dcall(zone.createTimer, timeLimit, timeout);
}
dart.fn(onError, dart.void, [dart.dynamic, core.StackTrace]);
function onDone() {
- timer.cancel();
- controller.close();
+ dart.dcall(timer.cancel);
+ dart.dcall(controller.close);
}
dart.fn(onDone, dart.void, []);
let onListen = (function() {
zone = Zone.current;
if (onTimeout == null) {
timeout = dart.fn(() => {
- controller.addError(new TimeoutException("No stream event", timeLimit), null);
+ dart.dcall(controller.addError, new TimeoutException("No stream event", timeLimit), null);
});
} else {
- onTimeout = dart.as(zone.registerUnaryCallback(onTimeout), __CastType18);
+ onTimeout = dart.as(dart.dcall(zone.registerUnaryCallback, onTimeout), __CastType6);
let wrapper = new _ControllerEventSinkWrapper(null);
timeout = dart.fn(() => {
wrapper[_sink] = controller;
- zone.runUnaryGuarded(onTimeout, wrapper);
+ dart.dcall(zone.runUnaryGuarded, onTimeout, wrapper);
wrapper[_sink] = null;
});
}
- subscription = this.listen(onData, {onError: onError, onDone: onDone});
- timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType(dart.void, [])));
+ subscription = dart.dcall(this.listen, onData, {onError: onError, onDone: onDone});
+ timer = dart.dcall(zone.createTimer, timeLimit, timeout);
}).bind(this);
dart.fn(onListen, dart.void, []);
function onCancel() {
- timer.cancel();
- let result = subscription.cancel();
+ dart.dcall(timer.cancel);
+ let result = dart.dcall(subscription.cancel);
subscription = null;
return result;
}
dart.fn(onCancel, Future, []);
controller = dart.notNull(this.isBroadcast) ? new _SyncBroadcastStreamController(onListen, onCancel) : new _SyncStreamController(onListen, dart.fn(() => {
- timer.cancel();
- subscription.pause();
+ dart.dcall(timer.cancel);
+ dart.dcall(subscription.pause);
}), dart.fn(() => {
- subscription.resume();
- timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType(dart.void, [])));
+ dart.dcall(subscription.resume);
+ timer = dart.dcall(zone.createTimer, timeLimit, timeout);
}), onCancel);
return controller.stream;
}
@@ -776,9 +775,9 @@ dart_library.library('dart/async', null, /* Imports */[
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;
- cancelOnError = core.identical(true, cancelOnError);
- let subscription = this[_createSubscription](onData, onError, onDone, cancelOnError);
- this[_onListen](subscription);
+ cancelOnError = dart.dcall(core.identical, true, cancelOnError);
+ let subscription = dart.dcall(this[_createSubscription], onData, onError, onDone, cancelOnError);
+ dart.dcall(this[_onListen], subscription);
return dart.as(subscription, StreamSubscription$(T));
}
[_createSubscription](onData, onError, onDone, cancelOnError) {
@@ -808,18 +807,18 @@ dart_library.library('dart/async', null, /* Imports */[
[_createSubscription](onData, onError, onDone, cancelOnError) {
dart.as(onData, dart.functionType(dart.void, [T]));
dart.as(onDone, dart.functionType(dart.void, []));
- return this[_controller][_subscribe](onData, onError, onDone, cancelOnError);
+ return dart.dcall(this[_controller][_subscribe], onData, onError, onDone, cancelOnError);
}
get hashCode() {
return dart.notNull(dart.hashCode(this[_controller])) ^ 892482866;
}
['=='](other) {
- if (dart.notNull(core.identical(this, other)))
+ if (dart.notNull(dart.dcall(core.identical, this, other)))
return true;
if (!dart.is(other, _ControllerStream$()))
return false;
let otherStream = dart.as(other, _ControllerStream$());
- return core.identical(otherStream[_controller], this[_controller]);
+ return dart.dcall(core.identical, otherStream[_controller], this[_controller]);
}
}
dart.setSignature(_ControllerStream, {
@@ -897,9 +896,9 @@ dart_library.library('dart/async', null, /* Imports */[
this[_onDone] = null;
this[_cancelFuture] = null;
this[_pending] = null;
- this.onData(onData);
- this.onError(onError);
- this.onDone(onDone);
+ dart.dcall(this.onData, onData);
+ dart.dcall(this.onError, onError);
+ dart.dcall(this.onDone, onDone);
}
[_setPendingEvents](pendingEvents) {
dart.assert(this[_pending] == null);
@@ -908,7 +907,7 @@ dart_library.library('dart/async', null, /* Imports */[
this[_pending] = pendingEvents;
if (!dart.notNull(pendingEvents.isEmpty)) {
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_HAS_PENDING);
- this[_pending].schedule(this);
+ dart.dcall(this[_pending].schedule, this);
}
}
[_extractPending]() {
@@ -920,19 +919,19 @@ dart_library.library('dart/async', null, /* Imports */[
onData(handleData) {
dart.as(handleData, dart.functionType(dart.void, [T]));
if (handleData == null)
- handleData = dart.as(_nullDataHandler, __CastType20);
- this[_onData] = dart.as(this[_zone].registerUnaryCallback(handleData), _DataHandler$(T));
+ handleData = dart.as(_nullDataHandler, __CastType8);
+ this[_onData] = dart.as(dart.dcall(this[_zone].registerUnaryCallback, handleData), _DataHandler$(T));
}
onError(handleError) {
if (handleError == null)
handleError = _nullErrorHandler;
- this[_onError] = _registerErrorHandler(handleError, this[_zone]);
+ this[_onError] = dart.dcall(_registerErrorHandler, handleError, this[_zone]);
}
onDone(handleDone) {
dart.as(handleDone, dart.functionType(dart.void, []));
if (handleDone == null)
handleDone = _nullDoneHandler;
- this[_onDone] = this[_zone].registerCallback(handleDone);
+ this[_onDone] = dart.dcall(this[_zone].registerCallback, handleDone);
}
pause(resumeSignal) {
if (resumeSignal === void 0)
@@ -943,25 +942,25 @@ dart_library.library('dart/async', null, /* Imports */[
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'));
+ dart.dcall(resumeSignal.whenComplete, dart.bind(this, 'resume'));
if (!dart.notNull(wasPaused) && this[_pending] != null)
- this[_pending].cancelSchedule();
+ dart.dcall(this[_pending].cancelSchedule);
if (!dart.notNull(wasInputPaused) && !dart.notNull(this[_inCallback]))
- this[_guardCallback](dart.bind(this, _onPause));
+ dart.dcall(this[_guardCallback], dart.bind(this, _onPause));
}
resume() {
if (dart.notNull(this[_isCanceled]))
return;
if (dart.notNull(this[_isPaused])) {
- this[_decrementPauseCount]();
+ dart.dcall(this[_decrementPauseCount]);
if (!dart.notNull(this[_isPaused])) {
if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_pending].isEmpty)) {
- this[_pending].schedule(this);
+ dart.dcall(this[_pending].schedule, this);
} else {
dart.assert(this[_mayResumeInput]);
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription$()._STATE_INPUT_PAUSED);
if (!dart.notNull(this[_inCallback]))
- this[_guardCallback](dart.bind(this, _onResume));
+ dart.dcall(this[_guardCallback], dart.bind(this, _onResume));
}
}
}
@@ -970,7 +969,7 @@ dart_library.library('dart/async', null, /* Imports */[
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription$()._STATE_WAIT_FOR_CANCEL);
if (dart.notNull(this[_isCanceled]))
return this[_cancelFuture];
- this[_cancel]();
+ dart.dcall(this[_cancel]);
return this[_cancelFuture];
}
asFuture(futureValue) {
@@ -978,11 +977,11 @@ dart_library.library('dart/async', null, /* Imports */[
futureValue = null;
let result = new (_Future$(T))();
this[_onDone] = dart.fn(() => {
- result[_complete](futureValue);
+ dart.dcall(result[_complete], futureValue);
});
this[_onError] = dart.fn(((error, stackTrace) => {
- this.cancel();
- result[_completeError](error, dart.as(stackTrace, core.StackTrace));
+ dart.dcall(this.cancel);
+ dart.dcall(result[_completeError], error, stackTrace);
}).bind(this));
return result;
}
@@ -1022,11 +1021,11 @@ dart_library.library('dart/async', null, /* Imports */[
[_cancel]() {
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_CANCELED);
if (dart.notNull(this[_hasPending])) {
- this[_pending].cancelSchedule();
+ dart.dcall(this[_pending].cancelSchedule);
}
if (!dart.notNull(this[_inCallback]))
this[_pending] = null;
- this[_cancelFuture] = this[_onCancel]();
+ this[_cancelFuture] = dart.dcall(this[_onCancel]);
}
[_incrementPauseCount]() {
this[_state] = dart.notNull(this[_state]) + dart.notNull(_BufferingStreamSubscription$()._STATE_PAUSE_COUNT) | dart.notNull(_BufferingStreamSubscription$()._STATE_INPUT_PAUSED);
@@ -1041,18 +1040,18 @@ dart_library.library('dart/async', null, /* Imports */[
if (dart.notNull(this[_isCanceled]))
return;
if (dart.notNull(this[_canFire])) {
- this[_sendData](data);
+ dart.dcall(this[_sendData], data);
} else {
- this[_addPending](new _DelayedData(data));
+ dart.dcall(this[_addPending], new _DelayedData(data));
}
}
[_addError](error, stackTrace) {
if (dart.notNull(this[_isCanceled]))
return;
if (dart.notNull(this[_canFire])) {
- this[_sendError](error, stackTrace);
+ dart.dcall(this[_sendError], error, stackTrace);
} else {
- this[_addPending](new _DelayedError(error, stackTrace));
+ dart.dcall(this[_addPending], new _DelayedError(error, stackTrace));
}
}
[_close]() {
@@ -1061,9 +1060,9 @@ dart_library.library('dart/async', null, /* Imports */[
return;
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_CLOSED);
if (dart.notNull(this[_canFire])) {
- this[_sendDone]();
+ dart.dcall(this[_sendDone]);
} else {
- this[_addPending](dart.const(new _DelayedDone()));
+ dart.dcall(this[_addPending], dart.const(new _DelayedDone()));
}
}
[_onPause]() {
@@ -1080,11 +1079,11 @@ dart_library.library('dart/async', null, /* Imports */[
let pending = dart.as(this[_pending], _StreamImplEvents);
if (this[_pending] == null)
pending = this[_pending] = new _StreamImplEvents();
- pending.add(event);
+ dart.dcall(pending.add, event);
if (!dart.notNull(this[_hasPending])) {
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_HAS_PENDING);
if (!dart.notNull(this[_isPaused])) {
- this[_pending].schedule(this);
+ dart.dcall(this[_pending].schedule, this);
}
}
}
@@ -1095,9 +1094,9 @@ dart_library.library('dart/async', null, /* Imports */[
dart.assert(!dart.notNull(this[_inCallback]));
let wasInputPaused = this[_isInputPaused];
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_IN_CALLBACK);
- this[_zone].runUnaryGuarded(this[_onData], data);
+ dart.dcall(this[_zone].runUnaryGuarded, this[_onData], data);
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription$()._STATE_IN_CALLBACK);
- this[_checkState](wasInputPaused);
+ dart.dcall(this[_checkState], wasInputPaused);
}
[_sendError](error, stackTrace) {
dart.assert(!dart.notNull(this[_isCanceled]));
@@ -1109,24 +1108,24 @@ dart_library.library('dart/async', null, /* Imports */[
return;
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], __CastType22), error, stackTrace);
+ dart.dcall(this[_zone].runBinaryGuarded, this[_onError], error, stackTrace);
} else {
- this[_zone].runUnaryGuarded(dart.as(this[_onError], __CastType25), error);
+ dart.dcall(this[_zone].runUnaryGuarded, this[_onError], error);
}
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription$()._STATE_IN_CALLBACK);
}).bind(this);
dart.fn(sendError, dart.void, []);
if (dart.notNull(this[_cancelOnError])) {
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_WAIT_FOR_CANCEL);
- this[_cancel]();
+ dart.dcall(this[_cancel]);
if (dart.is(this[_cancelFuture], Future)) {
- this[_cancelFuture].whenComplete(sendError);
+ dart.dcall(this[_cancelFuture].whenComplete, sendError);
} else {
- sendError();
+ dart.dcall(sendError);
}
} else {
- sendError();
- this[_checkState](wasInputPaused);
+ dart.dcall(sendError);
+ dart.dcall(this[_checkState], wasInputPaused);
}
}
[_sendDone]() {
@@ -1137,16 +1136,16 @@ dart_library.library('dart/async', null, /* Imports */[
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[_zone].runGuarded(this[_onDone]);
+ dart.dcall(this[_zone].runGuarded, this[_onDone]);
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription$()._STATE_IN_CALLBACK);
}).bind(this);
dart.fn(sendDone, dart.void, []);
- this[_cancel]();
+ dart.dcall(this[_cancel]);
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BufferingStreamSubscription$()._STATE_WAIT_FOR_CANCEL);
if (dart.is(this[_cancelFuture], Future)) {
- this[_cancelFuture].whenComplete(sendDone);
+ dart.dcall(this[_cancelFuture].whenComplete, sendDone);
} else {
- sendDone();
+ dart.dcall(sendDone);
}
}
[_guardCallback](callback) {
@@ -1155,7 +1154,7 @@ dart_library.library('dart/async', null, /* Imports */[
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[_checkState](wasInputPaused);
+ dart.dcall(this[_checkState], wasInputPaused);
}
[_checkState](wasInputPaused) {
dart.assert(!dart.notNull(this[_inCallback]));
@@ -1175,15 +1174,15 @@ dart_library.library('dart/async', null, /* Imports */[
break;
this[_state] = dart.notNull(this[_state]) ^ dart.notNull(_BufferingStreamSubscription$()._STATE_IN_CALLBACK);
if (dart.notNull(isInputPaused)) {
- this[_onPause]();
+ dart.dcall(this[_onPause]);
} else {
- this[_onResume]();
+ dart.dcall(this[_onResume]);
}
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BufferingStreamSubscription$()._STATE_IN_CALLBACK);
wasInputPaused = isInputPaused;
}
if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) {
- this[_pending].schedule(this);
+ dart.dcall(this[_pending].schedule, this);
}
}
}
@@ -1230,13 +1229,13 @@ dart_library.library('dart/async', null, /* Imports */[
super._BufferingStreamSubscription(onData, onError, onDone, cancelOnError);
}
[_onCancel]() {
- return this[_controller][_recordCancel](this);
+ return dart.dcall(this[_controller][_recordCancel], this);
}
[_onPause]() {
- this[_controller][_recordPause](this);
+ dart.dcall(this[_controller][_recordPause], this);
}
[_onResume]() {
- this[_controller][_recordResume](this);
+ dart.dcall(this[_controller][_recordResume], this);
}
}
dart.setSignature(_ControllerSubscription, {
@@ -1340,7 +1339,7 @@ dart_library.library('dart/async', null, /* Imports */[
}
get [_hasOneListener]() {
dart.assert(!dart.notNull(this[_isEmpty]));
- return core.identical(this[_next][_next], this);
+ return dart.dcall(core.identical, this[_next][_next], this);
}
get [_isFiring]() {
return (dart.notNull(this[_state]) & dart.notNull(_BroadcastStreamController$()._STATE_FIRING)) != 0;
@@ -1357,11 +1356,11 @@ dart_library.library('dart/async', null, /* Imports */[
return this[_doneFuture] = new _Future();
}
get [_isEmpty]() {
- return core.identical(this[_next], this);
+ return dart.dcall(core.identical, this[_next], this);
}
[_addListener](subscription) {
dart.as(subscription, _BroadcastSubscription$(T));
- dart.assert(core.identical(subscription[_next], subscription));
+ dart.assert(dart.dcall(core.identical, subscription[_next], subscription));
subscription[_previous] = this[_previous];
subscription[_next] = this;
this[_previous][_next] = subscription;
@@ -1370,8 +1369,8 @@ dart_library.library('dart/async', null, /* Imports */[
}
[_removeListener](subscription) {
dart.as(subscription, _BroadcastSubscription$(T));
- dart.assert(core.identical(subscription[_controller], this));
- dart.assert(!dart.notNull(core.identical(subscription[_next], subscription)));
+ dart.assert(dart.dcall(core.identical, subscription[_controller], this));
+ dart.assert(!dart.notNull(dart.dcall(core.identical, subscription[_next], subscription)));
let previous = subscription[_previous];
let next = subscription[_next];
previous[_next] = next;
@@ -1387,24 +1386,24 @@ dart_library.library('dart/async', null, /* Imports */[
return new (_DoneStreamSubscription$(T))(onDone);
}
let subscription = new (_BroadcastSubscription$(T))(this, onData, onError, onDone, cancelOnError);
- this[_addListener](dart.as(subscription, _BroadcastSubscription$(T)));
- if (dart.notNull(core.identical(this[_next], this[_previous]))) {
- _runGuarded(this[_onListen]);
+ dart.dcall(this[_addListener], subscription);
+ if (dart.notNull(dart.dcall(core.identical, this[_next], this[_previous]))) {
+ dart.dcall(_runGuarded, this[_onListen]);
}
return dart.as(subscription, StreamSubscription$(T));
}
[_recordCancel](subscription) {
dart.as(subscription, StreamSubscription$(T));
- if (dart.notNull(core.identical(subscription[_next], subscription)))
+ if (dart.notNull(dart.dcall(core.identical, subscription[_next], subscription)))
return null;
- dart.assert(!dart.notNull(core.identical(subscription[_next], subscription)));
+ dart.assert(!dart.notNull(dart.dcall(core.identical, subscription[_next], subscription)));
if (dart.notNull(dart.as(subscription[_isFiring], core.bool))) {
dart.dcall(subscription[_setRemoveAfterFiring]);
} else {
- dart.assert(!dart.notNull(core.identical(subscription[_next], subscription)));
- this[_removeListener](dart.as(subscription, _BroadcastSubscription$(T)));
+ dart.assert(!dart.notNull(dart.dcall(core.identical, subscription[_next], subscription)));
+ dart.dcall(this[_removeListener], subscription);
if (!dart.notNull(this[_isFiring]) && dart.notNull(this[_isEmpty])) {
- this[_callOnCancel]();
+ dart.dcall(this[_callOnCancel]);
}
}
return null;
@@ -1425,21 +1424,21 @@ dart_library.library('dart/async', null, /* Imports */[
add(data) {
dart.as(data, T);
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_addEventError]());
- this[_sendData](data);
+ dart.throw(dart.dcall(this[_addEventError]));
+ dart.dcall(this[_sendData], data);
}
addError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- error = _nonNullError(error);
+ error = dart.dcall(_nonNullError, error);
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_addEventError]());
- let replacement = Zone.current.errorCallback(error, stackTrace);
+ dart.throw(dart.dcall(this[_addEventError]));
+ let replacement = dart.dcall(Zone.current.errorCallback, error, stackTrace);
if (replacement != null) {
- error = _nonNullError(replacement.error);
+ error = dart.dcall(_nonNullError, replacement.error);
stackTrace = replacement.stackTrace;
}
- this[_sendError](error, stackTrace);
+ dart.dcall(this[_sendError], error, stackTrace);
}
close() {
if (dart.notNull(this.isClosed)) {
@@ -1447,37 +1446,37 @@ dart_library.library('dart/async', null, /* Imports */[
return this[_doneFuture];
}
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_addEventError]());
+ dart.throw(dart.dcall(this[_addEventError]));
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController$()._STATE_CLOSED);
- let doneFuture = this[_ensureDoneFuture]();
- this[_sendDone]();
+ let doneFuture = dart.dcall(this[_ensureDoneFuture]);
+ dart.dcall(this[_sendDone]);
return doneFuture;
}
get done() {
- return this[_ensureDoneFuture]();
+ return dart.dcall(this[_ensureDoneFuture]);
}
addStream(stream, opts) {
dart.as(stream, Stream$(T));
let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_addEventError]());
+ dart.throw(dart.dcall(this[_addEventError]));
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController$()._STATE_ADDSTREAM);
this[_addStreamState] = new (_AddStreamState$(T))(this, stream, cancelOnError);
return this[_addStreamState].addStreamFuture;
}
[_add](data) {
dart.as(data, T);
- this[_sendData](data);
+ dart.dcall(this[_sendData], data);
}
[_addError](error, stackTrace) {
- this[_sendError](error, stackTrace);
+ dart.dcall(this[_sendError], error, stackTrace);
}
[_close]() {
dart.assert(this[_isAddingStream]);
let addState = this[_addStreamState];
this[_addStreamState] = null;
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController$()._STATE_ADDSTREAM);
- addState.complete();
+ dart.dcall(addState.complete);
}
[_forEachListener](action) {
dart.as(action, dart.functionType(dart.void, [_BufferingStreamSubscription$(T)]));
@@ -1489,15 +1488,15 @@ dart_library.library('dart/async', null, /* Imports */[
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))) {
+ while (!dart.notNull(dart.dcall(core.identical, link, this))) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- if (dart.notNull(subscription[_expectsEvent](id))) {
+ if (dart.notNull(dart.dcall(subscription[_expectsEvent], id))) {
subscription[_eventState] = dart.notNull(subscription[_eventState]) | dart.notNull(_BroadcastSubscription._STATE_FIRING);
action(subscription);
- subscription[_toggleEventId]();
+ dart.dcall(subscription[_toggleEventId]);
link = subscription[_next];
if (dart.notNull(subscription[_removeAfterFiring])) {
- this[_removeListener](subscription);
+ dart.dcall(this[_removeListener], subscription);
}
subscription[_eventState] = dart.notNull(subscription[_eventState]) & ~dart.notNull(_BroadcastSubscription._STATE_FIRING);
} else {
@@ -1506,15 +1505,15 @@ dart_library.library('dart/async', null, /* Imports */[
}
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController$()._STATE_FIRING);
if (dart.notNull(this[_isEmpty])) {
- this[_callOnCancel]();
+ dart.dcall(this[_callOnCancel]);
}
}
[_callOnCancel]() {
dart.assert(this[_isEmpty]);
if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayComplete])) {
- this[_doneFuture][_asyncComplete](null);
+ dart.dcall(this[_doneFuture][_asyncComplete], null);
}
- _runGuarded(this[_onCancel]);
+ dart.dcall(_runGuarded, this[_onCancel]);
}
}
_BroadcastStreamController[dart.implements] = () => [StreamController$(T), _StreamControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _EventDispatch$(T)];
@@ -1560,36 +1559,36 @@ dart_library.library('dart/async', null, /* Imports */[
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);
+ dart.dcall(subscription[_add], data);
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastStreamController._STATE_FIRING);
if (dart.notNull(this[_isEmpty])) {
- this[_callOnCancel]();
+ dart.dcall(this[_callOnCancel]);
}
return;
}
- this[_forEachListener](dart.fn(subscription => {
+ dart.dcall(this[_forEachListener], dart.fn(subscription => {
dart.as(subscription, _BufferingStreamSubscription$(T));
- subscription[_add](data);
+ dart.dcall(subscription[_add], data);
}, dart.dynamic, [_BufferingStreamSubscription$(T)]));
}
[_sendError](error, stackTrace) {
if (dart.notNull(this[_isEmpty]))
return;
- this[_forEachListener](dart.fn(subscription => {
+ dart.dcall(this[_forEachListener], dart.fn(subscription => {
dart.as(subscription, _BufferingStreamSubscription$(T));
- subscription[_addError](error, stackTrace);
+ dart.dcall(subscription[_addError], error, stackTrace);
}, dart.dynamic, [_BufferingStreamSubscription$(T)]));
}
[_sendDone]() {
if (!dart.notNull(this[_isEmpty])) {
- this[_forEachListener](dart.as(dart.fn(subscription => {
+ dart.dcall(this[_forEachListener], dart.fn(subscription => {
dart.as(subscription, _BroadcastSubscription$(T));
- subscription[_close]();
- }, dart.dynamic, [_BroadcastSubscription$(T)]), __CastType2));
+ dart.dcall(subscription[_close]);
+ }, dart.dynamic, [_BroadcastSubscription$(T)]));
} else {
dart.assert(this[_doneFuture] != null);
dart.assert(this[_doneFuture][_mayComplete]);
- this[_doneFuture][_asyncComplete](null);
+ dart.dcall(this[_doneFuture][_asyncComplete], null);
}
}
}
@@ -1611,27 +1610,27 @@ dart_library.library('dart/async', null, /* Imports */[
}
[_sendData](data) {
dart.as(data, T);
- for (let link = this[_next]; !dart.notNull(core.identical(link, this)); link = link[_next]) {
+ for (let link = this[_next]; !dart.notNull(dart.dcall(core.identical, link, this)); link = link[_next]) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- subscription[_addPending](new _DelayedData(data));
+ dart.dcall(subscription[_addPending], new _DelayedData(data));
}
}
[_sendError](error, stackTrace) {
- for (let link = this[_next]; !dart.notNull(core.identical(link, this)); link = link[_next]) {
+ for (let link = this[_next]; !dart.notNull(dart.dcall(core.identical, link, this)); link = link[_next]) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- subscription[_addPending](new _DelayedError(error, stackTrace));
+ dart.dcall(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]) {
+ for (let link = this[_next]; !dart.notNull(dart.dcall(core.identical, link, this)); link = link[_next]) {
let subscription = dart.as(link, _BroadcastSubscription$(T));
- subscription[_addPending](dart.const(new _DelayedDone()));
+ dart.dcall(subscription[_addPending], dart.const(new _DelayedDone()));
}
} else {
dart.assert(this[_doneFuture] != null);
dart.assert(this[_doneFuture][_mayComplete]);
- this[_doneFuture][_asyncComplete](null);
+ dart.dcall(this[_doneFuture][_asyncComplete], null);
}
}
}
@@ -1660,49 +1659,49 @@ dart_library.library('dart/async', null, /* Imports */[
if (this[_pending] == null) {
this[_pending] = new _StreamImplEvents();
}
- this[_pending].add(event);
+ dart.dcall(this[_pending].add, event);
}
add(data) {
dart.as(data, T);
if (!dart.notNull(this.isClosed) && dart.notNull(this[_isFiring])) {
- this[_addPendingEvent](new (_DelayedData$(T))(data));
+ dart.dcall(this[_addPendingEvent], new (_DelayedData$(T))(data));
return;
}
- super.add(data);
+ dart.dcall(super.add, data);
while (dart.notNull(this[_hasPending])) {
- this[_pending].handleNext(this);
+ dart.dcall(this[_pending].handleNext, this);
}
}
addError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
if (!dart.notNull(this.isClosed) && dart.notNull(this[_isFiring])) {
- this[_addPendingEvent](new _DelayedError(error, stackTrace));
+ dart.dcall(this[_addPendingEvent], new _DelayedError(error, stackTrace));
return;
}
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_addEventError]());
- this[_sendError](error, stackTrace);
+ dart.throw(dart.dcall(this[_addEventError]));
+ dart.dcall(this[_sendError], error, stackTrace);
while (dart.notNull(this[_hasPending])) {
- this[_pending].handleNext(this);
+ dart.dcall(this[_pending].handleNext, this);
}
}
close() {
if (!dart.notNull(this.isClosed) && dart.notNull(this[_isFiring])) {
- this[_addPendingEvent](dart.const(new _DelayedDone()));
+ dart.dcall(this[_addPendingEvent], dart.const(new _DelayedDone()));
this[_state] = dart.notNull(this[_state]) | dart.notNull(_BroadcastStreamController._STATE_CLOSED);
return super.done;
}
- let result = super.close();
+ let result = dart.dcall(super.close);
dart.assert(!dart.notNull(this[_hasPending]));
return result;
}
[_callOnCancel]() {
if (dart.notNull(this[_hasPending])) {
- this[_pending].clear();
+ dart.dcall(this[_pending].clear);
this[_pending] = null;
}
- super[_callOnCancel]();
+ dart.dcall(super[_callOnCancel]);
}
}
_AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)];
@@ -1734,11 +1733,11 @@ dart_library.library('dart/async', null, /* Imports */[
if (resumeSignal === void 0)
resumeSignal = null;
if (resumeSignal != null)
- resumeSignal.then(dart.bind(this, _resume));
+ dart.dcall(resumeSignal.then, dart.bind(this, _resume));
this[_pauseCount] = dart.notNull(this[_pauseCount]) + 1;
}
resume() {
- this[_resume](null);
+ dart.dcall(this[_resume], null);
}
[_resume](_) {
if (dart.notNull(this[_pauseCount]) > 0) {
@@ -1773,11 +1772,6 @@ dart_library.library('dart/async', null, /* Imports */[
return _DoneSubscription;
});
let _DoneSubscription = _DoneSubscription$();
- let __CastType2$ = dart.generic(function(T) {
- let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.void, [_BufferingStreamSubscription$(T)]));
- return __CastType2;
- });
- let __CastType2 = __CastType2$();
class DeferredLibrary extends core.Object {
DeferredLibrary(libraryName, opts) {
let uri = opts && 'uri' in opts ? opts.uri : null;
@@ -1811,12 +1805,12 @@ dart_library.library('dart/async', null, /* Imports */[
class Future extends core.Object {
static new(computation) {
let result = new (_Future$(T))();
- Timer.run(dart.fn(() => {
+ dart.dcall(Timer.run, dart.fn(() => {
try {
- result[_complete](computation());
+ dart.dcall(result[_complete], computation());
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(result, e, s);
+ dart.dcall(_completeWithErrorCallback, result, e, s);
}
}));
@@ -1824,12 +1818,12 @@ dart_library.library('dart/async', null, /* Imports */[
}
static microtask(computation) {
let result = new (_Future$(T))();
- scheduleMicrotask(dart.fn(() => {
+ dart.dcall(scheduleMicrotask, dart.fn(() => {
try {
- result[_complete](computation());
+ dart.dcall(result[_complete], computation());
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(result, e, s);
+ dart.dcall(_completeWithErrorCallback, result, e, s);
}
}));
@@ -1853,11 +1847,11 @@ dart_library.library('dart/async', null, /* Imports */[
static error(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- error = _nonNullError(error);
- if (!dart.notNull(core.identical(Zone.current, _ROOT_ZONE))) {
- let replacement = Zone.current.errorCallback(error, stackTrace);
+ error = dart.dcall(_nonNullError, error);
+ if (!dart.notNull(dart.dcall(core.identical, Zone.current, _ROOT_ZONE))) {
+ let replacement = dart.dcall(Zone.current.errorCallback, error, stackTrace);
if (replacement != null) {
- error = _nonNullError(replacement.error);
+ error = dart.dcall(_nonNullError, replacement.error);
stackTrace = replacement.stackTrace;
}
}
@@ -1869,10 +1863,10 @@ dart_library.library('dart/async', null, /* Imports */[
let result = new (_Future$(T))();
Timer.new(duration, dart.fn(() => {
try {
- result[_complete](computation == null ? null : computation());
+ dart.dcall(result[_complete], computation == null ? null : computation());
} catch (e) {
let s = dart.stackTrace(e);
- _completeWithErrorCallback(result, e, s);
+ dart.dcall(_completeWithErrorCallback, result, e, s);
}
}));
@@ -1901,25 +1895,25 @@ dart_library.library('dart/async', null, /* Imports */[
}
values = null;
if (remaining == 0 || dart.notNull(eagerError)) {
- result[_completeError](theError, dart.as(theStackTrace, core.StackTrace));
+ dart.dcall(result[_completeError], theError, theStackTrace);
} else {
error = theError;
stackTrace = dart.as(theStackTrace, core.StackTrace);
}
} else if (remaining == 0 && !dart.notNull(eagerError)) {
- result[_completeError](error, stackTrace);
+ dart.dcall(result[_completeError], error, stackTrace);
}
}
dart.fn(handleError, dart.void, [dart.dynamic, dart.dynamic]);
for (let future of futures) {
let pos = remaining;
remaining = dart.notNull(pos) + 1;
- future.then(dart.fn(value => {
+ dart.dcall(future.then, dart.fn(value => {
remaining = dart.notNull(remaining) - 1;
if (values != null) {
values[dartx.set](pos, value);
if (remaining == 0) {
- result[_completeWithValue](values);
+ dart.dcall(result[_completeWithValue], values);
}
} else {
if (cleanUp != null && value != null) {
@@ -1928,7 +1922,7 @@ dart_library.library('dart/async', null, /* Imports */[
}));
}
if (remaining == 0 && !dart.notNull(eagerError)) {
- result[_completeError](error, stackTrace);
+ dart.dcall(result[_completeError], error, stackTrace);
}
}
}, dart.dynamic, [core.Object]), {onError: handleError});
@@ -1942,21 +1936,21 @@ dart_library.library('dart/async', null, /* Imports */[
static forEach(input, f) {
dart.as(f, dart.functionType(dart.dynamic, [dart.dynamic]));
let iterator = input[dartx.iterator];
- return Future$().doWhile(dart.fn(() => {
- if (!dart.notNull(iterator.moveNext()))
+ return dart.dcall(Future$().doWhile, dart.fn(() => {
+ if (!dart.notNull(dart.dcall(iterator.moveNext)))
return false;
- return Future$().sync(dart.fn(() => dart.dcall(f, iterator.current))).then(dart.fn(_ => true, core.bool, [dart.dynamic]));
+ return dart.dcall(Future$().sync(dart.fn(() => dart.dcall(f, iterator.current))).then, dart.fn(_ => true, core.bool, [dart.dynamic]));
}));
}
static doWhile(f) {
dart.as(f, dart.functionType(dart.dynamic, []));
let doneSignal = new _Future();
let nextIteration = null;
- nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => {
+ nextIteration = dart.dcall(Zone.current.bindUnaryCallback, dart.fn(keepGoing => {
if (dart.notNull(keepGoing)) {
- Future$().sync(f).then(dart.as(nextIteration, __CastType4), {onError: dart.bind(doneSignal, _completeError)});
+ dart.dcall(Future$().sync(f).then, nextIteration, {onError: dart.bind(doneSignal, _completeError)});
} else {
- doneSignal[_complete](null);
+ dart.dcall(doneSignal[_complete], null);
}
}, dart.dynamic, [core.bool]), {runGuarded: true});
dart.dcall(nextIteration, true);
@@ -2026,19 +2020,18 @@ dart_library.library('dart/async', null, /* Imports */[
});
let Completer = Completer$();
function _completeWithErrorCallback(result, error, stackTrace) {
- let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core.StackTrace));
+ let replacement = dart.dcall(Zone.current.errorCallback, error, stackTrace);
if (replacement != null) {
- error = _nonNullError(replacement.error);
+ error = dart.dcall(_nonNullError, replacement.error);
stackTrace = replacement.stackTrace;
}
- result[_completeError](error, dart.as(stackTrace, core.StackTrace));
+ dart.dcall(result[_completeError], error, stackTrace);
}
dart.fn(_completeWithErrorCallback, () => dart.definiteFunctionType(dart.void, [_Future, dart.dynamic, dart.dynamic]));
function _nonNullError(error) {
return error != null ? error : new core.NullThrownError();
}
dart.fn(_nonNullError, core.Object, [core.Object]);
- let __CastType4 = dart.typedef('__CastType4', () => dart.functionType(dart.dynamic, [dart.dynamic]));
let _FutureOnValue$ = dart.generic(function(T) {
let _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionType(dart.dynamic, [T]));
return _FutureOnValue;
@@ -2054,15 +2047,15 @@ dart_library.library('dart/async', null, /* Imports */[
completeError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- error = _nonNullError(error);
+ error = dart.dcall(_nonNullError, error);
if (!dart.notNull(this.future[_mayComplete]))
dart.throw(new core.StateError("Future already completed"));
- let replacement = Zone.current.errorCallback(error, stackTrace);
+ let replacement = dart.dcall(Zone.current.errorCallback, error, stackTrace);
if (replacement != null) {
- error = _nonNullError(replacement.error);
+ error = dart.dcall(_nonNullError, replacement.error);
stackTrace = replacement.stackTrace;
}
- this[_completeError](error, stackTrace);
+ dart.dcall(this[_completeError], error, stackTrace);
}
get isCompleted() {
return !dart.notNull(this.future[_mayComplete]);
@@ -2086,10 +2079,10 @@ dart_library.library('dart/async', null, /* Imports */[
value = null;
if (!dart.notNull(this.future[_mayComplete]))
dart.throw(new core.StateError("Future already completed"));
- this.future[_asyncComplete](value);
+ dart.dcall(this.future[_asyncComplete], value);
}
[_completeError](error, stackTrace) {
- this.future[_asyncCompleteError](error, stackTrace);
+ dart.dcall(this.future[_asyncCompleteError], error, stackTrace);
}
}
dart.setSignature(_AsyncCompleter, {
@@ -2111,10 +2104,10 @@ dart_library.library('dart/async', null, /* Imports */[
value = null;
if (!dart.notNull(this.future[_mayComplete]))
dart.throw(new core.StateError("Future already completed"));
- this.future[_complete](value);
+ dart.dcall(this.future[_complete], value);
}
[_completeError](error, stackTrace) {
- this.future[_completeError](error, stackTrace);
+ dart.dcall(this.future[_completeError], error, stackTrace);
}
}
dart.setSignature(_SyncCompleter, {
@@ -2235,7 +2228,7 @@ dart_library.library('dart/async', null, /* Imports */[
this[_zone] = Zone.current;
this[_state] = _Future$()._INCOMPLETE;
this[_resultOrListeners] = null;
- this[_asyncComplete](value);
+ dart.dcall(this[_asyncComplete], value);
}
immediateError(error, stackTrace) {
if (stackTrace === void 0)
@@ -2243,7 +2236,7 @@ dart_library.library('dart/async', null, /* Imports */[
this[_zone] = Zone.current;
this[_state] = _Future$()._INCOMPLETE;
this[_resultOrListeners] = null;
- this[_asyncCompleteError](error, stackTrace);
+ dart.dcall(this[_asyncCompleteError], error, stackTrace);
}
get [_mayComplete]() {
return this[_state] == _Future$()._INCOMPLETE;
@@ -2273,34 +2266,34 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(f, dart.functionType(dart.dynamic, [T]));
let onError = opts && 'onError' in opts ? opts.onError : null;
let result = new (_Future$())();
- if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) {
- f = dart.as(result[_zone].registerUnaryCallback(f), __CastType6);
+ if (!dart.notNull(dart.dcall(core.identical, result[_zone], _ROOT_ZONE))) {
+ f = dart.as(dart.dcall(result[_zone].registerUnaryCallback, f), __CastType0);
if (onError != null) {
- onError = _registerErrorHandler(onError, result[_zone]);
+ onError = dart.dcall(_registerErrorHandler, onError, result[_zone]);
}
}
- this[_addListener](new _FutureListener.then(result, f, onError));
+ dart.dcall(this[_addListener], new _FutureListener.then(result, f, onError));
return result;
}
catchError(onError, opts) {
let test = opts && 'test' in opts ? opts.test : null;
dart.as(test, dart.functionType(core.bool, [dart.dynamic]));
let result = new (_Future$())();
- if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) {
- onError = _registerErrorHandler(onError, result[_zone]);
+ if (!dart.notNull(dart.dcall(core.identical, result[_zone], _ROOT_ZONE))) {
+ onError = dart.dcall(_registerErrorHandler, onError, result[_zone]);
if (test != null)
- test = dart.as(result[_zone].registerUnaryCallback(test), __CastType8);
+ test = dart.as(dart.dcall(result[_zone].registerUnaryCallback, test), __CastType2);
}
- this[_addListener](new _FutureListener.catchError(result, onError, test));
+ dart.dcall(this[_addListener], new _FutureListener.catchError(result, onError, test));
return result;
}
whenComplete(action) {
dart.as(action, dart.functionType(dart.dynamic, []));
let result = new (_Future$(T))();
- if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) {
- action = result[_zone].registerCallback(action);
+ if (!dart.notNull(dart.dcall(core.identical, result[_zone], _ROOT_ZONE))) {
+ action = dart.dcall(result[_zone].registerCallback, action);
}
- this[_addListener](new _FutureListener.whenComplete(result, action));
+ dart.dcall(this[_addListener], new _FutureListener.whenComplete(result, action));
return dart.as(result, Future$(T));
}
asStream() {
@@ -2331,13 +2324,13 @@ dart_library.library('dart/async', null, /* Imports */[
this[_resultOrListeners] = error;
}
[_setError](error, stackTrace) {
- this[_setErrorObject](new AsyncError(error, stackTrace));
+ dart.dcall(this[_setErrorObject], new AsyncError(error, stackTrace));
}
[_addListener](listener) {
dart.assert(listener[_nextListener] == null);
if (dart.notNull(this[_isComplete])) {
- this[_zone].scheduleMicrotask(dart.fn((() => {
- _Future$()._propagateToListeners(this, listener);
+ dart.dcall(this[_zone].scheduleMicrotask, dart.fn((() => {
+ dart.dcall(_Future$()._propagateToListeners, this, listener);
}).bind(this)));
} else {
listener[_nextListener] = dart.as(this[_resultOrListeners], _FutureListener);
@@ -2361,14 +2354,14 @@ dart_library.library('dart/async', null, /* Imports */[
dart.assert(!dart.notNull(target[_isComplete]));
dart.assert(!dart.is(source, _Future$()));
target[_isChained] = true;
- source.then(dart.fn(value => {
+ dart.dcall(source.then, dart.fn(value => {
dart.assert(target[_isChained]);
- target[_completeWithValue](value);
+ dart.dcall(target[_completeWithValue], value);
}), {onError: dart.fn((error, stackTrace) => {
if (stackTrace === void 0)
stackTrace = null;
dart.assert(target[_isChained]);
- target[_completeError](error, dart.as(stackTrace, core.StackTrace));
+ dart.dcall(target[_completeError], error, stackTrace);
}, dart.dynamic, [dart.dynamic], [dart.dynamic])});
}
static _chainCoreFuture(source, target) {
@@ -2377,39 +2370,39 @@ dart_library.library('dart/async', null, /* Imports */[
target[_isChained] = true;
let listener = new _FutureListener.chain(target);
if (dart.notNull(source[_isComplete])) {
- _Future$()._propagateToListeners(source, listener);
+ dart.dcall(_Future$()._propagateToListeners, source, listener);
} else {
- source[_addListener](listener);
+ dart.dcall(source[_addListener], listener);
}
}
[_complete](value) {
dart.assert(!dart.notNull(this[_isComplete]));
if (dart.is(value, Future)) {
if (dart.is(value, _Future$())) {
- _Future$()._chainCoreFuture(dart.as(value, _Future$()), this);
+ dart.dcall(_Future$()._chainCoreFuture, value, this);
} else {
- _Future$()._chainForeignFuture(dart.as(value, Future), this);
+ dart.dcall(_Future$()._chainForeignFuture, value, this);
}
} else {
- let listeners = this[_removeListeners]();
- this[_setValue](dart.as(value, T));
- _Future$()._propagateToListeners(this, listeners);
+ let listeners = dart.dcall(this[_removeListeners]);
+ dart.dcall(this[_setValue], value);
+ dart.dcall(_Future$()._propagateToListeners, this, listeners);
}
}
[_completeWithValue](value) {
dart.assert(!dart.notNull(this[_isComplete]));
dart.assert(!dart.is(value, Future));
- let listeners = this[_removeListeners]();
- this[_setValue](dart.as(value, T));
- _Future$()._propagateToListeners(this, listeners);
+ let listeners = dart.dcall(this[_removeListeners]);
+ dart.dcall(this[_setValue], value);
+ dart.dcall(_Future$()._propagateToListeners, this, listeners);
}
[_completeError](error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
dart.assert(!dart.notNull(this[_isComplete]));
- let listeners = this[_removeListeners]();
- this[_setError](error, stackTrace);
- _Future$()._propagateToListeners(this, listeners);
+ let listeners = dart.dcall(this[_removeListeners]);
+ dart.dcall(this[_setError], error, stackTrace);
+ dart.dcall(_Future$()._propagateToListeners, this, listeners);
}
[_asyncComplete](value) {
dart.assert(!dart.notNull(this[_isComplete]));
@@ -2419,30 +2412,30 @@ dart_library.library('dart/async', null, /* Imports */[
if (dart.is(typedFuture, _Future$())) {
let coreFuture = dart.as(typedFuture, _Future$(T));
if (dart.notNull(coreFuture[_isComplete]) && dart.notNull(coreFuture[_hasError])) {
- this[_markPendingCompletion]();
- this[_zone].scheduleMicrotask(dart.fn((() => {
- _Future$()._chainCoreFuture(coreFuture, this);
+ dart.dcall(this[_markPendingCompletion]);
+ dart.dcall(this[_zone].scheduleMicrotask, dart.fn((() => {
+ dart.dcall(_Future$()._chainCoreFuture, coreFuture, this);
}).bind(this)));
} else {
- _Future$()._chainCoreFuture(coreFuture, this);
+ dart.dcall(_Future$()._chainCoreFuture, coreFuture, this);
}
} else {
- _Future$()._chainForeignFuture(typedFuture, this);
+ dart.dcall(_Future$()._chainForeignFuture, typedFuture, this);
}
return;
} else {
let typedValue = dart.as(value, T);
}
- this[_markPendingCompletion]();
- this[_zone].scheduleMicrotask(dart.fn((() => {
- this[_completeWithValue](value);
+ dart.dcall(this[_markPendingCompletion]);
+ dart.dcall(this[_zone].scheduleMicrotask, dart.fn((() => {
+ dart.dcall(this[_completeWithValue], value);
}).bind(this)));
}
[_asyncCompleteError](error, stackTrace) {
dart.assert(!dart.notNull(this[_isComplete]));
- this[_markPendingCompletion]();
- this[_zone].scheduleMicrotask(dart.fn((() => {
- this[_completeError](error, stackTrace);
+ dart.dcall(this[_markPendingCompletion]);
+ dart.dcall(this[_zone].scheduleMicrotask, dart.fn((() => {
+ dart.dcall(this[_completeError], error, stackTrace);
}).bind(this)));
}
static _propagateToListeners(source, listeners) {
@@ -2452,7 +2445,7 @@ dart_library.library('dart/async', null, /* Imports */[
if (listeners == null) {
if (dart.notNull(hasError)) {
let asyncError = source[_error];
- source[_zone].handleUncaughtError(asyncError.error, asyncError.stackTrace);
+ dart.dcall(source[_zone].handleUncaughtError, asyncError.error, asyncError.stackTrace);
}
return;
}
@@ -2460,7 +2453,7 @@ dart_library.library('dart/async', null, /* Imports */[
let listener = listeners;
listeners = listener[_nextListener];
listener[_nextListener] = null;
- _Future$()._propagateToListeners(source, listener);
+ dart.dcall(_Future$()._propagateToListeners, source, listener);
}
let listener = listeners;
let listenerHasValue = true;
@@ -2469,18 +2462,18 @@ dart_library.library('dart/async', null, /* Imports */[
let isPropagationAborted = false;
if (dart.notNull(hasError) || dart.notNull(listener.handlesValue) || dart.notNull(listener.handlesComplete)) {
let zone = listener[_zone];
- if (dart.notNull(hasError) && !dart.notNull(source[_zone].inSameErrorZone(zone))) {
+ if (dart.notNull(hasError) && !dart.notNull(dart.dcall(source[_zone].inSameErrorZone, zone))) {
let asyncError = source[_error];
- source[_zone].handleUncaughtError(asyncError.error, asyncError.stackTrace);
+ dart.dcall(source[_zone].handleUncaughtError, asyncError.error, asyncError.stackTrace);
return;
}
let oldZone = null;
- if (!dart.notNull(core.identical(Zone.current, zone))) {
- oldZone = Zone._enter(zone);
+ if (!dart.notNull(dart.dcall(core.identical, Zone.current, zone))) {
+ oldZone = dart.dcall(Zone._enter, zone);
}
function handleValueCallback() {
try {
- listenerValueOrError = zone.runUnary(listener[_onValue], sourceValue);
+ listenerValueOrError = dart.dcall(zone.runUnary, listener[_onValue], sourceValue);
return true;
} catch (e) {
let s = dart.stackTrace(e);
@@ -2496,10 +2489,10 @@ dart_library.library('dart/async', null, /* Imports */[
if (dart.notNull(listener.hasErrorTest)) {
let test = listener[_errorTest];
try {
- matchesTest = dart.as(zone.runUnary(test, asyncError.error), core.bool);
+ matchesTest = dart.as(dart.dcall(zone.runUnary, test, asyncError.error), core.bool);
} catch (e) {
let s = dart.stackTrace(e);
- listenerValueOrError = dart.notNull(core.identical(asyncError.error, e)) ? asyncError : new AsyncError(e, s);
+ listenerValueOrError = dart.notNull(dart.dcall(core.identical, asyncError.error, e)) ? asyncError : new AsyncError(e, s);
listenerHasValue = false;
return;
}
@@ -2509,13 +2502,13 @@ dart_library.library('dart/async', null, /* Imports */[
if (dart.notNull(matchesTest) && errorCallback != null) {
try {
if (dart.is(errorCallback, ZoneBinaryCallback)) {
- listenerValueOrError = zone.runBinary(errorCallback, asyncError.error, asyncError.stackTrace);
+ listenerValueOrError = dart.dcall(zone.runBinary, errorCallback, asyncError.error, asyncError.stackTrace);
} else {
- listenerValueOrError = zone.runUnary(dart.as(errorCallback, __CastType10), asyncError.error);
+ listenerValueOrError = dart.dcall(zone.runUnary, errorCallback, asyncError.error);
}
} catch (e) {
let s = dart.stackTrace(e);
- listenerValueOrError = dart.notNull(core.identical(asyncError.error, e)) ? asyncError : new AsyncError(e, s);
+ listenerValueOrError = dart.notNull(dart.dcall(core.identical, asyncError.error, e)) ? asyncError : new AsyncError(e, s);
listenerHasValue = false;
return;
}
@@ -2530,10 +2523,10 @@ dart_library.library('dart/async', null, /* Imports */[
function handleWhenCompleteCallback() {
let completeResult = null;
try {
- completeResult = zone.run(listener[_whenCompleteAction]);
+ completeResult = dart.dcall(zone.run, listener[_whenCompleteAction]);
} catch (e) {
let s = dart.stackTrace(e);
- if (dart.notNull(hasError) && dart.notNull(core.identical(source[_error].error, e))) {
+ if (dart.notNull(hasError) && dart.notNull(dart.dcall(core.identical, source[_error].error, e))) {
listenerValueOrError = source[_error];
} else {
listenerValueOrError = new AsyncError(e, s);
@@ -2547,7 +2540,7 @@ dart_library.library('dart/async', null, /* Imports */[
result[_isChained] = true;
isPropagationAborted = true;
dart.dsend(completeResult, 'then', dart.fn(ignored => {
- _Future$()._propagateToListeners(source, new _FutureListener.chain(result));
+ dart.dcall(_Future$()._propagateToListeners, source, new _FutureListener.chain(result));
}), {onError: dart.fn((error, stackTrace) => {
if (stackTrace === void 0)
stackTrace = null;
@@ -2555,26 +2548,26 @@ dart_library.library('dart/async', null, /* Imports */[
completeResult = new (_Future$())();
dart.dsend(completeResult, _setError, error, stackTrace);
}
- _Future$()._propagateToListeners(dart.as(completeResult, _Future$()), new _FutureListener.chain(result));
+ dart.dcall(_Future$()._propagateToListeners, completeResult, new _FutureListener.chain(result));
}, dart.dynamic, [dart.dynamic], [dart.dynamic])});
}
}
dart.fn(handleWhenCompleteCallback, dart.void, []);
if (!dart.notNull(hasError)) {
if (dart.notNull(listener.handlesValue)) {
- listenerHasValue = handleValueCallback();
+ listenerHasValue = dart.dcall(handleValueCallback);
}
} else {
- handleError();
+ dart.dcall(handleError);
}
if (dart.notNull(listener.handlesComplete)) {
- handleWhenCompleteCallback();
+ dart.dcall(handleWhenCompleteCallback);
}
if (oldZone != null)
- Zone._leave(oldZone);
+ dart.dcall(Zone._leave, oldZone);
if (dart.notNull(isPropagationAborted))
return;
- if (dart.notNull(listenerHasValue) && !dart.notNull(core.identical(sourceValue, listenerValueOrError)) && dart.is(listenerValueOrError, Future)) {
+ if (dart.notNull(listenerHasValue) && !dart.notNull(dart.dcall(core.identical, sourceValue, listenerValueOrError)) && dart.is(listenerValueOrError, Future)) {
let chainSource = dart.as(listenerValueOrError, Future);
let result = listener.result;
if (dart.is(chainSource, _Future$())) {
@@ -2584,21 +2577,21 @@ dart_library.library('dart/async', null, /* Imports */[
listeners = new _FutureListener.chain(result);
continue;
} else {
- _Future$()._chainCoreFuture(chainSource, result);
+ dart.dcall(_Future$()._chainCoreFuture, chainSource, result);
}
} else {
- _Future$()._chainForeignFuture(chainSource, result);
+ dart.dcall(_Future$()._chainForeignFuture, chainSource, result);
}
return;
}
}
let result = listener.result;
- listeners = result[_removeListeners]();
+ listeners = dart.dcall(result[_removeListeners]);
if (dart.notNull(listenerHasValue)) {
- result[_setValue](listenerValueOrError);
+ dart.dcall(result[_setValue], listenerValueOrError);
} else {
let asyncError = dart.as(listenerValueOrError, AsyncError);
- result[_setErrorObject](asyncError);
+ dart.dcall(result[_setErrorObject], asyncError);
}
source = result;
}
@@ -2612,31 +2605,31 @@ dart_library.library('dart/async', null, /* Imports */[
let timer = null;
if (onTimeout == null) {
timer = Timer.new(timeLimit, dart.fn(() => {
- result[_completeError](new TimeoutException("Future not completed", timeLimit));
+ dart.dcall(result[_completeError], new TimeoutException("Future not completed", timeLimit));
}));
} else {
let zone = Zone.current;
- onTimeout = zone.registerCallback(onTimeout);
+ onTimeout = dart.dcall(zone.registerCallback, onTimeout);
timer = Timer.new(timeLimit, dart.fn(() => {
try {
- result[_complete](zone.run(onTimeout));
+ dart.dcall(result[_complete], dart.dcall(zone.run, onTimeout));
} catch (e) {
let s = dart.stackTrace(e);
- result[_completeError](e, s);
+ dart.dcall(result[_completeError], e, s);
}
}));
}
- this.then(dart.fn(v => {
+ dart.dcall(this.then, dart.fn(v => {
dart.as(v, T);
if (dart.notNull(timer.isActive)) {
- timer.cancel();
- result[_completeWithValue](v);
+ dart.dcall(timer.cancel);
+ dart.dcall(result[_completeWithValue], v);
}
}, dart.dynamic, [T]), {onError: dart.fn((e, s) => {
if (dart.notNull(timer.isActive)) {
- timer.cancel();
- result[_completeError](e, dart.as(s, core.StackTrace));
+ dart.dcall(timer.cancel);
+ dart.dcall(result[_completeError], e, s);
}
})});
return result;
@@ -2684,13 +2677,12 @@ dart_library.library('dart/async', null, /* Imports */[
_Future._CHAINED = 2;
_Future._VALUE = 4;
_Future._ERROR = 8;
- let __CastType6$ = dart.generic(function(T) {
- let __CastType6 = dart.typedef('__CastType6', () => dart.functionType(dart.dynamic, [T]));
- return __CastType6;
+ let __CastType0$ = dart.generic(function(T) {
+ let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dynamic, [T]));
+ return __CastType0;
});
- let __CastType6 = __CastType6$();
- let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.bool, [dart.dynamic]));
- let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.dynamic, [dart.dynamic]));
+ let __CastType0 = __CastType0$();
+ let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(core.bool, [dart.dynamic]));
let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(dart.void, []));
class _AsyncCallbackEntry extends core.Object {
_AsyncCallbackEntry(callback) {
@@ -2712,19 +2704,19 @@ dart_library.library('dart/async', null, /* Imports */[
exports._nextCallback = entry.next;
if (exports._nextCallback == null)
exports._lastCallback = null;
- entry.callback();
+ dart.dcall(entry.callback);
}
}
dart.fn(_asyncRunCallbackLoop, dart.void, []);
function _asyncRunCallback() {
exports._isInCallbackLoop = true;
try {
- _asyncRunCallbackLoop();
+ dart.dcall(_asyncRunCallbackLoop);
} finally {
exports._lastPriorityCallback = null;
exports._isInCallbackLoop = false;
if (exports._nextCallback != null)
- _AsyncRun._scheduleImmediate(_asyncRunCallback);
+ dart.dcall(_AsyncRun._scheduleImmediate, _asyncRunCallback);
}
}
dart.fn(_asyncRunCallback, dart.void, []);
@@ -2732,7 +2724,7 @@ dart_library.library('dart/async', null, /* Imports */[
if (exports._nextCallback == null) {
exports._nextCallback = exports._lastCallback = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback));
if (!dart.notNull(exports._isInCallbackLoop)) {
- _AsyncRun._scheduleImmediate(_asyncRunCallback);
+ dart.dcall(_AsyncRun._scheduleImmediate, _asyncRunCallback);
}
} else {
let newEntry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback));
@@ -2744,7 +2736,7 @@ dart_library.library('dart/async', null, /* Imports */[
function _schedulePriorityAsyncCallback(callback) {
let entry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback));
if (exports._nextCallback == null) {
- _scheduleAsyncCallback(callback);
+ dart.dcall(_scheduleAsyncCallback, callback);
exports._lastPriorityCallback = exports._lastCallback;
} else if (exports._lastPriorityCallback == null) {
entry.next = exports._nextCallback;
@@ -2760,11 +2752,11 @@ dart_library.library('dart/async', null, /* Imports */[
}
dart.fn(_schedulePriorityAsyncCallback, dart.void, [dart.dynamic]);
function scheduleMicrotask(callback) {
- if (dart.notNull(core.identical(_ROOT_ZONE, Zone.current))) {
- _rootScheduleMicrotask(null, null, _ROOT_ZONE, callback);
+ if (dart.notNull(dart.dcall(core.identical, _ROOT_ZONE, Zone.current))) {
+ dart.dcall(_rootScheduleMicrotask, null, null, _ROOT_ZONE, callback);
return;
}
- Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuarded: true}));
+ dart.dcall(Zone.current.scheduleMicrotask, dart.dcall(Zone.current.bindCallback, callback, {runGuarded: true}));
}
dart.fn(scheduleMicrotask, dart.void, [dart.functionType(dart.void, [])]);
class _AsyncRun extends core.Object {
@@ -2780,7 +2772,7 @@ dart_library.library('dart/async', null, /* Imports */[
let span = self.document.createElement("span");
let storedCallback = null;
function internalCallback(_) {
- _isolate_helper.leaveJsAsync();
+ dart.dcall(_isolate_helper.leaveJsAsync);
let f = storedCallback;
storedCallback = null;
dart.dcall(f);
@@ -2791,7 +2783,7 @@ dart_library.library('dart/async', null, /* Imports */[
observer.observe(div, {childList: true});
return dart.fn(callback => {
dart.assert(storedCallback == null);
- _isolate_helper.enterJsAsync();
+ dart.dcall(_isolate_helper.enterJsAsync);
storedCallback = callback;
div.firstChild ? div.removeChild(span) : div.appendChild(span);
}, dart.dynamic, [dart.functionType(dart.void, [])]);
@@ -2802,26 +2794,26 @@ dart_library.library('dart/async', null, /* Imports */[
}
static _scheduleImmediateJsOverride(callback) {
function internalCallback() {
- _isolate_helper.leaveJsAsync();
+ dart.dcall(_isolate_helper.leaveJsAsync);
callback();
}
dart.fn(internalCallback);
;
- _isolate_helper.enterJsAsync();
+ dart.dcall(_isolate_helper.enterJsAsync);
self.scheduleImmediate(internalCallback);
}
static _scheduleImmediateWithSetImmediate(callback) {
function internalCallback() {
- _isolate_helper.leaveJsAsync();
+ dart.dcall(_isolate_helper.leaveJsAsync);
callback();
}
dart.fn(internalCallback);
;
- _isolate_helper.enterJsAsync();
+ dart.dcall(_isolate_helper.enterJsAsync);
self.setImmediate(internalCallback);
}
static _scheduleImmediateWithTimer(callback) {
- Timer._createTimer(core.Duration.ZERO, callback);
+ dart.dcall(Timer._createTimer, core.Duration.ZERO, callback);
}
}
dart.setSignature(_AsyncRun, {
@@ -2836,7 +2828,7 @@ dart_library.library('dart/async', null, /* Imports */[
});
dart.defineLazyProperties(_AsyncRun, {
get scheduleImmediateClosure() {
- return _AsyncRun._initializeScheduleImmediate();
+ return dart.dcall(_AsyncRun._initializeScheduleImmediate);
}
});
let StreamSubscription$ = dart.generic(function(T) {
@@ -2865,7 +2857,7 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)]));
let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)]));
- return this[_stream].asBroadcastStream({onListen: onListen, onCancel: onCancel});
+ return dart.dcall(this[_stream].asBroadcastStream, {onListen: onListen, onCancel: onCancel});
}
listen(onData, opts) {
dart.as(onData, dart.functionType(dart.void, [T]));
@@ -2873,7 +2865,7 @@ dart_library.library('dart/async', null, /* Imports */[
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;
- return this[_stream].listen(onData, {onError: onError, onDone: onDone, cancelOnError: cancelOnError});
+ return dart.dcall(this[_stream].listen, onData, {onError: onError, onDone: onDone, cancelOnError: cancelOnError});
}
}
dart.setSignature(StreamView, {
@@ -2934,15 +2926,15 @@ dart_library.library('dart/async', null, /* Imports */[
}
add(data) {
dart.as(data, T);
- this[_sink].add(data);
+ dart.dcall(this[_sink].add, data);
}
addError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- this[_sink].addError(error, stackTrace);
+ dart.dcall(this[_sink].addError, error, stackTrace);
}
close() {
- this[_sink].close();
+ dart.dcall(this[_sink].close);
}
}
_ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)];
@@ -2957,10 +2949,8 @@ dart_library.library('dart/async', null, /* Imports */[
return _ControllerEventSinkWrapper;
});
let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$();
- let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.void, [StreamSubscription]));
- let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]));
- let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.void, []));
- let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.void, [EventSink]));
+ let __CastType4 = dart.typedef('__CastType4', () => dart.functionType(dart.void, [StreamSubscription]));
+ let __CastType6 = dart.typedef('__CastType6', () => dart.functionType(dart.void, [EventSink]));
let StreamController$ = dart.generic(function(T) {
class StreamController extends core.Object {
static new(opts) {
@@ -3093,7 +3083,7 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(source, Stream$(T));
let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_badEventState]());
+ dart.throw(dart.dcall(this[_badEventState]));
if (dart.notNull(this[_isCanceled]))
return new _Future.immediate(null);
let addState = new _StreamControllerAddStreamState(this, this[_varData], source, cancelOnError);
@@ -3102,7 +3092,7 @@ dart_library.library('dart/async', null, /* Imports */[
return addState.addStreamFuture;
}
get done() {
- return this[_ensureDoneFuture]();
+ return dart.dcall(this[_ensureDoneFuture]);
}
[_ensureDoneFuture]() {
if (this[_doneFuture] == null) {
@@ -3113,52 +3103,52 @@ dart_library.library('dart/async', null, /* Imports */[
add(value) {
dart.as(value, T);
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_badEventState]());
- this[_add](value);
+ dart.throw(dart.dcall(this[_badEventState]));
+ dart.dcall(this[_add], value);
}
addError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- error = _nonNullError(error);
+ error = dart.dcall(_nonNullError, error);
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_badEventState]());
- let replacement = Zone.current.errorCallback(error, stackTrace);
+ dart.throw(dart.dcall(this[_badEventState]));
+ let replacement = dart.dcall(Zone.current.errorCallback, error, stackTrace);
if (replacement != null) {
- error = _nonNullError(replacement.error);
+ error = dart.dcall(_nonNullError, replacement.error);
stackTrace = replacement.stackTrace;
}
- this[_addError](error, stackTrace);
+ dart.dcall(this[_addError], error, stackTrace);
}
close() {
if (dart.notNull(this.isClosed)) {
- return this[_ensureDoneFuture]();
+ return dart.dcall(this[_ensureDoneFuture]);
}
if (!dart.notNull(this[_mayAddEvent]))
- dart.throw(this[_badEventState]());
- this[_closeUnchecked]();
- return this[_ensureDoneFuture]();
+ dart.throw(dart.dcall(this[_badEventState]));
+ dart.dcall(this[_closeUnchecked]);
+ return dart.dcall(this[_ensureDoneFuture]);
}
[_closeUnchecked]() {
this[_state] = dart.notNull(this[_state]) | dart.notNull(_StreamController$()._STATE_CLOSED);
if (dart.notNull(this.hasListener)) {
- this[_sendDone]();
+ dart.dcall(this[_sendDone]);
} else if (dart.notNull(this[_isInitialState])) {
- this[_ensurePendingEvents]().add(dart.const(new _DelayedDone()));
+ dart.dcall(dart.dcall(this[_ensurePendingEvents]).add, dart.const(new _DelayedDone()));
}
}
[_add](value) {
dart.as(value, T);
if (dart.notNull(this.hasListener)) {
- this[_sendData](value);
+ dart.dcall(this[_sendData], value);
} else if (dart.notNull(this[_isInitialState])) {
- this[_ensurePendingEvents]().add(new (_DelayedData$(T))(value));
+ dart.dcall(dart.dcall(this[_ensurePendingEvents]).add, new (_DelayedData$(T))(value));
}
}
[_addError](error, stackTrace) {
if (dart.notNull(this.hasListener)) {
- this[_sendError](error, stackTrace);
+ dart.dcall(this[_sendError], error, stackTrace);
} else if (dart.notNull(this[_isInitialState])) {
- this[_ensurePendingEvents]().add(new _DelayedError(error, stackTrace));
+ dart.dcall(dart.dcall(this[_ensurePendingEvents]).add, new _DelayedError(error, stackTrace));
}
}
[_close]() {
@@ -3166,7 +3156,7 @@ dart_library.library('dart/async', null, /* Imports */[
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
this[_varData] = addState.varData;
this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_StreamController$()._STATE_ADDSTREAM);
- addState.complete();
+ dart.dcall(addState.complete);
}
[_subscribe](onData, onError, onDone, cancelOnError) {
dart.as(onData, dart.functionType(dart.void, [T]));
@@ -3180,13 +3170,13 @@ dart_library.library('dart/async', null, /* Imports */[
if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
addState.varData = subscription;
- addState.resume();
+ dart.dcall(addState.resume);
} else {
this[_varData] = subscription;
}
- subscription[_setPendingEvents](pendingEvents);
- subscription[_guardCallback](dart.fn((() => {
- _runGuarded(this[_onListen]);
+ dart.dcall(subscription[_setPendingEvents], pendingEvents);
+ dart.dcall(subscription[_guardCallback], dart.fn((() => {
+ dart.dcall(_runGuarded, this[_onListen]);
}).bind(this)));
return dart.as(subscription, StreamSubscription$(T));
}
@@ -3195,34 +3185,34 @@ dart_library.library('dart/async', null, /* Imports */[
let result = null;
if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
- result = addState.cancel();
+ result = dart.dcall(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);
if (this[_onCancel] != null) {
if (result == null) {
try {
- result = dart.as(this[_onCancel](), Future);
+ result = dart.as(dart.dcall(this[_onCancel]), Future);
} catch (e) {
let s = dart.stackTrace(e);
result = new _Future();
- result[_asyncCompleteError](e, s);
+ dart.dcall(result[_asyncCompleteError], e, s);
}
} else {
- result = result.whenComplete(this[_onCancel]);
+ result = dart.dcall(result.whenComplete, this[_onCancel]);
}
}
let complete = (function() {
if (this[_doneFuture] != null && dart.notNull(this[_doneFuture][_mayComplete])) {
- this[_doneFuture][_asyncComplete](null);
+ dart.dcall(this[_doneFuture][_asyncComplete], null);
}
}).bind(this);
dart.fn(complete, dart.void, []);
if (result != null) {
- result = result.whenComplete(complete);
+ result = dart.dcall(result.whenComplete, complete);
} else {
- complete();
+ dart.dcall(complete);
}
return result;
}
@@ -3230,17 +3220,17 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(subscription, StreamSubscription$(T));
if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
- addState.pause();
+ dart.dcall(addState.pause);
}
- _runGuarded(this[_onPause]);
+ dart.dcall(_runGuarded, this[_onPause]);
}
[_recordResume](subscription) {
dart.as(subscription, StreamSubscription$(T));
if (dart.notNull(this[_isAddingStream])) {
let addState = dart.as(this[_varData], _StreamControllerAddStreamState);
- addState.resume();
+ dart.dcall(addState.resume);
}
- _runGuarded(this[_onResume]);
+ dart.dcall(_runGuarded, this[_onResume]);
}
}
_StreamController[dart.implements] = () => [StreamController$(T), _StreamControllerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)];
@@ -3277,13 +3267,13 @@ dart_library.library('dart/async', null, /* Imports */[
class _SyncStreamControllerDispatch extends core.Object {
[_sendData](data) {
dart.as(data, T);
- this[_subscription][_add](data);
+ dart.dcall(this[_subscription][_add], data);
}
[_sendError](error, stackTrace) {
- this[_subscription][_addError](error, stackTrace);
+ dart.dcall(this[_subscription][_addError], error, stackTrace);
}
[_sendDone]() {
- this[_subscription][_close]();
+ dart.dcall(this[_subscription][_close]);
}
}
_SyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(T)];
@@ -3301,13 +3291,13 @@ dart_library.library('dart/async', null, /* Imports */[
class _AsyncStreamControllerDispatch extends core.Object {
[_sendData](data) {
dart.as(data, T);
- this[_subscription][_addPending](new _DelayedData(data));
+ dart.dcall(this[_subscription][_addPending], new _DelayedData(data));
}
[_sendError](error, stackTrace) {
- this[_subscription][_addPending](new _DelayedError(error, stackTrace));
+ dart.dcall(this[_subscription][_addPending], new _DelayedError(error, stackTrace));
}
[_sendDone]() {
- this[_subscription][_addPending](dart.const(new _DelayedDone()));
+ dart.dcall(this[_subscription][_addPending], dart.const(new _DelayedDone()));
}
}
_AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(T)];
@@ -3388,7 +3378,7 @@ dart_library.library('dart/async', null, /* Imports */[
return null;
} catch (e) {
let s = dart.stackTrace(e);
- Zone.current.handleUncaughtError(e, s);
+ dart.dcall(Zone.current.handleUncaughtError, e, s);
}
}
@@ -3401,20 +3391,20 @@ dart_library.library('dart/async', null, /* Imports */[
}
add(data) {
dart.as(data, T);
- this[_target].add(data);
+ dart.dcall(this[_target].add, data);
}
addError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- this[_target].addError(error, stackTrace);
+ dart.dcall(this[_target].addError, error, stackTrace);
}
close() {
- return this[_target].close();
+ return dart.dcall(this[_target].close);
}
addStream(source, opts) {
dart.as(source, Stream$(T));
let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
- return this[_target].addStream(source, {cancelOnError: cancelOnError});
+ return dart.dcall(this[_target].addStream, source, {cancelOnError: cancelOnError});
}
get done() {
return this[_target].done;
@@ -3437,32 +3427,32 @@ dart_library.library('dart/async', null, /* Imports */[
class _AddStreamState extends core.Object {
_AddStreamState(controller, source, cancelOnError) {
this.addStreamFuture = new _Future();
- 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});
+ this.addSubscription = dart.dcall(source.listen, dart.bind(controller, _add), {onError: dart.notNull(cancelOnError) ? dart.dcall(_AddStreamState$().makeErrorHandler, controller) : dart.bind(controller, _addError), onDone: dart.bind(controller, _close), cancelOnError: cancelOnError});
}
static makeErrorHandler(controller) {
return dart.fn((e, s) => {
- controller[_addError](e, s);
- controller[_close]();
+ dart.dcall(controller[_addError], e, s);
+ dart.dcall(controller[_close]);
}, dart.dynamic, [dart.dynamic, core.StackTrace]);
}
pause() {
- this.addSubscription.pause();
+ dart.dcall(this.addSubscription.pause);
}
resume() {
- this.addSubscription.resume();
+ dart.dcall(this.addSubscription.resume);
}
cancel() {
- let cancel = this.addSubscription.cancel();
+ let cancel = dart.dcall(this.addSubscription.cancel);
if (cancel == null) {
- this.addStreamFuture[_asyncComplete](null);
+ dart.dcall(this.addStreamFuture[_asyncComplete], null);
return null;
}
- return cancel.whenComplete(dart.fn((() => {
- this.addStreamFuture[_asyncComplete](null);
- }).bind(this)));
+ return dart.as(dart.dsend(cancel, 'whenComplete', dart.fn((() => {
+ dart.dcall(this.addStreamFuture[_asyncComplete], null);
+ }).bind(this))), Future);
}
complete() {
- this.addStreamFuture[_asyncComplete](null);
+ dart.dcall(this.addStreamFuture[_asyncComplete], null);
}
}
dart.setSignature(_AddStreamState, {
@@ -3485,7 +3475,7 @@ dart_library.library('dart/async', null, /* Imports */[
this.varData = varData;
super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cancelOnError);
if (dart.notNull(controller.isPaused)) {
- this.addSubscription.pause();
+ dart.dcall(this.addSubscription.pause);
}
}
}
@@ -3530,7 +3520,7 @@ dart_library.library('dart/async', null, /* Imports */[
this[_isUsed] = true;
return dart.as((() => {
let _ = new _BufferingStreamSubscription(onData, onError, onDone, cancelOnError);
- _[_setPendingEvents](this[_pending]());
+ dart.dcall(_[_setPendingEvents], dart.dcall(this[_pending]));
return _;
}).bind(this)(), StreamSubscription$(T));
}
@@ -3562,12 +3552,12 @@ dart_library.library('dart/async', null, /* Imports */[
this[_state] = _PendingEvents._STATE_SCHEDULED;
return;
}
- scheduleMicrotask(dart.fn((() => {
+ dart.dcall(scheduleMicrotask, dart.fn((() => {
let oldState = this[_state];
this[_state] = _PendingEvents._STATE_UNSCHEDULED;
if (oldState == _PendingEvents._STATE_CANCELED)
return;
- this.handleNext(dispatch);
+ dart.dcall(this.handleNext, dispatch);
}).bind(this)));
this[_state] = _PendingEvents._STATE_SCHEDULED;
}
@@ -3598,24 +3588,24 @@ dart_library.library('dart/async', null, /* Imports */[
}
let isDone = null;
try {
- isDone = !dart.notNull(this[_iterator].moveNext());
+ isDone = !dart.notNull(dart.dcall(this[_iterator].moveNext));
} catch (e) {
let s = dart.stackTrace(e);
this[_iterator] = null;
- dispatch[_sendError](e, s);
+ dart.dcall(dispatch[_sendError], e, s);
return;
}
if (!dart.notNull(isDone)) {
- dispatch[_sendData](this[_iterator].current);
+ dart.dcall(dispatch[_sendData], this[_iterator].current);
} else {
this[_iterator] = null;
- dispatch[_sendDone]();
+ dart.dcall(dispatch[_sendDone]);
}
}
clear() {
if (dart.notNull(this.isScheduled))
- this.cancelSchedule();
+ dart.dcall(this.cancelSchedule);
this[_iterator] = null;
}
}
@@ -3641,7 +3631,7 @@ dart_library.library('dart/async', null, /* Imports */[
function _nullErrorHandler(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- Zone.current.handleUncaughtError(error, stackTrace);
+ dart.dcall(Zone.current.handleUncaughtError, error, stackTrace);
}
dart.fn(_nullErrorHandler, dart.void, [dart.dynamic], [core.StackTrace]);
function _nullDoneHandler() {
@@ -3664,7 +3654,7 @@ dart_library.library('dart/async', null, /* Imports */[
}
perform(dispatch) {
dart.as(dispatch, _EventDispatch$(T));
- dispatch[_sendData](this.value);
+ dart.dcall(dispatch[_sendData], this.value);
}
}
dart.setSignature(_DelayedData, {
@@ -3681,7 +3671,7 @@ dart_library.library('dart/async', null, /* Imports */[
super._DelayedEvent();
}
perform(dispatch) {
- dispatch[_sendError](this.error, this.stackTrace);
+ dart.dcall(dispatch[_sendError], this.error, this.stackTrace);
}
}
dart.setSignature(_DelayedError, {
@@ -3692,7 +3682,7 @@ dart_library.library('dart/async', null, /* Imports */[
_DelayedDone() {
}
perform(dispatch) {
- dispatch[_sendDone]();
+ dart.dcall(dispatch[_sendDone]);
}
get next() {
return null;
@@ -3732,11 +3722,11 @@ dart_library.library('dart/async', null, /* Imports */[
if (this.firstPendingEvent == null) {
this.lastPendingEvent = null;
}
- event.perform(dispatch);
+ dart.dcall(event.perform, dispatch);
}
clear() {
if (dart.notNull(this.isScheduled))
- this.cancelSchedule();
+ dart.dcall(this.cancelSchedule);
this.firstPendingEvent = this.lastPendingEvent = null;
}
}
@@ -3783,7 +3773,7 @@ dart_library.library('dart/async', null, /* Imports */[
this[_onDone] = onDone;
this[_zone] = Zone.current;
this[_state] = 0;
- this[_schedule]();
+ dart.dcall(this[_schedule]);
}
get [_isSent]() {
return (dart.notNull(this[_state]) & dart.notNull(_DoneStreamSubscription$()._DONE_SENT)) != 0;
@@ -3797,7 +3787,7 @@ dart_library.library('dart/async', null, /* Imports */[
[_schedule]() {
if (dart.notNull(this[_isScheduled]))
return;
- this[_zone].scheduleMicrotask(dart.bind(this, _sendDone));
+ dart.dcall(this[_zone].scheduleMicrotask, dart.bind(this, _sendDone));
this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubscription$()._SCHEDULED);
}
onData(handleData) {
@@ -3813,13 +3803,13 @@ dart_library.library('dart/async', null, /* Imports */[
resumeSignal = null;
this[_state] = dart.notNull(this[_state]) + dart.notNull(_DoneStreamSubscription$()._PAUSED);
if (resumeSignal != null)
- resumeSignal.whenComplete(dart.bind(this, 'resume'));
+ dart.dcall(resumeSignal.whenComplete, dart.bind(this, 'resume'));
}
resume() {
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]();
+ dart.dcall(this[_schedule]);
}
}
}
@@ -3831,7 +3821,7 @@ dart_library.library('dart/async', null, /* Imports */[
futureValue = null;
let result = new _Future();
this[_onDone] = dart.fn(() => {
- result[_completeWithValue](null);
+ dart.dcall(result[_completeWithValue], null);
});
return result;
}
@@ -3841,7 +3831,7 @@ dart_library.library('dart/async', null, /* Imports */[
return;
this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubscription$()._DONE_SENT);
if (this[_onDone] != null)
- this[_zone].runGuarded(this[_onDone]);
+ dart.dcall(this[_zone].runGuarded, this[_onDone]);
}
}
_DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)];
@@ -3876,8 +3866,8 @@ dart_library.library('dart/async', null, /* Imports */[
class _AsBroadcastStream extends Stream$(T) {
_AsBroadcastStream(source, onListenHandler, onCancelHandler) {
this[_source] = source;
- this[_onListenHandler] = dart.as(Zone.current.registerUnaryCallback(onListenHandler), _broadcastCallback);
- this[_onCancelHandler] = dart.as(Zone.current.registerUnaryCallback(onCancelHandler), _broadcastCallback);
+ this[_onListenHandler] = dart.as(dart.dcall(Zone.current.registerUnaryCallback, onListenHandler), _broadcastCallback);
+ this[_onCancelHandler] = dart.as(dart.dcall(Zone.current.registerUnaryCallback, onCancelHandler), _broadcastCallback);
this[_zone] = Zone.current;
this[_controller] = null;
this[_subscription] = null;
@@ -3897,26 +3887,26 @@ dart_library.library('dart/async', null, /* Imports */[
return new (_DoneStreamSubscription$(T))(onDone);
}
if (this[_subscription] == null) {
- this[_subscription] = this[_source].listen(dart.bind(this[_controller], 'add'), {onError: dart.bind(this[_controller], 'addError'), onDone: dart.bind(this[_controller], 'close')});
+ this[_subscription] = dart.dcall(this[_source].listen, dart.bind(this[_controller], 'add'), {onError: dart.bind(this[_controller], 'addError'), onDone: dart.bind(this[_controller], 'close')});
}
- cancelOnError = core.identical(true, cancelOnError);
- return this[_controller][_subscribe](onData, onError, onDone, cancelOnError);
+ cancelOnError = dart.dcall(core.identical, true, cancelOnError);
+ return dart.dcall(this[_controller][_subscribe], onData, onError, onDone, cancelOnError);
}
[_onCancel]() {
let shutdown = this[_controller] == null || dart.notNull(this[_controller].isClosed);
if (this[_onCancelHandler] != null) {
- this[_zone].runUnary(this[_onCancelHandler], new _BroadcastSubscriptionWrapper(this));
+ dart.dcall(this[_zone].runUnary, this[_onCancelHandler], new _BroadcastSubscriptionWrapper(this));
}
if (dart.notNull(shutdown)) {
if (this[_subscription] != null) {
- this[_subscription].cancel();
+ dart.dcall(this[_subscription].cancel);
this[_subscription] = null;
}
}
}
[_onListen]() {
if (this[_onListenHandler] != null) {
- this[_zone].runUnary(this[_onListenHandler], new _BroadcastSubscriptionWrapper(this));
+ dart.dcall(this[_zone].runUnary, this[_onListenHandler], new _BroadcastSubscriptionWrapper(this));
}
}
[_cancelSubscription]() {
@@ -3925,17 +3915,17 @@ dart_library.library('dart/async', null, /* Imports */[
let subscription = this[_subscription];
this[_subscription] = null;
this[_controller] = null;
- subscription.cancel();
+ dart.dcall(subscription.cancel);
}
[_pauseSubscription](resumeSignal) {
if (this[_subscription] == null)
return;
- this[_subscription].pause(resumeSignal);
+ dart.dcall(this[_subscription].pause, resumeSignal);
}
[_resumeSubscription]() {
if (this[_subscription] == null)
return;
- this[_subscription].resume();
+ dart.dcall(this[_subscription].resume);
}
get [_isSubscriptionPaused]() {
if (this[_subscription] == null)
@@ -3976,13 +3966,13 @@ dart_library.library('dart/async', null, /* Imports */[
pause(resumeSignal) {
if (resumeSignal === void 0)
resumeSignal = null;
- this[_stream][_pauseSubscription](resumeSignal);
+ dart.dcall(this[_stream][_pauseSubscription], resumeSignal);
}
resume() {
- this[_stream][_resumeSubscription]();
+ dart.dcall(this[_stream][_resumeSubscription]);
}
cancel() {
- this[_stream][_cancelSubscription]();
+ dart.dcall(this[_stream][_cancelSubscription]);
return null;
}
get isPaused() {
@@ -4020,7 +4010,7 @@ dart_library.library('dart/async', null, /* Imports */[
this[_current] = null;
this[_futureOrPrefetch] = null;
this[_state] = _StreamIteratorImpl$()._STATE_FOUND;
- this[_subscription] = stream.listen(dart.bind(this, _onData), {onError: dart.bind(this, _onError), onDone: dart.bind(this, _onDone), cancelOnError: true});
+ this[_subscription] = dart.dcall(stream.listen, dart.bind(this, _onData), {onError: dart.bind(this, _onError), onDone: dart.bind(this, _onDone), cancelOnError: true});
}
get current() {
return this[_current];
@@ -4045,18 +4035,18 @@ dart_library.library('dart/async', null, /* Imports */[
this[_state] = _StreamIteratorImpl$()._STATE_FOUND;
this[_current] = dart.as(this[_futureOrPrefetch], T);
this[_futureOrPrefetch] = null;
- this[_subscription].resume();
+ dart.dcall(this[_subscription].resume);
return new (_Future$(core.bool)).immediate(true);
}
case _StreamIteratorImpl$()._STATE_EXTRA_ERROR:
{
let prefetch = dart.as(this[_futureOrPrefetch], AsyncError);
- this[_clear]();
+ dart.dcall(this[_clear]);
return new (_Future$(core.bool)).immediateError(prefetch.error, prefetch.stackTrace);
}
case _StreamIteratorImpl$()._STATE_EXTRA_DONE:
{
- this[_clear]();
+ dart.dcall(this[_clear]);
return new (_Future$(core.bool)).immediate(false);
}
}
@@ -4074,12 +4064,12 @@ dart_library.library('dart/async', null, /* Imports */[
return null;
if (this[_state] == _StreamIteratorImpl$()._STATE_MOVING) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
- this[_clear]();
- hasNext[_complete](false);
+ dart.dcall(this[_clear]);
+ dart.dcall(hasNext[_complete], false);
} else {
- this[_clear]();
+ dart.dcall(this[_clear]);
}
- return subscription.cancel();
+ return dart.dcall(subscription.cancel);
}
[_onData](data) {
dart.as(data, T);
@@ -4088,10 +4078,10 @@ dart_library.library('dart/async', null, /* Imports */[
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
this[_futureOrPrefetch] = null;
this[_state] = _StreamIteratorImpl$()._STATE_FOUND;
- hasNext[_complete](true);
+ dart.dcall(hasNext[_complete], true);
return;
}
- this[_subscription].pause();
+ dart.dcall(this[_subscription].pause);
dart.assert(this[_futureOrPrefetch] == null);
this[_futureOrPrefetch] = data;
this[_state] = _StreamIteratorImpl$()._STATE_EXTRA_DATA;
@@ -4101,11 +4091,11 @@ dart_library.library('dart/async', null, /* Imports */[
stackTrace = null;
if (this[_state] == _StreamIteratorImpl$()._STATE_MOVING) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
- this[_clear]();
- hasNext[_completeError](error, stackTrace);
+ dart.dcall(this[_clear]);
+ dart.dcall(hasNext[_completeError], error, stackTrace);
return;
}
- this[_subscription].pause();
+ dart.dcall(this[_subscription].pause);
dart.assert(this[_futureOrPrefetch] == null);
this[_futureOrPrefetch] = new AsyncError(error, stackTrace);
this[_state] = _StreamIteratorImpl$()._STATE_EXTRA_ERROR;
@@ -4113,11 +4103,11 @@ dart_library.library('dart/async', null, /* Imports */[
[_onDone]() {
if (this[_state] == _StreamIteratorImpl$()._STATE_MOVING) {
let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
- this[_clear]();
- hasNext[_complete](false);
+ dart.dcall(this[_clear]);
+ dart.dcall(hasNext[_complete], false);
return;
}
- this[_subscription].pause();
+ dart.dcall(this[_subscription].pause);
this[_futureOrPrefetch] = null;
this[_state] = _StreamIteratorImpl$()._STATE_EXTRA_DONE;
}
@@ -4143,23 +4133,21 @@ dart_library.library('dart/async', null, /* Imports */[
_StreamIteratorImpl._STATE_EXTRA_DATA = 3;
_StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
_StreamIteratorImpl._STATE_EXTRA_DONE = 5;
- let __CastType20$ = dart.generic(function(T) {
- let __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart.void, [T]));
- return __CastType20;
+ let __CastType8$ = dart.generic(function(T) {
+ let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(dart.void, [T]));
+ return __CastType8;
});
- let __CastType20 = __CastType20$();
- let __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]));
- let __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart.dynamic, [dart.dynamic]));
+ let __CastType8 = __CastType8$();
function _runUserCode(userCode, onSuccess, onError) {
try {
dart.dcall(onSuccess, userCode());
} catch (e) {
let s = dart.stackTrace(e);
- let replacement = Zone.current.errorCallback(e, s);
+ let replacement = dart.dcall(Zone.current.errorCallback, e, s);
if (replacement == null) {
dart.dcall(onError, e, s);
} else {
- let error = _nonNullError(replacement.error);
+ let error = dart.dcall(_nonNullError, replacement.error);
let stackTrace = replacement.stackTrace;
dart.dcall(onError, error, stackTrace);
}
@@ -4168,33 +4156,33 @@ dart_library.library('dart/async', null, /* Imports */[
}
dart.fn(_runUserCode, dart.dynamic, [dart.functionType(dart.dynamic, []), dart.functionType(dart.dynamic, [dart.dynamic]), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace])]);
function _cancelAndError(subscription, future, error, stackTrace) {
- let cancelFuture = subscription.cancel();
+ let cancelFuture = dart.dcall(subscription.cancel);
if (dart.is(cancelFuture, Future)) {
- cancelFuture.whenComplete(dart.fn(() => future[_completeError](error, stackTrace), dart.void, []));
+ dart.dsend(cancelFuture, 'whenComplete', dart.fn(() => dart.dcall(future[_completeError], error, stackTrace), dart.void, []));
} else {
- future[_completeError](error, stackTrace);
+ dart.dcall(future[_completeError], error, stackTrace);
}
}
dart.fn(_cancelAndError, dart.void, [StreamSubscription, _Future, dart.dynamic, core.StackTrace]);
function _cancelAndErrorWithReplacement(subscription, future, error, stackTrace) {
- let replacement = Zone.current.errorCallback(error, stackTrace);
+ let replacement = dart.dcall(Zone.current.errorCallback, error, stackTrace);
if (replacement != null) {
- error = _nonNullError(replacement.error);
+ error = dart.dcall(_nonNullError, replacement.error);
stackTrace = replacement.stackTrace;
}
- _cancelAndError(subscription, future, error, stackTrace);
+ dart.dcall(_cancelAndError, subscription, future, error, stackTrace);
}
dart.fn(_cancelAndErrorWithReplacement, dart.void, [StreamSubscription, _Future, dart.dynamic, core.StackTrace]);
function _cancelAndErrorClosure(subscription, future) {
- return dart.fn((error, stackTrace) => _cancelAndError(subscription, future, error, stackTrace), dart.void, [dart.dynamic, core.StackTrace]);
+ return dart.fn((error, stackTrace) => dart.dcall(_cancelAndError, subscription, future, error, stackTrace), dart.void, [dart.dynamic, core.StackTrace]);
}
dart.fn(_cancelAndErrorClosure, dart.dynamic, [StreamSubscription, _Future]);
function _cancelAndValue(subscription, future, value) {
- let cancelFuture = subscription.cancel();
+ let cancelFuture = dart.dcall(subscription.cancel);
if (dart.is(cancelFuture, Future)) {
- cancelFuture.whenComplete(dart.fn(() => future[_complete](value), dart.void, []));
+ dart.dsend(cancelFuture, 'whenComplete', dart.fn(() => dart.dcall(future[_complete], value), dart.void, []));
} else {
- future[_complete](value);
+ dart.dcall(future[_complete], value);
}
}
dart.fn(_cancelAndValue, dart.void, [StreamSubscription, _Future, dart.dynamic]);
@@ -4216,8 +4204,8 @@ dart_library.library('dart/async', null, /* Imports */[
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;
- cancelOnError = core.identical(true, cancelOnError);
- return this[_createSubscription](onData, onError, onDone, cancelOnError);
+ cancelOnError = dart.dcall(core.identical, true, cancelOnError);
+ return dart.dcall(this[_createSubscription], onData, onError, onDone, cancelOnError);
}
[_createSubscription](onData, onError, onDone, cancelOnError) {
dart.as(onData, dart.functionType(dart.void, [T]));
@@ -4228,15 +4216,15 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(data, S);
dart.as(sink, _EventSink$(T));
let outputData = data;
- sink[_add](dart.as(outputData, T));
+ dart.dcall(sink[_add], outputData);
}
[_handleError](error, stackTrace, sink) {
dart.as(sink, _EventSink$(T));
- sink[_addError](error, stackTrace);
+ dart.dcall(sink[_addError], error, stackTrace);
}
[_handleDone](sink) {
dart.as(sink, _EventSink$(T));
- sink[_close]();
+ dart.dcall(sink[_close]);
}
}
dart.setSignature(_ForwardingStream, {
@@ -4258,46 +4246,46 @@ dart_library.library('dart/async', null, /* Imports */[
this[_stream] = stream;
this[_subscription] = null;
super._BufferingStreamSubscription(onData, onError, onDone, cancelOnError);
- this[_subscription] = this[_stream][_source].listen(dart.bind(this, _handleData), {onError: dart.bind(this, _handleError), onDone: dart.bind(this, _handleDone)});
+ this[_subscription] = dart.dcall(this[_stream][_source].listen, dart.bind(this, _handleData), {onError: dart.bind(this, _handleError), onDone: dart.bind(this, _handleDone)});
}
[_add](data) {
dart.as(data, T);
if (dart.notNull(this[_isClosed]))
return;
- super[_add](data);
+ dart.dcall(super[_add], data);
}
[_addError](error, stackTrace) {
if (dart.notNull(this[_isClosed]))
return;
- super[_addError](error, stackTrace);
+ dart.dcall(super[_addError], error, stackTrace);
}
[_onPause]() {
if (this[_subscription] == null)
return;
- this[_subscription].pause();
+ dart.dcall(this[_subscription].pause);
}
[_onResume]() {
if (this[_subscription] == null)
return;
- this[_subscription].resume();
+ dart.dcall(this[_subscription].resume);
}
[_onCancel]() {
if (this[_subscription] != null) {
let subscription = this[_subscription];
this[_subscription] = null;
- subscription.cancel();
+ dart.dcall(subscription.cancel);
}
return null;
}
[_handleData](data) {
dart.as(data, S);
- this[_stream][_handleData](data, this);
+ dart.dcall(this[_stream][_handleData], data, this);
}
[_handleError](error, stackTrace) {
- this[_stream][_handleError](error, stackTrace, this);
+ dart.dcall(this[_stream][_handleError], error, stackTrace, this);
}
[_handleDone]() {
- this[_stream][_handleDone](this);
+ dart.dcall(this[_stream][_handleDone], this);
}
}
dart.setSignature(_ForwardingStreamSubscription, {
@@ -4318,12 +4306,12 @@ dart_library.library('dart/async', null, /* Imports */[
});
let _Predicate = _Predicate$();
function _addErrorWithReplacement(sink, error, stackTrace) {
- let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core.StackTrace));
+ let replacement = dart.dcall(Zone.current.errorCallback, error, stackTrace);
if (replacement != null) {
- error = _nonNullError(replacement.error);
+ error = dart.dcall(_nonNullError, replacement.error);
stackTrace = replacement.stackTrace;
}
- sink[_addError](error, dart.as(stackTrace, core.StackTrace));
+ dart.dcall(sink[_addError], error, stackTrace);
}
dart.fn(_addErrorWithReplacement, dart.void, [_EventSink, dart.dynamic, dart.dynamic]);
let _test = Symbol('_test');
@@ -4338,15 +4326,15 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(sink, _EventSink$(T));
let satisfies = null;
try {
- satisfies = this[_test](inputEvent);
+ satisfies = dart.dcall(this[_test], inputEvent);
} catch (e) {
let s = dart.stackTrace(e);
- _addErrorWithReplacement(sink, e, s);
+ dart.dcall(_addErrorWithReplacement, sink, e, s);
return;
}
if (dart.notNull(satisfies)) {
- sink[_add](inputEvent);
+ dart.dcall(sink[_add], inputEvent);
}
}
}
@@ -4377,11 +4365,11 @@ dart_library.library('dart/async', null, /* Imports */[
outputEvent = dart.as(dart.dcall(this[_transform], inputEvent), T);
} catch (e) {
let s = dart.stackTrace(e);
- _addErrorWithReplacement(sink, e, s);
+ dart.dcall(_addErrorWithReplacement, sink, e, s);
return;
}
- sink[_add](outputEvent);
+ dart.dcall(sink[_add], outputEvent);
}
}
dart.setSignature(_MapStream, {
@@ -4402,12 +4390,12 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(inputEvent, S);
dart.as(sink, _EventSink$(T));
try {
- for (let value of this[_expand](inputEvent)) {
- sink[_add](value);
+ for (let value of dart.dcall(this[_expand], inputEvent)) {
+ dart.dcall(sink[_add], value);
}
} catch (e) {
let s = dart.stackTrace(e);
- _addErrorWithReplacement(sink, e, s);
+ dart.dcall(_addErrorWithReplacement, sink, e, s);
}
}
@@ -4435,26 +4423,26 @@ dart_library.library('dart/async', null, /* Imports */[
matches = dart.dcall(this[_test], error);
} catch (e) {
let s = dart.stackTrace(e);
- _addErrorWithReplacement(sink, e, s);
+ dart.dcall(_addErrorWithReplacement, sink, e, s);
return;
}
}
if (dart.notNull(matches)) {
try {
- _invokeErrorHandler(this[_transform], error, stackTrace);
+ dart.dcall(_invokeErrorHandler, this[_transform], error, stackTrace);
} catch (e) {
let s = dart.stackTrace(e);
- if (dart.notNull(core.identical(e, error))) {
- sink[_addError](error, stackTrace);
+ if (dart.notNull(dart.dcall(core.identical, e, error))) {
+ dart.dcall(sink[_addError], error, stackTrace);
} else {
- _addErrorWithReplacement(sink, e, s);
+ dart.dcall(_addErrorWithReplacement, sink, e, s);
}
return;
}
} else {
- sink[_addError](error, stackTrace);
+ dart.dcall(sink[_addError], error, stackTrace);
}
}
}
@@ -4478,10 +4466,10 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(inputEvent, T);
dart.as(sink, _EventSink$(T));
if (dart.notNull(this[_remaining]) > 0) {
- sink[_add](inputEvent);
+ dart.dcall(sink[_add], inputEvent);
this[_remaining] = dart.notNull(this[_remaining]) - 1;
if (this[_remaining] == 0) {
- sink[_close]();
+ dart.dcall(sink[_close]);
}
}
}
@@ -4504,18 +4492,18 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(sink, _EventSink$(T));
let satisfies = null;
try {
- satisfies = this[_test](inputEvent);
+ satisfies = dart.dcall(this[_test], inputEvent);
} catch (e) {
let s = dart.stackTrace(e);
- _addErrorWithReplacement(sink, e, s);
- sink[_close]();
+ dart.dcall(_addErrorWithReplacement, sink, e, s);
+ dart.dcall(sink[_close]);
return;
}
if (dart.notNull(satisfies)) {
- sink[_add](inputEvent);
+ dart.dcall(sink[_add], inputEvent);
} else {
- sink[_close]();
+ dart.dcall(sink[_close]);
}
}
}
@@ -4541,7 +4529,7 @@ dart_library.library('dart/async', null, /* Imports */[
this[_remaining] = dart.notNull(this[_remaining]) - 1;
return;
}
- sink[_add](inputEvent);
+ dart.dcall(sink[_add], inputEvent);
}
}
dart.setSignature(_SkipStream, {
@@ -4563,22 +4551,22 @@ dart_library.library('dart/async', null, /* Imports */[
dart.as(inputEvent, T);
dart.as(sink, _EventSink$(T));
if (dart.notNull(this[_hasFailed])) {
- sink[_add](inputEvent);
+ dart.dcall(sink[_add], inputEvent);
return;
}
let satisfies = null;
try {
- satisfies = this[_test](inputEvent);
+ satisfies = dart.dcall(this[_test], inputEvent);
} catch (e) {
let s = dart.stackTrace(e);
- _addErrorWithReplacement(sink, e, s);
+ dart.dcall(_addErrorWithReplacement, sink, e, s);
this[_hasFailed] = true;
return;
}
if (!dart.notNull(satisfies)) {
this[_hasFailed] = true;
- sink[_add](inputEvent);
+ dart.dcall(sink[_add], inputEvent);
}
}
}
@@ -4605,25 +4593,25 @@ dart_library.library('dart/async', null, /* Imports */[
[_handleData](inputEvent, sink) {
dart.as(inputEvent, T);
dart.as(sink, _EventSink$(T));
- if (dart.notNull(core.identical(this[_previous], _DistinctStream$()._SENTINEL))) {
+ if (dart.notNull(dart.dcall(core.identical, this[_previous], _DistinctStream$()._SENTINEL))) {
this[_previous] = inputEvent;
- return sink[_add](inputEvent);
+ return dart.dcall(sink[_add], inputEvent);
} else {
let isEqual = null;
try {
if (this[_equals] == null) {
isEqual = dart.equals(this[_previous], inputEvent);
} else {
- isEqual = this[_equals](dart.as(this[_previous], T), inputEvent);
+ isEqual = dart.dcall(this[_equals], this[_previous], inputEvent);
}
} catch (e) {
let s = dart.stackTrace(e);
- _addErrorWithReplacement(sink, e, s);
+ dart.dcall(_addErrorWithReplacement, sink, e, s);
return null;
}
if (!dart.notNull(isEqual)) {
- sink[_add](inputEvent);
+ dart.dcall(sink[_add], inputEvent);
this[_previous] = inputEvent;
}
}
@@ -4649,15 +4637,15 @@ dart_library.library('dart/async', null, /* Imports */[
}
add(data) {
dart.as(data, T);
- this[_sink][_add](data);
+ dart.dcall(this[_sink][_add], data);
}
addError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- this[_sink][_addError](error, stackTrace);
+ dart.dcall(this[_sink][_addError], error, stackTrace);
}
close() {
- this[_sink][_close]();
+ dart.dcall(this[_sink][_close]);
}
}
_EventSinkWrapper[dart.implements] = () => [EventSink$(T)];
@@ -4682,7 +4670,7 @@ dart_library.library('dart/async', null, /* Imports */[
super._BufferingStreamSubscription(onData, onError, onDone, cancelOnError);
let eventSink = new (_EventSinkWrapper$(T))(this);
this[_transformerSink] = mapper(eventSink);
- this[_subscription] = source.listen(dart.bind(this, _handleData), {onError: dart.bind(this, _handleError), onDone: dart.bind(this, _handleDone)});
+ this[_subscription] = dart.dcall(source.listen, dart.bind(this, _handleData), {onError: dart.bind(this, _handleError), onDone: dart.bind(this, _handleDone)});
}
get [_isSubscribed]() {
return this[_subscription] != null;
@@ -4692,43 +4680,43 @@ dart_library.library('dart/async', null, /* Imports */[
if (dart.notNull(this[_isClosed])) {
dart.throw(new core.StateError("Stream is already closed"));
}
- super[_add](data);
+ dart.dcall(super[_add], data);
}
[_addError](error, stackTrace) {
if (dart.notNull(this[_isClosed])) {
dart.throw(new core.StateError("Stream is already closed"));
}
- super[_addError](error, stackTrace);
+ dart.dcall(super[_addError], error, stackTrace);
}
[_close]() {
if (dart.notNull(this[_isClosed])) {
dart.throw(new core.StateError("Stream is already closed"));
}
- super[_close]();
+ dart.dcall(super[_close]);
}
[_onPause]() {
if (dart.notNull(this[_isSubscribed]))
- this[_subscription].pause();
+ dart.dcall(this[_subscription].pause);
}
[_onResume]() {
if (dart.notNull(this[_isSubscribed]))
- this[_subscription].resume();
+ dart.dcall(this[_subscription].resume);
}
[_onCancel]() {
if (dart.notNull(this[_isSubscribed])) {
let subscription = this[_subscription];
this[_subscription] = null;
- subscription.cancel();
+ dart.dcall(subscription.cancel);
}
return null;
}
[_handleData](data) {
dart.as(data, S);
try {
- this[_transformerSink].add(data);
+ dart.dcall(this[_transformerSink].add, data);
} catch (e) {
let s = dart.stackTrace(e);
- this[_addError](e, s);
+ dart.dcall(this[_addError], e, s);
}
}
@@ -4736,13 +4724,13 @@ dart_library.library('dart/async', null, /* Imports */[
if (stackTrace === void 0)
stackTrace = null;
try {
- this[_transformerSink].addError(error, dart.as(stackTrace, core.StackTrace));
+ dart.dcall(this[_transformerSink].addError, error, stackTrace);
} catch (e) {
let s = dart.stackTrace(e);
- if (dart.notNull(core.identical(e, error))) {
- this[_addError](error, dart.as(stackTrace, core.StackTrace));
+ if (dart.notNull(dart.dcall(core.identical, e, error))) {
+ dart.dcall(this[_addError], error, stackTrace);
} else {
- this[_addError](e, s);
+ dart.dcall(this[_addError], e, s);
}
}
@@ -4750,10 +4738,10 @@ dart_library.library('dart/async', null, /* Imports */[
[_handleDone]() {
try {
this[_subscription] = null;
- this[_transformerSink].close();
+ dart.dcall(this[_transformerSink].close);
} catch (e) {
let s = dart.stackTrace(e);
- this[_addError](e, s);
+ dart.dcall(this[_addError], e, s);
}
}
@@ -4810,7 +4798,7 @@ dart_library.library('dart/async', null, /* Imports */[
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;
- cancelOnError = core.identical(true, cancelOnError);
+ cancelOnError = dart.dcall(core.identical, true, cancelOnError);
let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic, T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, onDone, cancelOnError);
return subscription;
}
@@ -4847,15 +4835,15 @@ dart_library.library('dart/async', null, /* Imports */[
}
add(data) {
dart.as(data, S);
- return this[_handleData](data, this[_sink]);
+ return dart.dcall(this[_handleData], data, this[_sink]);
}
addError(error, stackTrace) {
if (stackTrace === void 0)
stackTrace = null;
- return this[_handleError](error, stackTrace, this[_sink]);
+ return dart.dcall(this[_handleError], error, stackTrace, this[_sink]);
}
close() {
- return this[_handleDone](this[_sink]);
+ return dart.dcall(this[_handleDone], this[_sink]);
}
}
_HandlerEventSink[dart.implements] = () => [EventSink$(S)];
@@ -4879,9 +4867,9 @@ dart_library.library('dart/async', null, /* Imports */[
super._StreamSinkTransformer(dart.as(dart.fn(outputSink => {
dart.as(outputSink, EventSink$(T));
if (handleData == null)
- handleData = dart.as(_StreamHandlerTransformer$()._defaultHandleData, __CastType27);
+ handleData = dart.as(_StreamHandlerTransformer$()._defaultHandleData, __CastType10);
if (handleError == null)
- handleError = dart.as(_StreamHandlerTransformer$()._defaultHandleError, __CastType30);
+ handleError = dart.as(_StreamHandlerTransformer$()._defaultHandleError, __CastType13);
if (handleDone == null)
handleDone = _StreamHandlerTransformer$()._defaultHandleDone;
return new (_HandlerEventSink$(S, T))(handleData, handleError, handleDone, outputSink);
@@ -4889,16 +4877,16 @@ dart_library.library('dart/async', null, /* Imports */[
}
bind(stream) {
dart.as(stream, Stream$(S));
- return super.bind(stream);
+ return dart.dcall(super.bind, stream);
}
static _defaultHandleData(data, sink) {
- sink.add(data);
+ dart.dcall(sink.add, data);
}
static _defaultHandleError(error, stackTrace, sink) {
- sink.addError(error);
+ dart.dcall(sink.addError, error);
}
static _defaultHandleDone(sink) {
- sink.close();
+ dart.dcall(sink.close);
}
}
dart.setSignature(_StreamHandlerTransformer, {
@@ -4951,11 +4939,11 @@ dart_library.library('dart/async', null, /* Imports */[
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;
- cancelOnError = core.identical(true, cancelOnError);
- let result = this[_transformer](this[_stream], cancelOnError);
- result.onData(onData);
- result.onError(onError);
- result.onDone(onDone);
+ cancelOnError = dart.dcall(core.identical, true, cancelOnError);
+ let result = dart.dcall(this[_transformer], this[_stream], cancelOnError);
+ dart.dcall(result.onData, onData);
+ dart.dcall(result.onError, onError);
+ dart.dcall(result.onDone, onDone);
return result;
}
}
@@ -4966,28 +4954,28 @@ dart_library.library('dart/async', null, /* Imports */[
return _BoundSubscriptionStream;
});
let _BoundSubscriptionStream = _BoundSubscriptionStream$();
- let __CastType27$ = dart.generic(function(S, T) {
- let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart.void, [S, EventSink$(T)]));
- return __CastType27;
+ let __CastType10$ = dart.generic(function(S, T) {
+ let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.void, [S, EventSink$(T)]));
+ return __CastType10;
});
- let __CastType27 = __CastType27$();
- let __CastType30$ = dart.generic(function(T) {
- let __CastType30 = dart.typedef('__CastType30', () => dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)]));
- return __CastType30;
+ let __CastType10 = __CastType10$();
+ let __CastType13$ = dart.generic(function(T) {
+ let __CastType13 = dart.typedef('__CastType13', () => dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)]));
+ return __CastType13;
});
- let __CastType30 = __CastType30$();
+ let __CastType13 = __CastType13$();
class Timer extends core.Object {
static new(duration, callback) {
if (dart.equals(Zone.current, Zone.ROOT)) {
- return Zone.current.createTimer(duration, callback);
+ return dart.dcall(Zone.current.createTimer, duration, callback);
}
- return Zone.current.createTimer(duration, Zone.current.bindCallback(callback, {runGuarded: true}));
+ return dart.dcall(Zone.current.createTimer, duration, dart.dcall(Zone.current.bindCallback, callback, {runGuarded: true}));
}
static periodic(duration, callback) {
if (dart.equals(Zone.current, Zone.ROOT)) {
- return Zone.current.createPeriodicTimer(duration, callback);
+ return dart.dcall(Zone.current.createPeriodicTimer, duration, callback);
}
- return Zone.current.createPeriodicTimer(duration, dart.as(Zone.current.bindUnaryCallback(callback, {runGuarded: true}), __CastType34));
+ return dart.dcall(Zone.current.createPeriodicTimer, duration, dart.dcall(Zone.current.bindUnaryCallback, callback, {runGuarded: true}));
}
static run(callback) {
Timer.new(core.Duration.ZERO, callback);
@@ -5017,7 +5005,6 @@ dart_library.library('dart/async', null, /* Imports */[
}),
names: ['run', '_createTimer', '_createPeriodicTimer']
});
- let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.void, [Timer]));
let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart.dynamic, []));
let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionType(dart.dynamic, [dart.dynamic]));
let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]));
@@ -5102,7 +5089,7 @@ dart_library.library('dart/async', null, /* Imports */[
}
_ZoneSpecification[dart.implements] = () => [ZoneSpecification];
dart.setSignature(_ZoneSpecification, {
- constructors: () => ({_ZoneSpecification: [_ZoneSpecification, [], {handleUncaughtError: HandleUncaughtErrorHandler, run: RunHandler, runUnary: RunUnaryHandler, runBinary: RunBinaryHandler, registerCallback: RegisterCallbackHandler, registerUnaryCallback: RegisterUnaryCallbackHandler, registerBinaryCallback: RegisterBinaryCallbackHandler, errorCallback: ErrorCallbackHandler, scheduleMicrotask: ScheduleMicrotaskHandler, createTimer: CreateTimerHandler, createPeriodicTimer: CreatePeriodicTimerHandler, print: PrintHandler, fork: ForkHandler}]})
+ constructors: () => ({_ZoneSpecification: [_ZoneSpecification, [], {handleUncaughtError: dart.dynamic, run: dart.dynamic, runUnary: dart.dynamic, runBinary: dart.dynamic, registerCallback: dart.dynamic, registerUnaryCallback: dart.dynamic, registerBinaryCallback: dart.dynamic, errorCallback: dart.dynamic, scheduleMicrotask: dart.dynamic, createTimer: dart.dynamic, createPeriodicTimer: dart.dynamic, print: dart.dynamic, fork: dart.dynamic}]})
});
class ZoneDelegate extends core.Object {}
class Zone extends core.Object {
@@ -5113,7 +5100,7 @@ dart_library.library('dart/async', null, /* Imports */[
}
static _enter(zone) {
dart.assert(zone != null);
- dart.assert(!dart.notNull(core.identical(zone, Zone._current)));
+ dart.assert(!dart.notNull(dart.dcall(core.identical, zone, Zone._current)));
let previous = Zone._current;
Zone._current = zone;
return previous;
@@ -5136,7 +5123,7 @@ dart_library.library('dart/async', null, /* Imports */[
_Zone() {
}
inSameErrorZone(otherZone) {
- return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.identical(this.errorZone, otherZone.errorZone));
+ return dart.notNull(dart.dcall(core.identical, this, otherZone)) || dart.notNull(dart.dcall(core.identical, this.errorZone, otherZone.errorZone));
}
}
_Zone[dart.implements] = () => [Zone];
@@ -5164,43 +5151,43 @@ dart_library.library('dart/async', null, /* Imports */[
super._Zone();
}
get [_run]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRun));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRun));
}
get [_runUnary]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunUnary));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRunUnary));
}
get [_runBinary]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRunBinary));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRunBinary));
}
get [_registerCallback]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRegisterCallback));
}
get [_registerUnaryCallback]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRegisterUnaryCallback));
}
get [_registerBinaryCallback]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallback));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootRegisterBinaryCallback));
}
get [_errorCallback]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootErrorCallback));
}
get [_scheduleMicrotask]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootScheduleMicrotask));
}
get [_createTimer]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootCreateTimer));
}
get [_createPeriodicTimer]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootCreatePeriodicTimer));
}
get [_print]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootPrint));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootPrint));
}
get [_fork]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootFork));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootFork));
}
get [_handleUncaughtError]() {
- return dart.const(new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError));
+ return dart.const(new _ZoneFunction(dart.as(_ROOT_ZONE, _Zone), _rootHandleUncaughtError));
}
get parent() {
return null;
@@ -5218,89 +5205,89 @@ dart_library.library('dart/async', null, /* Imports */[
}
runGuarded(f) {
try {
- if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
+ if (dart.notNull(dart.dcall(core.identical, _ROOT_ZONE, Zone._current))) {
return f();
}
- return _rootRun(null, null, this, f);
+ return dart.dcall(_rootRun, null, null, this, f);
} catch (e) {
let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
+ return dart.dcall(this.handleUncaughtError, e, s);
}
}
runUnaryGuarded(f, arg) {
try {
- if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
+ if (dart.notNull(dart.dcall(core.identical, _ROOT_ZONE, Zone._current))) {
return dart.dcall(f, arg);
}
- return _rootRunUnary(null, null, this, f, arg);
+ return dart.dcall(_rootRunUnary, null, null, this, f, arg);
} catch (e) {
let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
+ return dart.dcall(this.handleUncaughtError, e, s);
}
}
runBinaryGuarded(f, arg1, arg2) {
try {
- if (dart.notNull(core.identical(_ROOT_ZONE, Zone._current))) {
+ if (dart.notNull(dart.dcall(core.identical, _ROOT_ZONE, Zone._current))) {
return dart.dcall(f, arg1, arg2);
}
- return _rootRunBinary(null, null, this, f, arg1, arg2);
+ return dart.dcall(_rootRunBinary, null, null, this, f, arg1, arg2);
} catch (e) {
let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
+ return dart.dcall(this.handleUncaughtError, e, s);
}
}
bindCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
if (dart.notNull(runGuarded)) {
- return dart.fn((() => this.runGuarded(f)).bind(this));
+ return dart.fn((() => dart.dcall(this.runGuarded, f)).bind(this));
} else {
- return dart.fn((() => this.run(f)).bind(this));
+ return dart.fn((() => dart.dcall(this.run, f)).bind(this));
}
}
bindUnaryCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
if (dart.notNull(runGuarded)) {
- return dart.fn((arg => this.runUnaryGuarded(f, arg)).bind(this));
+ return dart.fn((arg => dart.dcall(this.runUnaryGuarded, f, arg)).bind(this));
} else {
- return dart.fn((arg => this.runUnary(f, arg)).bind(this));
+ return dart.fn((arg => dart.dcall(this.runUnary, f, arg)).bind(this));
}
}
bindBinaryCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
if (dart.notNull(runGuarded)) {
- return dart.fn(((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bind(this));
+ return dart.fn(((arg1, arg2) => dart.dcall(this.runBinaryGuarded, f, arg1, arg2)).bind(this));
} else {
- return dart.fn(((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this));
+ return dart.fn(((arg1, arg2) => dart.dcall(this.runBinary, f, arg1, arg2)).bind(this));
}
}
get(key) {
return null;
}
handleUncaughtError(error, stackTrace) {
- return _rootHandleUncaughtError(null, null, this, error, stackTrace);
+ return dart.dcall(_rootHandleUncaughtError, null, null, this, error, stackTrace);
}
fork(opts) {
let specification = opts && 'specification' in opts ? opts.specification : null;
let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
- return _rootFork(null, null, this, specification, zoneValues);
+ return dart.dcall(_rootFork, null, null, this, specification, zoneValues);
}
run(f) {
- if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE)))
+ if (dart.notNull(dart.dcall(core.identical, Zone._current, _ROOT_ZONE)))
return f();
- return _rootRun(null, null, this, f);
+ return dart.dcall(_rootRun, null, null, this, f);
}
runUnary(f, arg) {
- if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE)))
+ if (dart.notNull(dart.dcall(core.identical, Zone._current, _ROOT_ZONE)))
return dart.dcall(f, arg);
- return _rootRunUnary(null, null, this, f, arg);
+ return dart.dcall(_rootRunUnary, null, null, this, f, arg);
}
runBinary(f, arg1, arg2) {
- if (dart.notNull(core.identical(Zone._current, _ROOT_ZONE)))
+ if (dart.notNull(dart.dcall(core.identical, Zone._current, _ROOT_ZONE)))
return dart.dcall(f, arg1, arg2);
- return _rootRunBinary(null, null, this, f, arg1, arg2);
+ return dart.dcall(_rootRunBinary, null, null, this, f, arg1, arg2);
}
registerCallback(f) {
return f;
@@ -5315,16 +5302,16 @@ dart_library.library('dart/async', null, /* Imports */[
return null;
}
scheduleMicrotask(f) {
- _rootScheduleMicrotask(null, null, this, f);
+ dart.dcall(_rootScheduleMicrotask, null, null, this, f);
}
createTimer(duration, f) {
- return Timer._createTimer(duration, f);
+ return dart.dcall(Timer._createTimer, duration, f);
}
createPeriodicTimer(duration, f) {
- return Timer._createPeriodicTimer(duration, f);
+ return dart.dcall(Timer._createPeriodicTimer, duration, f);
}
print(line) {
- _internal.printToConsole(line);
+ dart.dcall(_internal.printToConsole, line);
}
}
dart.setSignature(_RootZone, {
@@ -5353,8 +5340,13 @@ dart_library.library('dart/async', null, /* Imports */[
})
});
let _ROOT_ZONE = dart.const(new _RootZone());
- Zone.ROOT = _ROOT_ZONE;
- Zone._current = _ROOT_ZONE;
+ Zone.ROOT = dart.as(_ROOT_ZONE, Zone);
+ dart.defineLazyProperties(Zone, {
+ get _current() {
+ return dart.as(_ROOT_ZONE, Zone);
+ },
+ set _current(_) {}
+ });
function _parentDelegate(zone) {
if (zone.parent == null)
return null;
@@ -5369,69 +5361,69 @@ dart_library.library('dart/async', null, /* Imports */[
handleUncaughtError(zone, error, stackTrace) {
let implementation = this[_delegationTarget][_handleUncaughtError];
let implZone = implementation.zone;
- return dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, error, stackTrace);
+ return dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, error, stackTrace);
}
run(zone, f) {
let implementation = this[_delegationTarget][_run];
let implZone = implementation.zone;
- return dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, f);
+ return dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, f);
}
runUnary(zone, f, arg) {
let implementation = this[_delegationTarget][_runUnary];
let implZone = implementation.zone;
- return dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, f, arg);
+ return dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, f, arg);
}
runBinary(zone, f, arg1, arg2) {
let implementation = this[_delegationTarget][_runBinary];
let implZone = implementation.zone;
- return dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, f, arg1, arg2);
+ return dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, f, arg1, arg2);
}
registerCallback(zone, f) {
let implementation = this[_delegationTarget][_registerCallback];
let implZone = implementation.zone;
- return dart.as(dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, f), ZoneCallback);
+ return dart.as(dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, f), ZoneCallback);
}
registerUnaryCallback(zone, f) {
let implementation = this[_delegationTarget][_registerUnaryCallback];
let implZone = implementation.zone;
- return dart.as(dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, f), ZoneUnaryCallback);
+ return dart.as(dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, f), ZoneUnaryCallback);
}
registerBinaryCallback(zone, f) {
let implementation = this[_delegationTarget][_registerBinaryCallback];
let implZone = implementation.zone;
- return dart.as(dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, f), ZoneBinaryCallback);
+ return dart.as(dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, f), ZoneBinaryCallback);
}
errorCallback(zone, error, stackTrace) {
let implementation = this[_delegationTarget][_errorCallback];
let implZone = implementation.zone;
- if (dart.notNull(core.identical(implZone, _ROOT_ZONE)))
+ if (dart.notNull(dart.dcall(core.identical, implZone, _ROOT_ZONE)))
return null;
- return dart.as(dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, error, stackTrace), AsyncError);
+ return dart.as(dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, error, stackTrace), AsyncError);
}
scheduleMicrotask(zone, f) {
let implementation = this[_delegationTarget][_scheduleMicrotask];
let implZone = implementation.zone;
- dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, f);
+ dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, f);
}
createTimer(zone, duration, f) {
let implementation = this[_delegationTarget][_createTimer];
let implZone = implementation.zone;
- return dart.as(dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, duration, f), Timer);
+ return dart.as(dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, duration, f), Timer);
}
createPeriodicTimer(zone, period, f) {
let implementation = this[_delegationTarget][_createPeriodicTimer];
let implZone = implementation.zone;
- return dart.as(dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, period, f), Timer);
+ return dart.as(dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, period, f), Timer);
}
print(zone, line) {
let implementation = this[_delegationTarget][_print];
let implZone = implementation.zone;
- dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, line);
+ dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, line);
}
fork(zone, specification, zoneValues) {
let implementation = this[_delegationTarget][_fork];
let implZone = implementation.zone;
- return dart.as(dart.dcall(implementation.function, implZone, _parentDelegate(implZone), zone, specification, zoneValues), Zone);
+ return dart.as(dart.dcall(implementation.function, implZone, dart.dcall(_parentDelegate, implZone), zone, specification, zoneValues), Zone);
}
}
_ZoneDelegate[dart.implements] = () => [ZoneDelegate];
@@ -5498,61 +5490,61 @@ dart_library.library('dart/async', null, /* Imports */[
}
runGuarded(f) {
try {
- return this.run(f);
+ return dart.dcall(this.run, f);
} catch (e) {
let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
+ return dart.dcall(this.handleUncaughtError, e, s);
}
}
runUnaryGuarded(f, arg) {
try {
- return this.runUnary(f, arg);
+ return dart.dcall(this.runUnary, f, arg);
} catch (e) {
let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
+ return dart.dcall(this.handleUncaughtError, e, s);
}
}
runBinaryGuarded(f, arg1, arg2) {
try {
- return this.runBinary(f, arg1, arg2);
+ return dart.dcall(this.runBinary, f, arg1, arg2);
} catch (e) {
let s = dart.stackTrace(e);
- return this.handleUncaughtError(e, s);
+ return dart.dcall(this.handleUncaughtError, e, s);
}
}
bindCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- let registered = this.registerCallback(f);
+ let registered = dart.dcall(this.registerCallback, f);
if (dart.notNull(runGuarded)) {
- return dart.fn((() => this.runGuarded(registered)).bind(this));
+ return dart.fn((() => dart.dcall(this.runGuarded, registered)).bind(this));
} else {
- return dart.fn((() => this.run(registered)).bind(this));
+ return dart.fn((() => dart.dcall(this.run, registered)).bind(this));
}
}
bindUnaryCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- let registered = this.registerUnaryCallback(f);
+ let registered = dart.dcall(this.registerUnaryCallback, f);
if (dart.notNull(runGuarded)) {
- return dart.fn((arg => this.runUnaryGuarded(registered, arg)).bind(this));
+ return dart.fn((arg => dart.dcall(this.runUnaryGuarded, registered, arg)).bind(this));
} else {
- return dart.fn((arg => this.runUnary(registered, arg)).bind(this));
+ return dart.fn((arg => dart.dcall(this.runUnary, registered, arg)).bind(this));
}
}
bindBinaryCallback(f, opts) {
let runGuarded = opts && 'runGuarded' in opts ? opts.runGuarded : true;
- let registered = this.registerBinaryCallback(f);
+ let registered = dart.dcall(this.registerBinaryCallback, f);
if (dart.notNull(runGuarded)) {
- return dart.fn(((arg1, arg2) => this.runBinaryGuarded(registered, arg1, arg2)).bind(this));
+ return dart.fn(((arg1, arg2) => dart.dcall(this.runBinaryGuarded, registered, arg1, arg2)).bind(this));
} else {
- return dart.fn(((arg1, arg2) => this.runBinary(registered, arg1, arg2)).bind(this));
+ return dart.fn(((arg1, arg2) => dart.dcall(this.runBinary, registered, arg1, arg2)).bind(this));
}
}
get(key) {
let result = this[_map].get(key);
- if (result != null || dart.notNull(this[_map].containsKey(key)))
+ if (result != null || dart.notNull(dart.dcall(this[_map].containsKey, key)))
return result;
if (this.parent != null) {
let value = this.parent.get(key);
@@ -5567,7 +5559,7 @@ dart_library.library('dart/async', null, /* Imports */[
handleUncaughtError(error, stackTrace) {
let implementation = this[_handleUncaughtError];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.dcall(implementation.function, implementation.zone, parentDelegate, this, error, stackTrace);
}
fork(opts) {
@@ -5575,76 +5567,76 @@ dart_library.library('dart/async', null, /* Imports */[
let zoneValues = opts && 'zoneValues' in opts ? opts.zoneValues : null;
let implementation = this[_fork];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.as(dart.dcall(implementation.function, implementation.zone, parentDelegate, this, specification, zoneValues), Zone);
}
run(f) {
let implementation = this[_run];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.dcall(implementation.function, implementation.zone, parentDelegate, this, f);
}
runUnary(f, arg) {
let implementation = this[_runUnary];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.dcall(implementation.function, implementation.zone, parentDelegate, this, f, arg);
}
runBinary(f, arg1, arg2) {
let implementation = this[_runBinary];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.dcall(implementation.function, implementation.zone, parentDelegate, this, f, arg1, arg2);
}
registerCallback(f) {
let implementation = this[_registerCallback];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.as(dart.dcall(implementation.function, implementation.zone, parentDelegate, this, f), ZoneCallback);
}
registerUnaryCallback(f) {
let implementation = this[_registerUnaryCallback];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.as(dart.dcall(implementation.function, implementation.zone, parentDelegate, this, f), ZoneUnaryCallback);
}
registerBinaryCallback(f) {
let implementation = this[_registerBinaryCallback];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.as(dart.dcall(implementation.function, implementation.zone, parentDelegate, this, f), ZoneBinaryCallback);
}
errorCallback(error, stackTrace) {
let implementation = this[_errorCallback];
dart.assert(implementation != null);
let implementationZone = implementation.zone;
- if (dart.notNull(core.identical(implementationZone, _ROOT_ZONE)))
+ if (dart.notNull(dart.dcall(core.identical, implementationZone, _ROOT_ZONE)))
return null;
- let parentDelegate = _parentDelegate(dart.as(implementationZone, _Zone));
+ let parentDelegate = dart.dcall(_parentDelegate, implementationZone);
return dart.as(dart.dcall(implementation.function, implementationZone, parentDelegate, this, error, stackTrace), AsyncError);
}
scheduleMicrotask(f) {
let implementation = this[_scheduleMicrotask];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.dcall(implementation.function, implementation.zone, parentDelegate, this, f);
}
createTimer(duration, f) {
let implementation = this[_createTimer];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.as(dart.dcall(implementation.function, implementation.zone, parentDelegate, this, duration, f), Timer);
}
createPeriodicTimer(duration, f) {
let implementation = this[_createPeriodicTimer];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.as(dart.dcall(implementation.function, implementation.zone, parentDelegate, this, duration, f), Timer);
}
print(line) {
let implementation = this[_print];
dart.assert(implementation != null);
- let parentDelegate = _parentDelegate(implementation.zone);
+ let parentDelegate = dart.dcall(_parentDelegate, implementation.zone);
return dart.dcall(implementation.function, implementation.zone, parentDelegate, this, line);
}
}
@@ -5674,7 +5666,7 @@ dart_library.library('dart/async', null, /* Imports */[
})
});
function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) {
- _schedulePriorityAsyncCallback(dart.fn(() => {
+ dart.dcall(_schedulePriorityAsyncCallback, dart.fn(() => {
dart.throw(new _UncaughtAsyncError(error, stackTrace));
}));
}
@@ -5682,33 +5674,33 @@ dart_library.library('dart/async', null, /* Imports */[
function _rootRun(self, parent, zone, f) {
if (dart.equals(Zone._current, zone))
return f();
- let old = Zone._enter(zone);
+ let old = dart.dcall(Zone._enter, zone);
try {
return f();
} finally {
- Zone._leave(old);
+ dart.dcall(Zone._leave, old);
}
}
dart.fn(_rootRun, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])]);
function _rootRunUnary(self, parent, zone, f, arg) {
if (dart.equals(Zone._current, zone))
return dart.dcall(f, arg);
- let old = Zone._enter(zone);
+ let old = dart.dcall(Zone._enter, zone);
try {
return dart.dcall(f, arg);
} finally {
- Zone._leave(old);
+ dart.dcall(Zone._leave, old);
}
}
dart.fn(_rootRunUnary, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]);
function _rootRunBinary(self, parent, zone, f, arg1, arg2) {
if (dart.equals(Zone._current, zone))
return dart.dcall(f, arg1, arg2);
- let old = Zone._enter(zone);
+ let old = dart.dcall(Zone._enter, zone);
try {
return dart.dcall(f, arg1, arg2);
} finally {
- Zone._leave(old);
+ dart.dcall(Zone._leave, old);
}
}
dart.fn(_rootRunBinary, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]);
@@ -5729,33 +5721,33 @@ dart_library.library('dart/async', null, /* Imports */[
}
dart.fn(_rootErrorCallback, AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]);
function _rootScheduleMicrotask(self, parent, zone, f) {
- if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) {
- let hasErrorHandler = !dart.notNull(_ROOT_ZONE.inSameErrorZone(zone));
- f = zone.bindCallback(f, {runGuarded: hasErrorHandler});
+ if (!dart.notNull(dart.dcall(core.identical, _ROOT_ZONE, zone))) {
+ let hasErrorHandler = !dart.notNull(dart.as(dart.dsend(_ROOT_ZONE, 'inSameErrorZone', zone), core.bool));
+ f = dart.dcall(zone.bindCallback, f, {runGuarded: hasErrorHandler});
}
- _scheduleAsyncCallback(f);
+ dart.dcall(_scheduleAsyncCallback, f);
}
dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])]);
function _rootCreateTimer(self, parent, zone, duration, callback) {
- if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) {
- callback = zone.bindCallback(callback);
+ if (!dart.notNull(dart.dcall(core.identical, _ROOT_ZONE, zone))) {
+ callback = dart.dcall(zone.bindCallback, callback);
}
- return Timer._createTimer(duration, callback);
+ return dart.dcall(Timer._createTimer, duration, callback);
}
dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [])]);
function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) {
- if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) {
- callback = dart.as(zone.bindUnaryCallback(callback), __CastType36);
+ if (!dart.notNull(dart.dcall(core.identical, _ROOT_ZONE, zone))) {
+ callback = dart.as(dart.dcall(zone.bindUnaryCallback, callback), __CastType17);
}
- return Timer._createPeriodicTimer(duration, callback);
+ return dart.dcall(Timer._createPeriodicTimer, duration, callback);
}
dart.fn(_rootCreatePeriodicTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [Timer])]);
function _rootPrint(self, parent, zone, line) {
- _internal.printToConsole(line);
+ dart.dcall(_internal.printToConsole, line);
}
dart.fn(_rootPrint, dart.void, [Zone, ZoneDelegate, Zone, core.String]);
function _printToZone(line) {
- Zone.current.print(line);
+ dart.dcall(Zone.current.print, line);
}
dart.fn(_printToZone, dart.void, [core.String]);
function _rootFork(self, parent, zone, specification, zoneValues) {
@@ -5836,15 +5828,15 @@ dart_library.library('dart/async', null, /* Imports */[
errorHandler = dart.fn((self, parent, zone, error, stackTrace) => {
try {
if (dart.is(onError, ZoneBinaryCallback)) {
- return self.parent.runBinary(onError, error, stackTrace);
+ return dart.dcall(self.parent.runBinary, onError, error, stackTrace);
}
- return self.parent.runUnary(dart.as(onError, __CastType38), error);
+ return dart.dcall(self.parent.runUnary, onError, error);
} catch (e) {
let s = dart.stackTrace(e);
- if (dart.notNull(core.identical(e, error))) {
- return parent.handleUncaughtError(zone, error, stackTrace);
+ if (dart.notNull(dart.dcall(core.identical, e, error))) {
+ return dart.dcall(parent.handleUncaughtError, zone, error, stackTrace);
} else {
- return parent.handleUncaughtError(zone, e, s);
+ return dart.dcall(parent.handleUncaughtError, zone, e, s);
}
}
@@ -5855,19 +5847,18 @@ dart_library.library('dart/async', null, /* Imports */[
} else if (errorHandler != null) {
zoneSpecification = ZoneSpecification.from(zoneSpecification, {handleUncaughtError: errorHandler});
}
- let zone = Zone.current.fork({specification: zoneSpecification, zoneValues: zoneValues});
+ let zone = dart.dcall(Zone.current.fork, {specification: zoneSpecification, zoneValues: zoneValues});
if (onError != null) {
- return zone.runGuarded(body);
+ return dart.dcall(zone.runGuarded, body);
} else {
- return zone.run(body);
+ return dart.dcall(zone.run, body);
}
}
dart.fn(runZoned, dart.dynamic, [dart.functionType(dart.dynamic, [])], {zoneValues: core.Map, zoneSpecification: ZoneSpecification, onError: core.Function});
- let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.void, [Timer]));
- let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(dart.dynamic, [dart.dynamic]));
+ let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.void, [Timer]));
dart.copyProperties(exports, {
get _hasDocument() {
- return typeof document == 'object';
+ return dart.equals(typeof document, 'object');
}
});
// Exports:
« lib/runtime/dart/_foreign_helper.js ('K') | « lib/runtime/dart/_native_typed_data.js ('k') | lib/runtime/dart/collection.js » ('j') | pubspec.yaml » ('J')

Powered by Google App Engine
This is Rietveld 408576698