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

Unified Diff: test/codegen/expect/async/async.js

Issue 949383003: use js_ast instead of strings to generate JS (Closed) Base URL: git@github.com:dart-lang/dart-dev-compiler.git@master
Patch Set: add redirecting ctor test Created 5 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « test/codegen/expect/_internal/_internal.js ('k') | test/codegen/expect/cascade/cascade.js » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: test/codegen/expect/async/async.js
diff --git a/test/codegen/expect/async/async.js b/test/codegen/expect/async/async.js
index 314cd09f6c89e35afbfac0a012808ef2635339a4..1ec861d54b74019aafc02a6e7a4fe11dee400a0c 100644
--- a/test/codegen/expect/async/async.js
+++ b/test/codegen/expect/async/async.js
@@ -1,10 +1,11 @@
var async;
-(function (async) {
+(function(async) {
'use strict';
dart.copyProperties(async, {
- get _hasDocument() { return dart.equals(dart.dinvokef(/* Unimplemented unknown name */JS, 'String', 'typeof document'), 'object'); },
+ get _hasDocument() {
+ return dart.equals(dart.dinvokef(/* Unimplemented unknown name */JS, 'String', 'typeof document'), 'object');
+ }
});
-
// Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic
function _invokeErrorHandler(errorHandler, error, stackTrace) {
if (dart.is(errorHandler, ZoneBinaryCallback)) {
@@ -13,24 +14,23 @@ var async;
return dart.dinvokef(errorHandler, error);
}
}
-
// Function _registerErrorHandler: (Function, Zone) → Function
function _registerErrorHandler(errorHandler, zone) {
if (dart.is(errorHandler, ZoneBinaryCallback)) {
return zone.registerBinaryCallback(errorHandler);
} else {
- return zone.registerUnaryCallback(dart.as(errorHandler, /* Unimplemented type (dynamic) → dynamic */));
+ return zone.registerUnaryCallback(dart.as(errorHandler, dart.throw_("Unimplemented type (dynamic) → dynamic")));
}
}
-
class _UncaughtAsyncError extends AsyncError {
_UncaughtAsyncError(error, stackTrace) {
super.AsyncError(error, _getBestStackTrace(error, stackTrace));
}
static _getBestStackTrace(error, stackTrace) {
- if (stackTrace !== null) return stackTrace;
+ if (stackTrace !== null)
+ return stackTrace;
if (dart.is(error, core.Error)) {
- return dart.as(dart.dload(error, "stackTrace"), core.StackTrace);
+ return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace);
}
return null;
}
@@ -42,25 +42,24 @@ var async;
return result;
}
}
-
let _BroadcastStream$ = dart.generic(function(T) {
class _BroadcastStream extends _ControllerStream$(T) {
_BroadcastStream(controller) {
super._ControllerStream(dart.as(controller, _StreamControllerLifecycle$(T)));
}
- get isBroadcast() { return true; }
+ get isBroadcast() {
+ return true;
+ }
}
return _BroadcastStream;
});
let _BroadcastStream = _BroadcastStream$(dynamic);
-
class _BroadcastSubscriptionLink extends dart.Object {
_BroadcastSubscriptionLink() {
this._next = null;
this._previous = null;
}
}
-
let _BroadcastSubscription$ = dart.generic(function(T) {
class _BroadcastSubscription extends _ControllerSubscription$(T) {
_BroadcastSubscription(controller, onData, onError, onDone, cancelOnError) {
@@ -70,21 +69,27 @@ var async;
super._ControllerSubscription(dart.as(controller, _StreamControllerLifecycle$(T)), onData, onError, onDone, cancelOnError);
this._next = this._previous = this;
}
- get _controller() { return dart.as(super._controller, _BroadcastStreamController); }
- _expectsEvent(eventId) { return (this._eventState & _STATE_EVENT_ID) === eventId; }
+ get _controller() {
+ return dart.as(super._controller, _BroadcastStreamController);
+ }
+ _expectsEvent(eventId) {
+ return (this._eventState & _STATE_EVENT_ID) === eventId;
+ }
_toggleEventId() {
this._eventState = _STATE_EVENT_ID;
}
- get _isFiring() { return (this._eventState & _STATE_FIRING) !== 0; }
+ get _isFiring() {
+ return (this._eventState & _STATE_FIRING) !== 0;
+ }
_setRemoveAfterFiring() {
dart.assert(this._isFiring);
this._eventState = _STATE_REMOVE_AFTER_FIRING;
}
- get _removeAfterFiring() { return (this._eventState & _STATE_REMOVE_AFTER_FIRING) !== 0; }
- _onPause() {
- }
- _onResume() {
+ get _removeAfterFiring() {
+ return (this._eventState & _STATE_REMOVE_AFTER_FIRING) !== 0;
}
+ _onPause() {}
+ _onResume() {}
}
_BroadcastSubscription._STATE_EVENT_ID = 1;
_BroadcastSubscription._STATE_FIRING = 2;
@@ -92,7 +97,6 @@ var async;
return _BroadcastSubscription;
});
let _BroadcastSubscription = _BroadcastSubscription$(dynamic);
-
let _BroadcastStreamController$ = dart.generic(function(T) {
class _BroadcastStreamController extends dart.Object {
_BroadcastStreamController(_onListen, _onCancel) {
@@ -105,30 +109,49 @@ var async;
this._doneFuture = null;
this._next = this._previous = this;
}
- get stream() { return new _BroadcastStream(this); }
- get sink() { return new _StreamSinkWrapper(this); }
- get isClosed() { return (this._state & _STATE_CLOSED) !== 0; }
- get isPaused() { return false; }
- get hasListener() { return !dart.notNull(this._isEmpty); }
+ get stream() {
+ return new _BroadcastStream(this);
+ }
+ get sink() {
+ return new _StreamSinkWrapper(this);
+ }
+ get isClosed() {
+ return (this._state & _STATE_CLOSED) !== 0;
+ }
+ get isPaused() {
+ return false;
+ }
+ get hasListener() {
+ return !dart.notNull(this._isEmpty);
+ }
get _hasOneListener() {
dart.assert(!dart.notNull(this._isEmpty));
return core.identical(this._next._next, this);
}
- get _isFiring() { return (this._state & _STATE_FIRING) !== 0; }
- get _isAddingStream() { return (this._state & _STATE_ADDSTREAM) !== 0; }
- get _mayAddEvent() { return (this._state < _STATE_CLOSED); }
+ get _isFiring() {
+ return (this._state & _STATE_FIRING) !== 0;
+ }
+ get _isAddingStream() {
+ return (this._state & _STATE_ADDSTREAM) !== 0;
+ }
+ get _mayAddEvent() {
+ return this._state < _STATE_CLOSED;
+ }
_ensureDoneFuture() {
- if (this._doneFuture !== null) return this._doneFuture;
+ if (this._doneFuture !== null)
+ return this._doneFuture;
return this._doneFuture = new _Future();
}
- get _isEmpty() { return core.identical(this._next, this); }
+ get _isEmpty() {
+ return core.identical(this._next, this);
+ }
_addListener(subscription) {
dart.assert(core.identical(subscription._next, subscription));
subscription._previous = this._previous;
subscription._next = this;
this._previous._next = subscription;
this._previous = subscription;
- subscription._eventState = (this._state & _STATE_EVENT_ID);
+ subscription._eventState = this._state & _STATE_EVENT_ID;
}
_removeListener(subscription) {
dart.assert(core.identical(subscription._controller, this));
@@ -141,7 +164,8 @@ var async;
}
_subscribe(onData, onError, onDone, cancelOnError) {
if (this.isClosed) {
- if (onDone === null) onDone = _nullDoneHandler;
+ if (onDone === null)
+ onDone = _nullDoneHandler;
return new _DoneStreamSubscription(onDone);
}
let subscription = new _BroadcastSubscription(this, onData, onError, onDone, cancelOnError);
@@ -152,7 +176,8 @@ var async;
return dart.as(subscription, StreamSubscription$(T));
}
_recordCancel(subscription) {
- if (core.identical(subscription._next, subscription)) return null;
+ if (core.identical(subscription._next, subscription))
+ return null;
dart.assert(!dart.notNull(core.identical(subscription._next, subscription)));
if (subscription._isFiring) {
subscription._setRemoveAfterFiring();
@@ -165,10 +190,8 @@ var async;
}
return null;
}
- _recordPause(subscription) {
- }
- _recordResume(subscription) {
- }
+ _recordPause(subscription) {}
+ _recordResume(subscription) {}
_addEventError() {
if (this.isClosed) {
return new core.StateError("Cannot add new events after calling close");
@@ -177,13 +200,16 @@ var async;
return new core.StateError("Cannot add new events while doing an addStream");
}
add(data) {
- if (!dart.notNull(this._mayAddEvent)) throw this._addEventError();
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._addEventError();
this._sendData(data);
}
addError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
error = _nonNullError(error);
- if (!dart.notNull(this._mayAddEvent)) throw this._addEventError();
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._addEventError();
let replacement = Zone.current.errorCallback(error, stackTrace);
if (replacement !== null) {
error = _nonNullError(replacement.error);
@@ -196,16 +222,20 @@ var async;
dart.assert(this._doneFuture !== null);
return this._doneFuture;
}
- if (!dart.notNull(this._mayAddEvent)) throw this._addEventError();
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._addEventError();
this._state = _STATE_CLOSED;
let doneFuture = this._ensureDoneFuture();
this._sendDone();
return doneFuture;
}
- get done() { return this._ensureDoneFuture(); }
+ get done() {
+ return this._ensureDoneFuture();
+ }
addStream(stream, opt$) {
- let cancelOnError = opt$.cancelOnError === undefined ? true : opt$.cancelOnError;
- if (!dart.notNull(this._mayAddEvent)) throw this._addEventError();
+ let cancelOnError = opt$.cancelOnError === void 0 ? true : opt$.cancelOnError;
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._addEventError();
this._state = _STATE_ADDSTREAM;
this._addStreamState = dart.as(new _AddStreamState(this, stream, cancelOnError), _AddStreamState$(T));
return this._addStreamState.addStreamFuture;
@@ -227,8 +257,9 @@ var async;
if (this._isFiring) {
throw new core.StateError("Cannot fire new event. Controller is already firing an event");
}
- if (this._isEmpty) return;
- let id = (this._state & _STATE_EVENT_ID);
+ if (this._isEmpty)
+ return;
+ let id = this._state & _STATE_EVENT_ID;
this._state = _STATE_EVENT_ID | _STATE_FIRING;
let link = this._next;
while (!dart.notNull(core.identical(link, this))) {
@@ -267,14 +298,14 @@ var async;
return _BroadcastStreamController;
});
let _BroadcastStreamController = _BroadcastStreamController$(dynamic);
-
let _SyncBroadcastStreamController$ = dart.generic(function(T) {
class _SyncBroadcastStreamController extends _BroadcastStreamController$(T) {
_SyncBroadcastStreamController(onListen, onCancel) {
super._BroadcastStreamController(onListen, onCancel);
}
_sendData(data) {
- if (this._isEmpty) return;
+ if (this._isEmpty)
+ return;
if (this._hasOneListener) {
this._state = _BroadcastStreamController._STATE_FIRING;
let subscription = dart.as(this._next, _BroadcastSubscription);
@@ -290,7 +321,8 @@ var async;
}).bind(this));
}
_sendError(error, stackTrace) {
- if (this._isEmpty) return;
+ if (this._isEmpty)
+ return;
this._forEachListener(((subscription) => {
subscription._addError(error, stackTrace);
}).bind(this));
@@ -299,7 +331,7 @@ var async;
if (!dart.notNull(this._isEmpty)) {
this._forEachListener(dart.as(((subscription) => {
subscription._close();
- }).bind(this), /* Unimplemented type (_BufferingStreamSubscription<T>) → void */));
+ }).bind(this), dart.throw_("Unimplemented type (_BufferingStreamSubscription<T>) → void")));
} else {
dart.assert(this._doneFuture !== null);
dart.assert(this._doneFuture._mayComplete);
@@ -310,7 +342,6 @@ var async;
return _SyncBroadcastStreamController;
});
let _SyncBroadcastStreamController = _SyncBroadcastStreamController$(dynamic);
-
let _AsyncBroadcastStreamController$ = dart.generic(function(T) {
class _AsyncBroadcastStreamController extends _BroadcastStreamController$(T) {
_AsyncBroadcastStreamController(onListen, onCancel) {
@@ -344,14 +375,15 @@ var async;
return _AsyncBroadcastStreamController;
});
let _AsyncBroadcastStreamController = _AsyncBroadcastStreamController$(dynamic);
-
let _AsBroadcastStreamController$ = dart.generic(function(T) {
class _AsBroadcastStreamController extends _SyncBroadcastStreamController$(T) {
_AsBroadcastStreamController(onListen, onCancel) {
this._pending = null;
super._SyncBroadcastStreamController(onListen, onCancel);
}
- get _hasPending() { return dart.notNull(this._pending !== null) && dart.notNull(!dart.notNull(this._pending.isEmpty)); }
+ get _hasPending() {
+ return dart.notNull(this._pending !== null) && dart.notNull(!dart.notNull(this._pending.isEmpty));
+ }
_addPendingEvent(event) {
if (this._pending === null) {
this._pending = new _StreamImplEvents();
@@ -369,12 +401,14 @@ var async;
}
}
addError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
if (dart.notNull(!dart.notNull(this.isClosed)) && dart.notNull(this._isFiring)) {
this._addPendingEvent(new _DelayedError(error, stackTrace));
return;
}
- if (!dart.notNull(this._mayAddEvent)) throw this._addEventError();
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._addEventError();
this._sendError(error, stackTrace);
while (this._hasPending) {
this._pending.handleNext(this);
@@ -401,61 +435,61 @@ var async;
return _AsBroadcastStreamController;
});
let _AsBroadcastStreamController = _AsBroadcastStreamController$(dynamic);
-
let _DoneSubscription$ = dart.generic(function(T) {
class _DoneSubscription extends dart.Object {
_DoneSubscription() {
this._pauseCount = 0;
}
- onData(handleData) {
- }
- onError(handleError) {
- }
- onDone(handleDone) {
- }
+ onData(handleData) {}
+ onError(handleError) {}
+ onDone(handleDone) {}
pause(resumeSignal) {
- if (resumeSignal === undefined) resumeSignal = null;
- if (resumeSignal !== null) resumeSignal.then(this._resume);
+ if (resumeSignal === void 0)
+ resumeSignal = null;
+ if (resumeSignal !== null)
+ resumeSignal.then(this._resume);
this._pauseCount++;
}
resume() {
this._resume(null);
}
_resume(_) {
- if (this._pauseCount > 0) this._pauseCount--;
+ if (this._pauseCount > 0)
+ this._pauseCount--;
}
cancel() {
return new _Future.immediate(null);
}
- get isPaused() { return this._pauseCount > 0; }
+ get isPaused() {
+ return this._pauseCount > 0;
+ }
asFuture(value) {
- if (value === undefined) value = null;
- return new _Future()
+ if (value === void 0)
+ value = null;
+ return new _Future();
}
}
return _DoneSubscription;
});
let _DoneSubscription = _DoneSubscription$(dynamic);
-
class DeferredLibrary extends dart.Object {
DeferredLibrary(libraryName, opt$) {
- let uri = opt$.uri === undefined ? null : opt$.uri;
+ let uri = opt$.uri === void 0 ? null : opt$.uri;
this.libraryName = libraryName;
this.uri = uri;
}
load() {
- throw 'DeferredLibrary not supported. ' +
- 'please use the `import "lib.dart" deferred as lib` syntax.';
+ throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dart" deferred as lib` syntax.';
}
}
-
class DeferredLoadException extends dart.Object {
DeferredLoadException(_s) {
this._s = _s;
}
- toString() { return `DeferredLoadException: '${this._s}'`; }
+ toString() {
+ return `DeferredLoadException: '${this._s}'`;
+ }
}
-
let Future$ = dart.generic(function(T) {
class Future extends dart.Object {
Future(computation) {
@@ -463,11 +497,11 @@ var async;
Timer.run((() => {
try {
result._complete(computation());
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_completeWithErrorCallback(result, e, s);
}
+
}).bind(this));
return dart.as(result, Future$(T));
}
@@ -476,11 +510,11 @@ var async;
scheduleMicrotask((() => {
try {
result._complete(computation());
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_completeWithErrorCallback(result, e, s);
}
+
}).bind(this));
return dart.as(result, Future$(T));
}
@@ -488,18 +522,20 @@ var async;
try {
let result = computation();
return new Future.value(result);
- }
- catch (error) {
+ } catch (error) {
let stackTrace = dart.stackTrace(error);
return new Future.error(error, stackTrace);
}
+
}
Future$value(value) {
- if (value === undefined) value = null;
+ if (value === void 0)
+ value = null;
return new _Future.immediate(value);
}
Future$error(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ 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);
@@ -511,22 +547,23 @@ var async;
return new _Future.immediateError(error, stackTrace);
}
Future$delayed(duration, computation) {
- if (computation === undefined) computation = null;
+ if (computation === void 0)
+ computation = null;
let result = new _Future();
new Timer(duration, (() => {
try {
result._complete(computation === null ? null : computation());
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_completeWithErrorCallback(result, e, s);
}
+
}).bind(this));
return dart.as(result, Future$(T));
}
static wait(futures, opt$) {
- let eagerError = opt$.eagerError === undefined ? false : opt$.eagerError;
- let cleanUp = opt$.cleanUp === undefined ? null : opt$.cleanUp;
+ let eagerError = opt$.eagerError === void 0 ? false : opt$.eagerError;
+ let cleanUp = opt$.cleanUp === void 0 ? null : opt$.cleanUp;
let result = new _Future();
let values = null;
let remaining = 0;
@@ -575,7 +612,7 @@ var async;
result._completeError(error, stackTrace);
}
}
- }).bind(this), /* Unimplemented type (dynamic) → dynamic */), {onError: handleError});
+ }).bind(this), dart.throw_("Unimplemented type (dynamic) → dynamic")), {onError: handleError});
}
if (remaining === 0) {
return dart.as(new Future.value(/* Unimplemented const */new List.from([])), Future$(core.List));
@@ -586,7 +623,8 @@ var async;
static forEach(input, f) {
let iterator = input.iterator;
return doWhile((() => {
- if (!dart.notNull(iterator.moveNext())) return false;
+ if (!dart.notNull(iterator.moveNext()))
+ return false;
return new Future.sync((() => f(iterator.current)).bind(this)).then((_) => true);
}).bind(this));
}
@@ -595,41 +633,44 @@ var async;
let nextIteration = null;
nextIteration = Zone.current.bindUnaryCallback(dart.as(((keepGoing) => {
if (keepGoing) {
- new Future.sync(f).then(dart.as(nextIteration, /* Unimplemented type (dynamic) → dynamic */), {onError: doneSignal._completeError});
+ new Future.sync(f).then(dart.as(nextIteration, dart.throw_("Unimplemented type (dynamic) → dynamic")), {onError: doneSignal._completeError});
} else {
doneSignal._complete(null);
}
- }).bind(this), /* Unimplemented type (dynamic) → dynamic */), {runGuarded: true});
+ }).bind(this), dart.throw_("Unimplemented type (dynamic) → dynamic")), {runGuarded: true});
dart.dinvokef(nextIteration, true);
return doneSignal;
}
}
- dart.defineNamedConstructor(Future, "microtask");
- dart.defineNamedConstructor(Future, "sync");
- dart.defineNamedConstructor(Future, "value");
- dart.defineNamedConstructor(Future, "error");
- dart.defineNamedConstructor(Future, "delayed");
+ dart.defineNamedConstructor(Future, 'microtask');
+ dart.defineNamedConstructor(Future, 'sync');
+ dart.defineNamedConstructor(Future, 'value');
+ dart.defineNamedConstructor(Future, 'error');
+ dart.defineNamedConstructor(Future, 'delayed');
dart.defineLazyProperties(Future, {
- get _nullFuture() { return dart.as(new Future.value(null), _Future) },
+ get _nullFuture() {
+ return dart.as(new Future.value(null), _Future);
+ }
});
return Future;
});
let Future = Future$(dynamic);
-
class TimeoutException extends dart.Object {
TimeoutException(message, duration) {
- if (duration === undefined) duration = null;
+ if (duration === void 0)
+ duration = null;
this.message = message;
this.duration = duration;
}
toString() {
let result = "TimeoutException";
- if (this.duration !== null) result = `TimeoutException after ${this.duration}`;
- if (this.message !== null) result = `${result}: ${this.message}`;
+ if (this.duration !== null)
+ result = `TimeoutException after ${this.duration}`;
+ if (this.message !== null)
+ result = `${result}: ${this.message}`;
return result;
}
}
-
let Completer$ = dart.generic(function(T) {
class Completer extends dart.Object {
Completer() {
@@ -639,11 +680,10 @@ var async;
return new _SyncCompleter();
}
}
- dart.defineNamedConstructor(Completer, "sync");
+ dart.defineNamedConstructor(Completer, 'sync');
return Completer;
});
let Completer = Completer$(dynamic);
-
// Function _completeWithErrorCallback: (_Future<dynamic>, dynamic, dynamic) → void
function _completeWithErrorCallback(result, error, stackTrace) {
let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core.StackTrace));
@@ -653,19 +693,21 @@ var async;
}
result._completeError(error, dart.as(stackTrace, core.StackTrace));
}
-
// Function _nonNullError: (Object) → Object
- function _nonNullError(error) { return (error !== null) ? error : new core.NullThrownError(); }
-
+ function _nonNullError(error) {
+ return error !== null ? error : new core.NullThrownError();
+ }
let _Completer$ = dart.generic(function(T) {
class _Completer extends dart.Object {
_Completer() {
this.future = new _Future();
}
completeError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
error = _nonNullError(error);
- if (!dart.notNull(this.future._mayComplete)) throw new core.StateError("Future already completed");
+ if (!dart.notNull(this.future._mayComplete))
+ throw new core.StateError("Future already completed");
let replacement = Zone.current.errorCallback(error, stackTrace);
if (replacement !== null) {
error = _nonNullError(replacement.error);
@@ -673,17 +715,20 @@ var async;
}
this._completeError(error, stackTrace);
}
- get isCompleted() { return !dart.notNull(this.future._mayComplete); }
+ get isCompleted() {
+ return !dart.notNull(this.future._mayComplete);
+ }
}
return _Completer;
});
let _Completer = _Completer$(dynamic);
-
let _AsyncCompleter$ = dart.generic(function(T) {
class _AsyncCompleter extends _Completer$(T) {
complete(value) {
- if (value === undefined) value = null;
- if (!dart.notNull(this.future._mayComplete)) throw new core.StateError("Future already completed");
+ if (value === void 0)
+ value = null;
+ if (!dart.notNull(this.future._mayComplete))
+ throw new core.StateError("Future already completed");
this.future._asyncComplete(value);
}
_completeError(error, stackTrace) {
@@ -693,12 +738,13 @@ var async;
return _AsyncCompleter;
});
let _AsyncCompleter = _AsyncCompleter$(dynamic);
-
let _SyncCompleter$ = dart.generic(function(T) {
class _SyncCompleter extends _Completer$(T) {
complete(value) {
- if (value === undefined) value = null;
- if (!dart.notNull(this.future._mayComplete)) throw new core.StateError("Future already completed");
+ if (value === void 0)
+ value = null;
+ if (!dart.notNull(this.future._mayComplete))
+ throw new core.StateError("Future already completed");
this.future._complete(value);
}
_completeError(error, stackTrace) {
@@ -708,20 +754,19 @@ var async;
return _SyncCompleter;
});
let _SyncCompleter = _SyncCompleter$(dynamic);
-
class _FutureListener extends dart.Object {
_FutureListener$then(result, onValue, errorCallback) {
this.result = result;
this.callback = onValue;
this.errorCallback = errorCallback;
- this.state = (errorCallback === null) ? STATE_THEN : STATE_THEN_ONERROR;
+ this.state = errorCallback === null ? STATE_THEN : STATE_THEN_ONERROR;
this._nextListener = null;
}
_FutureListener$catchError(result, errorCallback, test) {
this.result = result;
this.errorCallback = errorCallback;
this.callback = test;
- this.state = (test === null) ? STATE_CATCHERROR : STATE_CATCHERROR_TEST;
+ this.state = test === null ? STATE_CATCHERROR : STATE_CATCHERROR_TEST;
this._nextListener = null;
}
_FutureListener$whenComplete(result, onComplete) {
@@ -738,16 +783,28 @@ var async;
this.state = STATE_CHAIN;
this._nextListener = null;
}
- get _zone() { return this.result._zone; }
- get handlesValue() { return (this.state & MASK_VALUE !== 0); }
- get handlesError() { return (this.state & MASK_ERROR !== 0); }
- get hasErrorTest() { return (this.state === STATE_CATCHERROR_TEST); }
- get handlesComplete() { return (this.state === STATE_WHENCOMPLETE); }
+ get _zone() {
+ return this.result._zone;
+ }
+ get handlesValue() {
+ return (this.state & MASK_VALUE) !== 0;
+ }
+ get handlesError() {
+ return (this.state & MASK_ERROR) !== 0;
+ }
+ get hasErrorTest() {
+ return this.state === STATE_CATCHERROR_TEST;
+ }
+ get handlesComplete() {
+ return this.state === STATE_WHENCOMPLETE;
+ }
get _onValue() {
dart.assert(this.handlesValue);
return dart.as(this.callback, _FutureOnValue);
}
- get _onError() { return this.errorCallback; }
+ get _onError() {
+ return this.errorCallback;
+ }
get _errorTest() {
dart.assert(this.hasErrorTest);
return dart.as(this.callback, _FutureErrorTest);
@@ -757,10 +814,10 @@ var async;
return dart.as(this.callback, _FutureAction);
}
}
- dart.defineNamedConstructor(_FutureListener, "then");
- dart.defineNamedConstructor(_FutureListener, "catchError");
- dart.defineNamedConstructor(_FutureListener, "whenComplete");
- dart.defineNamedConstructor(_FutureListener, "chain");
+ dart.defineNamedConstructor(_FutureListener, 'then');
+ dart.defineNamedConstructor(_FutureListener, 'catchError');
+ dart.defineNamedConstructor(_FutureListener, 'whenComplete');
+ dart.defineNamedConstructor(_FutureListener, 'chain');
_FutureListener.MASK_VALUE = 1;
_FutureListener.MASK_ERROR = 2;
_FutureListener.MASK_TEST_ERROR = 4;
@@ -771,7 +828,6 @@ var async;
_FutureListener.STATE_CATCHERROR = MASK_ERROR;
_FutureListener.STATE_CATCHERROR_TEST = MASK_ERROR | MASK_TEST_ERROR;
_FutureListener.STATE_WHENCOMPLETE = MASK_WHENCOMPLETE;
-
let _Future$ = dart.generic(function(T) {
class _Future extends dart.Object {
_Future() {
@@ -786,17 +842,28 @@ var async;
this._asyncComplete(value);
}
_Future$immediateError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
this._zone = Zone.current;
this._state = _INCOMPLETE;
this._resultOrListeners = null;
this._asyncCompleteError(error, stackTrace);
}
- get _mayComplete() { return this._state === _INCOMPLETE; }
- get _isChained() { return this._state === _CHAINED; }
- get _isComplete() { return this._state >= _VALUE; }
- get _hasValue() { return this._state === _VALUE; }
- get _hasError() { return this._state === _ERROR; }
+ get _mayComplete() {
+ return this._state === _INCOMPLETE;
+ }
+ get _isChained() {
+ return this._state === _CHAINED;
+ }
+ get _isComplete() {
+ return this._state >= _VALUE;
+ }
+ get _hasValue() {
+ return this._state === _VALUE;
+ }
+ get _hasError() {
+ return this._state === _ERROR;
+ }
set _isChained(value) {
if (value) {
dart.assert(!dart.notNull(this._isComplete));
@@ -807,10 +874,10 @@ var async;
}
}
then(f, opt$) {
- let onError = opt$.onError === undefined ? null : opt$.onError;
+ let onError = opt$.onError === void 0 ? null : opt$.onError;
let result = new _Future();
if (!dart.notNull(core.identical(result._zone, _ROOT_ZONE))) {
- f = result._zone.registerUnaryCallback(dart.as(f, /* Unimplemented type (dynamic) → dynamic */));
+ f = result._zone.registerUnaryCallback(dart.as(f, dart.throw_("Unimplemented type (dynamic) → dynamic")));
if (onError !== null) {
onError = _registerErrorHandler(onError, result._zone);
}
@@ -819,11 +886,12 @@ var async;
return result;
}
catchError(onError, opt$) {
- let test = opt$.test === undefined ? null : opt$.test;
+ let test = opt$.test === void 0 ? null : opt$.test;
let result = new _Future();
if (!dart.notNull(core.identical(result._zone, _ROOT_ZONE))) {
onError = _registerErrorHandler(onError, result._zone);
- if (test !== null) test = dart.as(result._zone.registerUnaryCallback(test), /* Unimplemented type (dynamic) → bool */);
+ if (test !== null)
+ test = dart.as(result._zone.registerUnaryCallback(test), dart.throw_("Unimplemented type (dynamic) → bool"));
}
this._addListener(new _FutureListener.catchError(result, onError, test));
return result;
@@ -836,9 +904,12 @@ var async;
this._addListener(new _FutureListener.whenComplete(result, action));
return dart.as(result, Future$(T));
}
- asStream() { return dart.as(new Stream.fromFuture(this), Stream$(T)); }
+ asStream() {
+ return dart.as(new Stream.fromFuture(this), Stream$(T));
+ }
_markPendingCompletion() {
- if (!dart.notNull(this._mayComplete)) throw new core.StateError("Future already completed");
+ if (!dart.notNull(this._mayComplete))
+ throw new core.StateError("Future already completed");
this._state = _PENDING_COMPLETE;
}
get _value() {
@@ -894,10 +965,11 @@ var async;
dart.assert(target._isChained);
target._completeWithValue(value);
}).bind(this), {onError: ((error, stackTrace) => {
- if (stackTrace === undefined) stackTrace = null;
- dart.assert(target._isChained);
- target._completeError(error, dart.as(stackTrace, core.StackTrace));
- }).bind(this)});
+ if (stackTrace === void 0)
+ stackTrace = null;
+ dart.assert(target._isChained);
+ target._completeError(error, dart.as(stackTrace, core.StackTrace));
+ }).bind(this)});
}
static _chainCoreFuture(source, target) {
dart.assert(!dart.notNull(target._isComplete));
@@ -932,7 +1004,8 @@ var async;
_propagateToListeners(this, listeners);
}
_completeError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
dart.assert(!dart.notNull(this._isComplete));
let listeners = this._removeListeners();
this._setError(error, stackTrace);
@@ -994,7 +1067,7 @@ var async;
let sourceValue = hasError ? null : source._value;
let listenerValueOrError = sourceValue;
let isPropagationAborted = false;
- if (dart.notNull(hasError) || dart.notNull((dart.notNull(listener.handlesValue) || dart.notNull(listener.handlesComplete)))) {
+ if (dart.notNull(hasError) || dart.notNull(dart.notNull(listener.handlesValue) || dart.notNull(listener.handlesComplete))) {
let zone = listener._zone;
if (dart.notNull(hasError) && dart.notNull(!dart.notNull(source._zone.inSameErrorZone(zone)))) {
let asyncError = source._error;
@@ -1010,12 +1083,12 @@ var async;
try {
listenerValueOrError = zone.runUnary(listener._onValue, sourceValue);
return true;
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
listenerValueOrError = new AsyncError(e, s);
return false;
}
+
}
// Function handleError: () → void
function handleError() {
@@ -1025,13 +1098,13 @@ var async;
let test = listener._errorTest;
try {
matchesTest = dart.as(zone.runUnary(test, asyncError.error), core.bool);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
listenerValueOrError = core.identical(asyncError.error, e) ? asyncError : new AsyncError(e, s);
listenerHasValue = false;
return;
}
+
}
let errorCallback = listener._onError;
if (dart.notNull(matchesTest) && dart.notNull(errorCallback !== null)) {
@@ -1039,15 +1112,15 @@ var async;
if (dart.is(errorCallback, ZoneBinaryCallback)) {
listenerValueOrError = zone.runBinary(errorCallback, asyncError.error, asyncError.stackTrace);
} else {
- listenerValueOrError = zone.runUnary(dart.as(errorCallback, /* Unimplemented type (dynamic) → dynamic */), asyncError.error);
+ listenerValueOrError = zone.runUnary(dart.as(errorCallback, dart.throw_("Unimplemented type (dynamic) → dynamic")), asyncError.error);
}
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
listenerValueOrError = core.identical(asyncError.error, e) ? asyncError : new AsyncError(e, s);
listenerHasValue = false;
return;
}
+
listenerHasValue = true;
} else {
listenerValueOrError = asyncError;
@@ -1059,8 +1132,7 @@ var async;
let completeResult = null;
try {
completeResult = zone.run(listener._whenCompleteAction);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
if (dart.notNull(hasError) && dart.notNull(core.identical(source._error.error, e))) {
listenerValueOrError = source._error;
@@ -1070,20 +1142,24 @@ var async;
listenerHasValue = false;
return;
}
+
if (dart.is(completeResult, Future)) {
let result = listener.result;
result._isChained = true;
isPropagationAborted = true;
- dart.dinvoke(completeResult, "then", (ignored) => {
+ dart.dinvoke(completeResult, 'then', (ignored) => {
_propagateToListeners(source, new _FutureListener.chain(result));
- }, {onError: (error, stackTrace) => {
- if (stackTrace === undefined) stackTrace = null;
- if (!dart.is(completeResult, _Future)) {
- completeResult = new _Future();
- dart.dinvoke(completeResult, "_setError", error, stackTrace);
+ }, {
+ onError: (error, stackTrace) => {
+ if (stackTrace === void 0)
+ stackTrace = null;
+ if (!dart.is(completeResult, _Future)) {
+ completeResult = new _Future();
+ dart.dinvoke(completeResult, '_setError', error, stackTrace);
+ }
+ _propagateToListeners(dart.as(completeResult, _Future), new _FutureListener.chain(result));
}
- _propagateToListeners(dart.as(completeResult, _Future), new _FutureListener.chain(result));
- }});
+ });
}
}
if (!dart.notNull(hasError)) {
@@ -1096,8 +1172,10 @@ var async;
if (listener.handlesComplete) {
handleWhenCompleteCallback();
}
- if (oldZone !== null) Zone._leave(oldZone);
- if (isPropagationAborted) return;
+ if (oldZone !== null)
+ Zone._leave(oldZone);
+ if (isPropagationAborted)
+ return;
if (dart.notNull(dart.notNull(listenerHasValue) && dart.notNull(!dart.notNull(core.identical(sourceValue, listenerValueOrError)))) && dart.notNull(dart.is(listenerValueOrError, Future))) {
let chainSource = dart.as(listenerValueOrError, Future);
let result = listener.result;
@@ -1128,8 +1206,9 @@ var async;
}
}
timeout(timeLimit, opt$) {
- let onTimeout = opt$.onTimeout === undefined ? null : opt$.onTimeout;
- if (this._isComplete) return new _Future.immediate(this);
+ let onTimeout = opt$.onTimeout === void 0 ? null : opt$.onTimeout;
+ if (this._isComplete)
+ return new _Future.immediate(this);
let result = new _Future();
let timer = null;
if (onTimeout === null) {
@@ -1142,11 +1221,11 @@ var async;
timer = new Timer(timeLimit, (() => {
try {
result._complete(zone.run(onTimeout));
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
result._completeError(e, s);
}
+
}).bind(this));
}
this.then(((v) => {
@@ -1155,16 +1234,16 @@ var async;
result._completeWithValue(v);
}
}).bind(this), {onError: ((e, s) => {
- if (timer.isActive) {
- timer.cancel();
- result._completeError(e, dart.as(s, core.StackTrace));
- }
- }).bind(this)});
+ if (timer.isActive) {
+ timer.cancel();
+ result._completeError(e, dart.as(s, core.StackTrace));
+ }
+ }).bind(this)});
return result;
}
}
- dart.defineNamedConstructor(_Future, "immediate");
- dart.defineNamedConstructor(_Future, "immediateError");
+ dart.defineNamedConstructor(_Future, 'immediate');
+ dart.defineNamedConstructor(_Future, 'immediateError');
_Future._INCOMPLETE = 0;
_Future._PENDING_COMPLETE = 1;
_Future._CHAINED = 2;
@@ -1173,14 +1252,12 @@ var async;
return _Future;
});
let _Future = _Future$(dynamic);
-
class _AsyncCallbackEntry extends dart.Object {
_AsyncCallbackEntry(callback) {
this.callback = callback;
this.next = null;
}
}
-
async._nextCallback = null;
async._lastCallback = null;
async._lastPriorityCallback = null;
@@ -1191,24 +1268,23 @@ var async;
async._lastPriorityCallback = null;
let entry = async._nextCallback;
async._nextCallback = entry.next;
- if (async._nextCallback === null) async._lastCallback = null;
+ if (async._nextCallback === null)
+ async._lastCallback = null;
entry.callback();
}
}
-
// Function _asyncRunCallback: () → void
function _asyncRunCallback() {
async._isInCallbackLoop = true;
try {
_asyncRunCallbackLoop();
- }
- finally {
+ } finally {
async._lastPriorityCallback = null;
async._isInCallbackLoop = false;
- if (async._nextCallback !== null) _AsyncRun._scheduleImmediate(_asyncRunCallback);
+ if (async._nextCallback !== null)
+ _AsyncRun._scheduleImmediate(_asyncRunCallback);
}
}
-
// Function _scheduleAsyncCallback: (dynamic) → void
function _scheduleAsyncCallback(callback) {
if (async._nextCallback === null) {
@@ -1222,7 +1298,6 @@ var async;
async._lastCallback = newEntry;
}
}
-
// Function _schedulePriorityAsyncCallback: (dynamic) → void
function _schedulePriorityAsyncCallback(callback) {
let entry = new _AsyncCallbackEntry(callback);
@@ -1241,7 +1316,6 @@ var async;
}
}
}
-
// Function scheduleMicrotask: (() → void) → void
function scheduleMicrotask(callback) {
if (core.identical(_ROOT_ZONE, Zone.current)) {
@@ -1250,13 +1324,11 @@ var async;
}
Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuarded: true}));
}
-
class _AsyncRun extends dart.Object {
static _scheduleImmediate(callback) {
dart.dinvokef(/* Unimplemented unknown name */scheduleImmediateClosure, callback);
}
}
-
let Stream$ = dart.generic(function(T) {
class Stream extends dart.Object {
Stream() {
@@ -1267,17 +1339,19 @@ var async;
controller._add(dart.as(value, T));
controller._closeUnchecked();
}).bind(this), {onError: ((error, stackTrace) => {
- controller._addError(error, dart.as(stackTrace, core.StackTrace));
- controller._closeUnchecked();
- }).bind(this)});
+ controller._addError(error, dart.as(stackTrace, core.StackTrace));
+ controller._closeUnchecked();
+ }).bind(this)});
return controller.stream;
}
Stream$fromIterable(data) {
return new _GeneratedStreamImpl(() => new _IterablePendingEvents(data));
}
Stream$periodic(period, computation) {
- if (computation === undefined) computation = null;
- if (computation === null) computation = dart.as(((i) => null), /* Unimplemented type (int) → T */);
+ if (computation === void 0)
+ computation = null;
+ if (computation === null)
+ computation = dart.as((i) => null, dart.throw_("Unimplemented type (int) → T"));
let timer = null;
let computationCount = 0;
let controller = null;
@@ -1296,34 +1370,37 @@ var async;
});
}
controller = new StreamController({sync: true, onListen: (() => {
- watch.start();
- startPeriodicTimer();
- }).bind(this), onPause: (() => {
- timer.cancel();
- timer = null;
- watch.stop();
- }).bind(this), onResume: (() => {
- dart.assert(timer === null);
- let elapsed = watch.elapsed;
- watch.start();
- timer = new Timer(period['-'](elapsed), () => {
- timer = null;
+ watch.start();
startPeriodicTimer();
- sendEvent();
- });
- }).bind(this), onCancel: (() => {
- if (timer !== null) timer.cancel();
- timer = null;
- }).bind(this)});
+ }).bind(this), onPause: (() => {
+ timer.cancel();
+ timer = null;
+ watch.stop();
+ }).bind(this), onResume: (() => {
+ dart.assert(timer === null);
+ let elapsed = watch.elapsed;
+ watch.start();
+ timer = new Timer(period['-'](elapsed), () => {
+ timer = null;
+ startPeriodicTimer();
+ sendEvent();
+ });
+ }).bind(this), onCancel: (() => {
+ if (timer !== null)
+ timer.cancel();
+ timer = null;
+ }).bind(this)});
return controller.stream;
}
Stream$eventTransformed(source, mapSink) {
return dart.as(new _BoundSinkStream(source, mapSink), Stream$(T));
}
- get isBroadcast() { return false; }
+ get isBroadcast() {
+ return false;
+ }
asBroadcastStream(opt$) {
- let onListen = opt$.onListen === undefined ? null : opt$.onListen;
- let onCancel = opt$.onCancel === undefined ? null : opt$.onCancel;
+ let onListen = opt$.onListen === void 0 ? null : opt$.onListen;
+ let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel;
return new _AsBroadcastStream(this, onListen, onCancel);
}
where(test) {
@@ -1345,15 +1422,15 @@ var async;
let newValue = null;
try {
newValue = convert(event);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
controller.addError(e, s);
return;
}
+
if (dart.is(newValue, Future)) {
subscription.pause();
- dart.dinvoke(dart.dinvoke(newValue, "then", add, {onError: addError}), "whenComplete", subscription.resume);
+ dart.dinvoke(dart.dinvoke(newValue, 'then', add, {onError: addError}), 'whenComplete', subscription.resume);
} else {
controller.add(newValue);
}
@@ -1361,16 +1438,16 @@ var async;
}
if (this.isBroadcast) {
controller = new StreamController.broadcast({onListen: onListen, onCancel: (() => {
- subscription.cancel();
- }).bind(this), sync: true});
+ subscription.cancel();
+ }).bind(this), sync: true});
} else {
controller = new StreamController({onListen: onListen, onPause: (() => {
- subscription.pause();
- }).bind(this), onResume: (() => {
- subscription.resume();
- }).bind(this), onCancel: (() => {
- subscription.cancel();
- }).bind(this), sync: true});
+ subscription.pause();
+ }).bind(this), onResume: (() => {
+ subscription.resume();
+ }).bind(this), onCancel: (() => {
+ subscription.cancel();
+ }).bind(this), sync: true});
}
return controller.stream;
}
@@ -1385,12 +1462,12 @@ var async;
let newStream = null;
try {
newStream = convert(event);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
controller.addError(e, s);
return;
}
+
if (newStream !== null) {
subscription.pause();
controller.addStream(newStream).whenComplete(subscription.resume);
@@ -1399,21 +1476,21 @@ var async;
}
if (this.isBroadcast) {
controller = new StreamController.broadcast({onListen: onListen, onCancel: (() => {
- subscription.cancel();
- }).bind(this), sync: true});
+ subscription.cancel();
+ }).bind(this), sync: true});
} else {
controller = new StreamController({onListen: onListen, onPause: (() => {
- subscription.pause();
- }).bind(this), onResume: (() => {
- subscription.resume();
- }).bind(this), onCancel: (() => {
- subscription.cancel();
- }).bind(this), sync: true});
+ subscription.pause();
+ }).bind(this), onResume: (() => {
+ subscription.resume();
+ }).bind(this), onCancel: (() => {
+ subscription.cancel();
+ }).bind(this), sync: true});
}
return controller.stream;
}
handleError(onError, opt$) {
- let test = opt$.test === undefined ? null : opt$.test;
+ let test = opt$.test === void 0 ? null : opt$.test;
return new _HandleErrorStream(this, onError, test);
}
expand(convert) {
@@ -1434,24 +1511,24 @@ var async;
if (seenFirst) {
_runUserCode(() => combine(value, element), dart.as((newValue) => {
value = newValue;
- }, /* Unimplemented type (dynamic) → dynamic */), dart.as(_cancelAndErrorClosure(subscription, result), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.throw_("Unimplemented type (dynamic) → dynamic")), dart.as(_cancelAndErrorClosure(subscription, result), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
} else {
value = element;
seenFirst = true;
}
}, {onError: result._completeError, onDone: (() => {
- if (!dart.notNull(seenFirst)) {
- try {
- throw _internal.IterableElementError.noElement();
- }
- catch (e) {
- let s = dart.stackTrace(e);
- _completeWithErrorCallback(result, e, s);
+ if (!dart.notNull(seenFirst)) {
+ try {
+ throw _internal.IterableElementError.noElement();
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ _completeWithErrorCallback(result, e, s);
+ }
+
+ } else {
+ result._complete(value);
}
- } else {
- result._complete(value);
- }
- }).bind(this), cancelOnError: true});
+ }).bind(this), cancelOnError: true});
return result;
}
fold(initialValue, combine) {
@@ -1461,16 +1538,17 @@ var async;
subscription = this.listen((element) => {
_runUserCode(() => combine(value, element), (newValue) => {
value = newValue;
- }, dart.as(_cancelAndErrorClosure(subscription, result), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.as(_cancelAndErrorClosure(subscription, result), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: ((e, st) => {
- result._completeError(e, dart.as(st, core.StackTrace));
- }).bind(this), onDone: (() => {
- result._complete(value);
- }).bind(this), cancelOnError: true});
+ result._completeError(e, dart.as(st, core.StackTrace));
+ }).bind(this), onDone: (() => {
+ result._complete(value);
+ }).bind(this), cancelOnError: true});
return result;
}
join(separator) {
- if (separator === undefined) separator = "";
+ if (separator === void 0)
+ separator = "";
let result = new _Future();
let buffer = new core.StringBuffer();
let subscription = null;
@@ -1482,30 +1560,30 @@ var async;
first = false;
try {
buffer.write(element);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_cancelAndErrorWithReplacement(subscription, result, e, s);
}
+
}).bind(this), {onError: ((e) => {
- result._completeError(e);
- }).bind(this), onDone: (() => {
- result._complete(buffer.toString());
- }).bind(this), cancelOnError: true});
+ result._completeError(e);
+ }).bind(this), onDone: (() => {
+ result._complete(buffer.toString());
+ }).bind(this), cancelOnError: true});
return result;
}
contains(needle) {
let future = new _Future();
let subscription = null;
subscription = this.listen((element) => {
- _runUserCode(() => (dart.equals(element, needle)), dart.as((isMatch) => {
+ _runUserCode(() => dart.equals(element, needle), dart.as((isMatch) => {
if (isMatch) {
_cancelAndValue(subscription, future, true);
}
- }, /* Unimplemented type (dynamic) → dynamic */), dart.as(_cancelAndErrorClosure(subscription, future), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.throw_("Unimplemented type (dynamic) → dynamic")), dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future._completeError, onDone: (() => {
- future._complete(false);
- }).bind(this), cancelOnError: true});
+ future._complete(false);
+ }).bind(this), cancelOnError: true});
return future;
}
forEach(action) {
@@ -1513,10 +1591,10 @@ var async;
let subscription = null;
subscription = this.listen((element) => {
_runUserCode(() => action(element), (_) => {
- }, dart.as(_cancelAndErrorClosure(subscription, future), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future._completeError, onDone: (() => {
- future._complete(null);
- }).bind(this), cancelOnError: true});
+ future._complete(null);
+ }).bind(this), cancelOnError: true});
return future;
}
every(test) {
@@ -1527,10 +1605,10 @@ var async;
if (!dart.notNull(isMatch)) {
_cancelAndValue(subscription, future, false);
}
- }, /* Unimplemented type (dynamic) → dynamic */), dart.as(_cancelAndErrorClosure(subscription, future), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.throw_("Unimplemented type (dynamic) → dynamic")), dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future._completeError, onDone: (() => {
- future._complete(true);
- }).bind(this), cancelOnError: true});
+ future._complete(true);
+ }).bind(this), cancelOnError: true});
return future;
}
any(test) {
@@ -1541,10 +1619,10 @@ var async;
if (isMatch) {
_cancelAndValue(subscription, future, true);
}
- }, /* Unimplemented type (dynamic) → dynamic */), dart.as(_cancelAndErrorClosure(subscription, future), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.throw_("Unimplemented type (dynamic) → dynamic")), dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future._completeError, onDone: (() => {
- future._complete(false);
- }).bind(this), cancelOnError: true});
+ future._complete(false);
+ }).bind(this), cancelOnError: true});
return future;
}
get length() {
@@ -1553,8 +1631,8 @@ var async;
this.listen((_) => {
count++;
}, {onError: future._completeError, onDone: (() => {
- future._complete(count);
- }).bind(this), cancelOnError: true});
+ future._complete(count);
+ }).bind(this), cancelOnError: true});
return future;
}
get isEmpty() {
@@ -1563,8 +1641,8 @@ var async;
subscription = this.listen((_) => {
_cancelAndValue(subscription, future, false);
}, {onError: future._completeError, onDone: (() => {
- future._complete(true);
- }).bind(this), cancelOnError: true});
+ future._complete(true);
+ }).bind(this), cancelOnError: true});
return future;
}
toList() {
@@ -1573,8 +1651,8 @@ var async;
this.listen(((data) => {
result.add(data);
}).bind(this), {onError: future._completeError, onDone: (() => {
- future._complete(result);
- }).bind(this), cancelOnError: true});
+ future._complete(result);
+ }).bind(this), cancelOnError: true});
return future;
}
toSet() {
@@ -1583,13 +1661,14 @@ var async;
this.listen(((data) => {
result.add(data);
}).bind(this), {onError: future._completeError, onDone: (() => {
- future._complete(result);
- }).bind(this), cancelOnError: true});
+ future._complete(result);
+ }).bind(this), cancelOnError: true});
return future;
}
drain(futureValue) {
- if (futureValue === undefined) futureValue = null;
- return this.listen(null, {cancelOnError: true}).asFuture(futureValue)
+ if (futureValue === void 0)
+ futureValue = null;
+ return this.listen(null, {cancelOnError: true}).asFuture(futureValue);
}
take(count) {
return dart.as(new _TakeStream(this, count), Stream$(T));
@@ -1604,7 +1683,8 @@ var async;
return dart.as(new _SkipWhileStream(this, test), Stream$(T));
}
distinct(equals) {
- if (equals === undefined) equals = null;
+ if (equals === void 0)
+ equals = null;
return dart.as(new _DistinctStream(this, equals), Stream$(T));
}
get first() {
@@ -1612,15 +1692,19 @@ var async;
let subscription = null;
subscription = this.listen((value) => {
_cancelAndValue(subscription, future, value);
- }, {onError: future._completeError, onDone: () => {
- try {
- throw _internal.IterableElementError.noElement();
- }
- catch (e) {
- let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
- }
- }, cancelOnError: true});
+ }, {
+ onError: future._completeError,
+ onDone: () => {
+ try {
+ throw _internal.IterableElementError.noElement();
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ _completeWithErrorCallback(future, e, s);
+ }
+
+ },
+ cancelOnError: true
+ });
return future;
}
get last() {
@@ -1632,18 +1716,18 @@ var async;
foundResult = true;
result = value;
}, {onError: future._completeError, onDone: (() => {
- if (foundResult) {
- future._complete(result);
- return;
- }
- try {
- throw _internal.IterableElementError.noElement();
- }
- catch (e) {
- let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
- }
- }).bind(this), cancelOnError: true});
+ if (foundResult) {
+ future._complete(result);
+ return;
+ }
+ try {
+ throw _internal.IterableElementError.noElement();
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ _completeWithErrorCallback(future, e, s);
+ }
+
+ }).bind(this), cancelOnError: true});
return future;
}
get single() {
@@ -1655,32 +1739,32 @@ var async;
if (foundResult) {
try {
throw _internal.IterableElementError.tooMany();
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_cancelAndErrorWithReplacement(subscription, future, e, s);
}
+
return;
}
foundResult = true;
result = value;
}, {onError: future._completeError, onDone: (() => {
- if (foundResult) {
- future._complete(result);
- return;
- }
- try {
- throw _internal.IterableElementError.noElement();
- }
- catch (e) {
- let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
- }
- }).bind(this), cancelOnError: true});
+ if (foundResult) {
+ future._complete(result);
+ return;
+ }
+ try {
+ throw _internal.IterableElementError.noElement();
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ _completeWithErrorCallback(future, e, s);
+ }
+
+ }).bind(this), cancelOnError: true});
return future;
}
firstWhere(test, opt$) {
- let defaultValue = opt$.defaultValue === undefined ? null : opt$.defaultValue;
+ let defaultValue = opt$.defaultValue === void 0 ? null : opt$.defaultValue;
let future = new _Future();
let subscription = null;
subscription = this.listen((value) => {
@@ -1688,24 +1772,24 @@ var async;
if (isMatch) {
_cancelAndValue(subscription, future, value);
}
- }, /* Unimplemented type (dynamic) → dynamic */), dart.as(_cancelAndErrorClosure(subscription, future), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.throw_("Unimplemented type (dynamic) → dynamic")), dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future._completeError, onDone: (() => {
- if (defaultValue !== null) {
- _runUserCode(defaultValue, future._complete, future._completeError);
- return;
- }
- try {
- throw _internal.IterableElementError.noElement();
- }
- catch (e) {
- let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
- }
- }).bind(this), cancelOnError: true});
+ if (defaultValue !== null) {
+ _runUserCode(defaultValue, future._complete, future._completeError);
+ return;
+ }
+ try {
+ throw _internal.IterableElementError.noElement();
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ _completeWithErrorCallback(future, e, s);
+ }
+
+ }).bind(this), cancelOnError: true});
return future;
}
lastWhere(test, opt$) {
- let defaultValue = opt$.defaultValue === undefined ? null : opt$.defaultValue;
+ let defaultValue = opt$.defaultValue === void 0 ? null : opt$.defaultValue;
let future = new _Future();
let result = dart.as(null, T);
let foundResult = false;
@@ -1716,24 +1800,24 @@ var async;
foundResult = true;
result = value;
}
- }, /* Unimplemented type (dynamic) → dynamic */), dart.as(_cancelAndErrorClosure(subscription, future), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.throw_("Unimplemented type (dynamic) → dynamic")), dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future._completeError, onDone: (() => {
- if (foundResult) {
- future._complete(result);
- return;
- }
- if (defaultValue !== null) {
- _runUserCode(defaultValue, future._complete, future._completeError);
- return;
- }
- try {
- throw _internal.IterableElementError.noElement();
- }
- catch (e) {
- let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
- }
- }).bind(this), cancelOnError: true});
+ if (foundResult) {
+ future._complete(result);
+ return;
+ }
+ if (defaultValue !== null) {
+ _runUserCode(defaultValue, future._complete, future._completeError);
+ return;
+ }
+ try {
+ throw _internal.IterableElementError.noElement();
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ _completeWithErrorCallback(future, e, s);
+ }
+
+ }).bind(this), cancelOnError: true});
return future;
}
singleWhere(test) {
@@ -1747,34 +1831,35 @@ var async;
if (foundResult) {
try {
throw _internal.IterableElementError.tooMany();
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_cancelAndErrorWithReplacement(subscription, future, e, s);
}
+
return;
}
foundResult = true;
result = value;
}
- }, /* Unimplemented type (dynamic) → dynamic */), dart.as(_cancelAndErrorClosure(subscription, future), /* Unimplemented type (dynamic, StackTrace) → dynamic */));
+ }, dart.throw_("Unimplemented type (dynamic) → dynamic")), dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("Unimplemented type (dynamic, StackTrace) → dynamic")));
}, {onError: future._completeError, onDone: (() => {
- if (foundResult) {
- future._complete(result);
- return;
- }
- try {
- throw _internal.IterableElementError.noElement();
- }
- catch (e) {
- let s = dart.stackTrace(e);
- _completeWithErrorCallback(future, e, s);
- }
- }).bind(this), cancelOnError: true});
+ if (foundResult) {
+ future._complete(result);
+ return;
+ }
+ try {
+ throw _internal.IterableElementError.noElement();
+ } catch (e) {
+ let s = dart.stackTrace(e);
+ _completeWithErrorCallback(future, e, s);
+ }
+
+ }).bind(this), cancelOnError: true});
return future;
}
elementAt(index) {
- if (dart.notNull(!(typeof index == "number")) || dart.notNull(index < 0)) throw new core.ArgumentError(index);
+ if (dart.notNull(!(typeof index == number)) || dart.notNull(index < 0))
+ throw new core.ArgumentError(index);
let future = new _Future();
let subscription = null;
let elementIndex = 0;
@@ -1785,12 +1870,12 @@ var async;
}
elementIndex = 1;
}, {onError: future._completeError, onDone: (() => {
- future._completeError(new core.RangeError.index(index, this, "index", null, elementIndex));
- }).bind(this), cancelOnError: true});
+ future._completeError(new core.RangeError.index(index, this, "index", null, elementIndex));
+ }).bind(this), cancelOnError: true});
return future;
}
timeout(timeLimit, opt$) {
- let onTimeout = opt$.onTimeout === undefined ? null : opt$.onTimeout;
+ let onTimeout = opt$.onTimeout === void 0 ? null : opt$.onTimeout;
let controller = null;
let subscription = null;
let timer = null;
@@ -1800,15 +1885,15 @@ var async;
function onData(event) {
timer.cancel();
controller.add(event);
- timer = zone.createTimer(timeLimit, dart.as(timeout, /* Unimplemented type () → void */));
+ timer = zone.createTimer(timeLimit, dart.as(timeout, dart.throw_("Unimplemented type () → void")));
}
// Function onError: (dynamic, StackTrace) → void
function onError(error, stackTrace) {
timer.cancel();
dart.assert(dart.notNull(dart.is(controller, _StreamController)) || dart.notNull(dart.is(controller, _BroadcastStreamController)));
let eventSink = controller;
- dart.dinvoke(eventSink, "_addError", error, stackTrace);
- timer = zone.createTimer(timeLimit, dart.as(timeout, /* Unimplemented type () → void */));
+ dart.dinvoke(eventSink, '_addError', error, stackTrace);
+ timer = zone.createTimer(timeLimit, dart.as(timeout, dart.throw_("Unimplemented type () → void")));
}
// Function onDone: () → void
function onDone() {
@@ -1823,16 +1908,16 @@ var async;
controller.addError(new TimeoutException("No stream event", timeLimit), null);
}).bind(this);
} else {
- onTimeout = zone.registerUnaryCallback(dart.as(onTimeout, /* Unimplemented type (dynamic) → dynamic */));
+ onTimeout = zone.registerUnaryCallback(dart.as(onTimeout, dart.throw_("Unimplemented type (dynamic) → dynamic")));
let wrapper = new _ControllerEventSinkWrapper(null);
timeout = (() => {
wrapper._sink = controller;
- zone.runUnaryGuarded(dart.as(onTimeout, /* Unimplemented type (dynamic) → dynamic */), wrapper);
+ zone.runUnaryGuarded(dart.as(onTimeout, dart.throw_("Unimplemented type (dynamic) → dynamic")), wrapper);
wrapper._sink = null;
}).bind(this);
}
subscription = this.listen(onData, {onError: onError, onDone: onDone});
- timer = zone.createTimer(timeLimit, dart.as(timeout, /* Unimplemented type () → void */));
+ timer = zone.createTimer(timeLimit, dart.as(timeout, dart.throw_("Unimplemented type () → void")));
}
// Function onCancel: () → Future<dynamic>
function onCancel() {
@@ -1846,70 +1931,66 @@ var async;
subscription.pause();
}).bind(this), (() => {
subscription.resume();
- timer = zone.createTimer(timeLimit, dart.as(timeout, /* Unimplemented type () → void */));
+ timer = zone.createTimer(timeLimit, dart.as(timeout, dart.throw_("Unimplemented type () → void")));
}).bind(this), onCancel);
return controller.stream;
}
}
- dart.defineNamedConstructor(Stream, "fromFuture");
- dart.defineNamedConstructor(Stream, "fromIterable");
- dart.defineNamedConstructor(Stream, "periodic");
- dart.defineNamedConstructor(Stream, "eventTransformed");
+ dart.defineNamedConstructor(Stream, 'fromFuture');
+ dart.defineNamedConstructor(Stream, 'fromIterable');
+ dart.defineNamedConstructor(Stream, 'periodic');
+ dart.defineNamedConstructor(Stream, 'eventTransformed');
return Stream;
});
let Stream = Stream$(dynamic);
-
let StreamSubscription$ = dart.generic(function(T) {
class StreamSubscription extends dart.Object {
}
return StreamSubscription;
});
let StreamSubscription = StreamSubscription$(dynamic);
-
let EventSink$ = dart.generic(function(T) {
class EventSink extends dart.Object {
}
return EventSink;
});
let EventSink = EventSink$(dynamic);
-
let StreamView$ = dart.generic(function(T) {
class StreamView extends Stream$(T) {
StreamView(_stream) {
this._stream = _stream;
super.Stream();
}
- get isBroadcast() { return this._stream.isBroadcast; }
+ get isBroadcast() {
+ return this._stream.isBroadcast;
+ }
asBroadcastStream(opt$) {
- let onListen = opt$.onListen === undefined ? null : opt$.onListen;
- let onCancel = opt$.onCancel === undefined ? null : opt$.onCancel;
- return this._stream.asBroadcastStream({onListen: onListen, onCancel: onCancel})
+ let onListen = opt$.onListen === void 0 ? null : opt$.onListen;
+ let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel;
+ return this._stream.asBroadcastStream({onListen: onListen, onCancel: onCancel});
}
listen(onData, opt$) {
- let onError = opt$.onError === undefined ? null : opt$.onError;
- let onDone = opt$.onDone === undefined ? null : opt$.onDone;
- let cancelOnError = opt$.cancelOnError === undefined ? null : opt$.cancelOnError;
+ let onError = opt$.onError === void 0 ? null : opt$.onError;
+ let onDone = opt$.onDone === void 0 ? null : opt$.onDone;
+ let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOnError;
return this._stream.listen(onData, {onError: onError, onDone: onDone, cancelOnError: cancelOnError});
}
}
return StreamView;
});
let StreamView = StreamView$(dynamic);
-
let StreamConsumer$ = dart.generic(function(S) {
class StreamConsumer extends dart.Object {
}
return StreamConsumer;
});
let StreamConsumer = StreamConsumer$(dynamic);
-
let StreamSink$ = dart.generic(function(S) {
class StreamSink extends dart.Object {
}
return StreamSink;
});
let StreamSink = StreamSink$(dynamic);
-
let StreamTransformer$ = dart.generic(function(S, T) {
class StreamTransformer extends dart.Object {
StreamTransformer(transformer) {
@@ -1919,11 +2000,10 @@ var async;
return new _StreamHandlerTransformer(opt$);
}
}
- dart.defineNamedConstructor(StreamTransformer, "fromHandlers");
+ dart.defineNamedConstructor(StreamTransformer, 'fromHandlers');
return StreamTransformer;
});
let StreamTransformer = StreamTransformer$(dynamic, dynamic);
-
let StreamIterator$ = dart.generic(function(T) {
class StreamIterator extends dart.Object {
StreamIterator(stream) {
@@ -1933,7 +2013,6 @@ var async;
return StreamIterator;
});
let StreamIterator = StreamIterator$(dynamic);
-
let _ControllerEventSinkWrapper$ = dart.generic(function(T) {
class _ControllerEventSinkWrapper extends dart.Object {
_ControllerEventSinkWrapper(_sink) {
@@ -1943,7 +2022,8 @@ var async;
this._sink.add(data);
}
addError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
this._sink.addError(error, stackTrace);
}
close() {
@@ -1953,44 +2033,41 @@ var async;
return _ControllerEventSinkWrapper;
});
let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dynamic);
-
let StreamController$ = dart.generic(function(T) {
class StreamController extends dart.Object {
StreamController(opt$) {
- let onListen = opt$.onListen === undefined ? null : opt$.onListen;
- let onPause = opt$.onPause === undefined ? null : opt$.onPause;
- let onResume = opt$.onResume === undefined ? null : opt$.onResume;
- let onCancel = opt$.onCancel === undefined ? null : opt$.onCancel;
- let sync = opt$.sync === undefined ? false : opt$.sync;
+ let onListen = opt$.onListen === void 0 ? null : opt$.onListen;
+ let onPause = opt$.onPause === void 0 ? null : opt$.onPause;
+ let onResume = opt$.onResume === void 0 ? null : opt$.onResume;
+ let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel;
+ let sync = opt$.sync === void 0 ? false : opt$.sync;
if (dart.notNull(dart.notNull(dart.notNull(onListen === null) && dart.notNull(onPause === null)) && dart.notNull(onResume === null)) && dart.notNull(onCancel === null)) {
return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController(), StreamController$(T));
}
return sync ? new _SyncStreamController(onListen, onPause, onResume, onCancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel);
}
StreamController$broadcast(opt$) {
- let onListen = opt$.onListen === undefined ? null : opt$.onListen;
- let onCancel = opt$.onCancel === undefined ? null : opt$.onCancel;
- let sync = opt$.sync === undefined ? false : opt$.sync;
+ let onListen = opt$.onListen === void 0 ? null : opt$.onListen;
+ let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel;
+ let sync = opt$.sync === void 0 ? false : opt$.sync;
return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : new _AsyncBroadcastStreamController(onListen, onCancel);
}
}
- dart.defineNamedConstructor(StreamController, "broadcast");
+ dart.defineNamedConstructor(StreamController, 'broadcast');
return StreamController;
});
let StreamController = StreamController$(dynamic);
-
let _StreamControllerLifecycle$ = dart.generic(function(T) {
class _StreamControllerLifecycle extends dart.Object {
- _recordPause(subscription) {
- }
- _recordResume(subscription) {
+ _recordPause(subscription) {}
+ _recordResume(subscription) {}
+ _recordCancel(subscription) {
+ return null;
}
- _recordCancel(subscription) { return null; }
}
return _StreamControllerLifecycle;
});
let _StreamControllerLifecycle = _StreamControllerLifecycle$(dynamic);
-
let _StreamController$ = dart.generic(function(T) {
class _StreamController extends dart.Object {
_StreamController() {
@@ -1998,15 +2075,33 @@ var async;
this._state = _STATE_INITIAL;
this._doneFuture = null;
}
- get stream() { return dart.as(new _ControllerStream(this), Stream$(T)); }
- get sink() { return new _StreamSinkWrapper(this); }
- get _isCanceled() { return (this._state & _STATE_CANCELED) !== 0; }
- get hasListener() { return (this._state & _STATE_SUBSCRIBED) !== 0; }
- get _isInitialState() { return (this._state & _STATE_SUBSCRIPTION_MASK) === _STATE_INITIAL; }
- get isClosed() { return (this._state & _STATE_CLOSED) !== 0; }
- get isPaused() { return this.hasListener ? this._subscription._isInputPaused : !dart.notNull(this._isCanceled); }
- get _isAddingStream() { return (this._state & _STATE_ADDSTREAM) !== 0; }
- get _mayAddEvent() { return (this._state < _STATE_CLOSED); }
+ get stream() {
+ return dart.as(new _ControllerStream(this), Stream$(T));
+ }
+ get sink() {
+ return new _StreamSinkWrapper(this);
+ }
+ get _isCanceled() {
+ return (this._state & _STATE_CANCELED) !== 0;
+ }
+ get hasListener() {
+ return (this._state & _STATE_SUBSCRIBED) !== 0;
+ }
+ get _isInitialState() {
+ return (this._state & _STATE_SUBSCRIPTION_MASK) === _STATE_INITIAL;
+ }
+ get isClosed() {
+ return (this._state & _STATE_CLOSED) !== 0;
+ }
+ get isPaused() {
+ return this.hasListener ? this._subscription._isInputPaused : !dart.notNull(this._isCanceled);
+ }
+ get _isAddingStream() {
+ return (this._state & _STATE_ADDSTREAM) !== 0;
+ }
+ get _mayAddEvent() {
+ return this._state < _STATE_CLOSED;
+ }
get _pendingEvents() {
dart.assert(this._isInitialState);
if (!dart.notNull(this._isAddingStream)) {
@@ -2018,11 +2113,13 @@ var async;
_ensurePendingEvents() {
dart.assert(this._isInitialState);
if (!dart.notNull(this._isAddingStream)) {
- if (this._varData === null) this._varData = new _StreamImplEvents();
+ if (this._varData === null)
+ this._varData = new _StreamImplEvents();
return dart.as(this._varData, _StreamImplEvents);
}
let state = dart.as(this._varData, _StreamControllerAddStreamState);
- if (state.varData === null) state.varData = new _StreamImplEvents();
+ if (state.varData === null)
+ state.varData = new _StreamImplEvents();
return dart.as(state.varData, _StreamImplEvents);
}
get _subscription() {
@@ -2041,15 +2138,19 @@ var async;
return new core.StateError("Cannot add event while adding a stream");
}
addStream(source, opt$) {
- let cancelOnError = opt$.cancelOnError === undefined ? true : opt$.cancelOnError;
- if (!dart.notNull(this._mayAddEvent)) throw this._badEventState();
- if (this._isCanceled) return new _Future.immediate(null);
+ let cancelOnError = opt$.cancelOnError === void 0 ? true : opt$.cancelOnError;
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._badEventState();
+ if (this._isCanceled)
+ return new _Future.immediate(null);
let addState = new _StreamControllerAddStreamState(this, this._varData, source, cancelOnError);
this._varData = addState;
this._state = _STATE_ADDSTREAM;
return addState.addStreamFuture;
}
- get done() { return this._ensureDoneFuture(); }
+ get done() {
+ return this._ensureDoneFuture();
+ }
_ensureDoneFuture() {
if (this._doneFuture === null) {
this._doneFuture = this._isCanceled ? Future._nullFuture : new _Future();
@@ -2057,13 +2158,16 @@ var async;
return this._doneFuture;
}
add(value) {
- if (!dart.notNull(this._mayAddEvent)) throw this._badEventState();
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._badEventState();
this._add(value);
}
addError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
error = _nonNullError(error);
- if (!dart.notNull(this._mayAddEvent)) throw this._badEventState();
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._badEventState();
let replacement = Zone.current.errorCallback(error, stackTrace);
if (replacement !== null) {
error = _nonNullError(replacement.error);
@@ -2075,7 +2179,8 @@ var async;
if (this.isClosed) {
return this._ensureDoneFuture();
}
- if (!dart.notNull(this._mayAddEvent)) throw this._badEventState();
+ if (!dart.notNull(this._mayAddEvent))
+ throw this._badEventState();
this._closeUnchecked();
return this._ensureDoneFuture();
}
@@ -2135,19 +2240,19 @@ var async;
result = addState.cancel();
}
this._varData = null;
- this._state = (this._state & ~(_STATE_SUBSCRIBED | _STATE_ADDSTREAM)) | _STATE_CANCELED;
+ this._state = this._state & ~(_STATE_SUBSCRIBED | _STATE_ADDSTREAM) | _STATE_CANCELED;
if (this._onCancel !== null) {
if (result === null) {
try {
result = dart.as(this._onCancel(), Future);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
result = ((_) => {
_._asyncCompleteError(e, s);
return _;
}).bind(this)(new _Future());
}
+
} else {
result = result.whenComplete(this._onCancel);
}
@@ -2189,7 +2294,6 @@ var async;
return _StreamController;
});
let _StreamController = _StreamController$(dynamic);
-
let _SyncStreamControllerDispatch$ = dart.generic(function(T) {
class _SyncStreamControllerDispatch extends dart.Object {
_sendData(data) {
@@ -2205,7 +2309,6 @@ var async;
return _SyncStreamControllerDispatch;
});
let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(dynamic);
-
let _AsyncStreamControllerDispatch$ = dart.generic(function(T) {
class _AsyncStreamControllerDispatch extends dart.Object {
_sendData(data) {
@@ -2221,7 +2324,6 @@ var async;
return _AsyncStreamControllerDispatch;
});
let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(dynamic);
-
let _AsyncStreamController$ = dart.generic(function(T) {
class _AsyncStreamController extends dart.mixin(_StreamController$(T), _AsyncStreamControllerDispatch$(T)) {
_AsyncStreamController(_onListen, _onPause, _onResume, _onCancel) {
@@ -2235,7 +2337,6 @@ var async;
return _AsyncStreamController;
});
let _AsyncStreamController = _AsyncStreamController$(dynamic);
-
let _SyncStreamController$ = dart.generic(function(T) {
class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncStreamControllerDispatch$(T)) {
_SyncStreamController(_onListen, _onPause, _onResume, _onCancel) {
@@ -2249,43 +2350,56 @@ var async;
return _SyncStreamController;
});
let _SyncStreamController = _SyncStreamController$(dynamic);
-
class _NoCallbacks extends dart.Object {
- get _onListen() { return null; }
- get _onPause() { return null; }
- get _onResume() { return null; }
- get _onCancel() { return null; }
+ get _onListen() {
+ return null;
+ }
+ get _onPause() {
+ return null;
+ }
+ get _onResume() {
+ return null;
+ }
+ get _onCancel() {
+ return null;
+ }
+ }
+ class _NoCallbackAsyncStreamController extends dart.mixin(_AsyncStreamControllerDispatch, _NoCallbacks) {
+ }
+ class _NoCallbackSyncStreamController extends dart.mixin(_SyncStreamControllerDispatch, _NoCallbacks) {
}
-
- class _NoCallbackAsyncStreamController extends dart.mixin(_AsyncStreamControllerDispatch, _NoCallbacks) {}
-
- class _NoCallbackSyncStreamController extends dart.mixin(_SyncStreamControllerDispatch, _NoCallbacks) {}
-
// Function _runGuarded: (() → dynamic) → Future<dynamic>
function _runGuarded(notificationHandler) {
- if (notificationHandler === null) return null;
+ if (notificationHandler === null)
+ return null;
try {
let result = notificationHandler();
- if (dart.is(result, Future)) return dart.as(result, Future);
+ if (dart.is(result, Future))
+ return dart.as(result, Future);
return null;
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
Zone.current.handleUncaughtError(e, s);
}
- }
+ }
let _ControllerStream$ = dart.generic(function(T) {
class _ControllerStream extends _StreamImpl$(T) {
_ControllerStream(_controller) {
this._controller = _controller;
super._StreamImpl();
}
- _createSubscription(onData, onError, onDone, cancelOnError) { return this._controller._subscribe(onData, onError, onDone, cancelOnError); }
- get hashCode() { return this._controller.hashCode ^ 892482866; }
+ _createSubscription(onData, onError, onDone, cancelOnError) {
+ return this._controller._subscribe(onData, onError, onDone, cancelOnError);
+ }
+ get hashCode() {
+ return this._controller.hashCode ^ 892482866;
+ }
['=='](other) {
- if (core.identical(this, other)) return true;
- if (!dart.is(other, _ControllerStream)) return false;
+ if (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);
}
@@ -2293,7 +2407,6 @@ var async;
return _ControllerStream;
});
let _ControllerStream = _ControllerStream$(dynamic);
-
let _ControllerSubscription$ = dart.generic(function(T) {
class _ControllerSubscription extends _BufferingStreamSubscription$(T) {
_ControllerSubscription(_controller, onData, onError, onDone, cancelOnError) {
@@ -2313,7 +2426,6 @@ var async;
return _ControllerSubscription;
});
let _ControllerSubscription = _ControllerSubscription$(dynamic);
-
let _StreamSinkWrapper$ = dart.generic(function(T) {
class _StreamSinkWrapper extends dart.Object {
_StreamSinkWrapper(_target) {
@@ -2323,30 +2435,36 @@ var async;
this._target.add(data);
}
addError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
this._target.addError(error, stackTrace);
}
- close() { return this._target.close(); }
+ close() {
+ return this._target.close();
+ }
addStream(source, opt$) {
- let cancelOnError = opt$.cancelOnError === undefined ? true : opt$.cancelOnError;
- return this._target.addStream(source, {cancelOnError: cancelOnError})
+ let cancelOnError = opt$.cancelOnError === void 0 ? true : opt$.cancelOnError;
+ return this._target.addStream(source, {cancelOnError: cancelOnError});
+ }
+ get done() {
+ return this._target.done;
}
- get done() { return this._target.done; }
}
return _StreamSinkWrapper;
});
let _StreamSinkWrapper = _StreamSinkWrapper$(dynamic);
-
let _AddStreamState$ = dart.generic(function(T) {
class _AddStreamState extends dart.Object {
_AddStreamState(controller, source, cancelOnError) {
this.addStreamFuture = new _Future();
- this.addSubscription = source.listen(dart.as(controller._add, /* Unimplemented type (dynamic) → void */), {onError: dart.as(cancelOnError ? makeErrorHandler(controller) : controller._addError, core.Function), onDone: controller._close, cancelOnError: cancelOnError});
+ this.addSubscription = source.listen(dart.as(controller._add, dart.throw_("Unimplemented type (dynamic) → void")), {onError: dart.as(cancelOnError ? makeErrorHandler(controller) : controller._addError, core.Function), onDone: controller._close, cancelOnError: cancelOnError});
+ }
+ static makeErrorHandler(controller) {
+ return ((e, s) => {
+ controller._addError(e, s);
+ controller._close();
+ }).bind(this);
}
- static makeErrorHandler(controller) { return ((e, s) => {
- controller._addError(e, s);
- controller._close();
- }).bind(this); }
pause() {
this.addSubscription.pause();
}
@@ -2370,7 +2488,6 @@ var async;
return _AddStreamState;
});
let _AddStreamState = _AddStreamState$(dynamic);
-
let _StreamControllerAddStreamState$ = dart.generic(function(T) {
class _StreamControllerAddStreamState extends _AddStreamState$(T) {
_StreamControllerAddStreamState(controller, varData, source, cancelOnError) {
@@ -2384,26 +2501,23 @@ var async;
return _StreamControllerAddStreamState;
});
let _StreamControllerAddStreamState = _StreamControllerAddStreamState$(dynamic);
-
let _EventSink$ = dart.generic(function(T) {
class _EventSink extends dart.Object {
}
return _EventSink;
});
let _EventSink = _EventSink$(dynamic);
-
let _EventDispatch$ = dart.generic(function(T) {
class _EventDispatch extends dart.Object {
}
return _EventDispatch;
});
let _EventDispatch = _EventDispatch$(dynamic);
-
let _BufferingStreamSubscription$ = dart.generic(function(T) {
class _BufferingStreamSubscription extends dart.Object {
_BufferingStreamSubscription(onData, onError, onDone, cancelOnError) {
this._zone = Zone.current;
- this._state = (cancelOnError ? _STATE_CANCEL_ON_ERROR : 0);
+ this._state = cancelOnError ? _STATE_CANCEL_ON_ERROR : 0;
this._onData = null;
this._onError = null;
this._onDone = null;
@@ -2415,7 +2529,8 @@ var async;
}
_setPendingEvents(pendingEvents) {
dart.assert(this._pending === null);
- if (pendingEvents === null) return;
+ if (pendingEvents === null)
+ return;
this._pending = pendingEvents;
if (!dart.notNull(pendingEvents.isEmpty)) {
this._state = _STATE_HAS_PENDING;
@@ -2429,29 +2544,38 @@ var async;
return events;
}
onData(handleData) {
- if (handleData === null) handleData = _nullDataHandler;
- this._onData = this._zone.registerUnaryCallback(dart.as(handleData, /* Unimplemented type (dynamic) → dynamic */));
+ if (handleData === null)
+ handleData = _nullDataHandler;
+ this._onData = this._zone.registerUnaryCallback(dart.as(handleData, dart.throw_("Unimplemented type (dynamic) → dynamic")));
}
onError(handleError) {
- if (handleError === null) handleError = _nullErrorHandler;
+ if (handleError === null)
+ handleError = _nullErrorHandler;
this._onError = _registerErrorHandler(handleError, this._zone);
}
onDone(handleDone) {
- if (handleDone === null) handleDone = _nullDoneHandler;
+ if (handleDone === null)
+ handleDone = _nullDoneHandler;
this._onDone = this._zone.registerCallback(handleDone);
}
pause(resumeSignal) {
- if (resumeSignal === undefined) resumeSignal = null;
- if (this._isCanceled) return;
+ if (resumeSignal === void 0)
+ resumeSignal = null;
+ if (this._isCanceled)
+ return;
let wasPaused = this._isPaused;
let wasInputPaused = this._isInputPaused;
- this._state = (this._state + _STATE_PAUSE_COUNT) | _STATE_INPUT_PAUSED;
- if (resumeSignal !== null) resumeSignal.whenComplete(this.resume);
- if (dart.notNull(!dart.notNull(wasPaused)) && dart.notNull(this._pending !== null)) this._pending.cancelSchedule();
- if (dart.notNull(!dart.notNull(wasInputPaused)) && dart.notNull(!dart.notNull(this._inCallback))) this._guardCallback(this._onPause);
+ this._state = this._state + _STATE_PAUSE_COUNT | _STATE_INPUT_PAUSED;
+ if (resumeSignal !== null)
+ resumeSignal.whenComplete(this.resume);
+ if (dart.notNull(!dart.notNull(wasPaused)) && dart.notNull(this._pending !== null))
+ this._pending.cancelSchedule();
+ if (dart.notNull(!dart.notNull(wasInputPaused)) && dart.notNull(!dart.notNull(this._inCallback)))
+ this._guardCallback(this._onPause);
}
resume() {
- if (this._isCanceled) return;
+ if (this._isCanceled)
+ return;
if (this._isPaused) {
this._decrementPauseCount();
if (!dart.notNull(this._isPaused)) {
@@ -2460,19 +2584,22 @@ var async;
} else {
dart.assert(this._mayResumeInput);
this._state = ~_STATE_INPUT_PAUSED;
- if (!dart.notNull(this._inCallback)) this._guardCallback(this._onResume);
+ if (!dart.notNull(this._inCallback))
+ this._guardCallback(this._onResume);
}
}
}
}
cancel() {
this._state = ~_STATE_WAIT_FOR_CANCEL;
- if (this._isCanceled) return this._cancelFuture;
+ if (this._isCanceled)
+ return this._cancelFuture;
this._cancel();
return this._cancelFuture;
}
asFuture(futureValue) {
- if (futureValue === undefined) futureValue = null;
+ if (futureValue === void 0)
+ futureValue = null;
let result = new _Future();
this._onDone = (() => {
result._complete(futureValue);
@@ -2483,27 +2610,50 @@ var async;
}).bind(this);
return result;
}
- get _isInputPaused() { return (this._state & _STATE_INPUT_PAUSED) !== 0; }
- get _isClosed() { return (this._state & _STATE_CLOSED) !== 0; }
- get _isCanceled() { return (this._state & _STATE_CANCELED) !== 0; }
- get _waitsForCancel() { return (this._state & _STATE_WAIT_FOR_CANCEL) !== 0; }
- get _inCallback() { return (this._state & _STATE_IN_CALLBACK) !== 0; }
- get _hasPending() { return (this._state & _STATE_HAS_PENDING) !== 0; }
- get _isPaused() { return this._state >= _STATE_PAUSE_COUNT; }
- get _canFire() { return this._state < _STATE_IN_CALLBACK; }
- get _mayResumeInput() { return dart.notNull(!dart.notNull(this._isPaused)) && dart.notNull((dart.notNull(this._pending === null) || dart.notNull(this._pending.isEmpty))); }
- get _cancelOnError() { return (this._state & _STATE_CANCEL_ON_ERROR) !== 0; }
- get isPaused() { return this._isPaused; }
+ get _isInputPaused() {
+ return (this._state & _STATE_INPUT_PAUSED) !== 0;
+ }
+ get _isClosed() {
+ return (this._state & _STATE_CLOSED) !== 0;
+ }
+ get _isCanceled() {
+ return (this._state & _STATE_CANCELED) !== 0;
+ }
+ get _waitsForCancel() {
+ return (this._state & _STATE_WAIT_FOR_CANCEL) !== 0;
+ }
+ get _inCallback() {
+ return (this._state & _STATE_IN_CALLBACK) !== 0;
+ }
+ get _hasPending() {
+ return (this._state & _STATE_HAS_PENDING) !== 0;
+ }
+ get _isPaused() {
+ return this._state >= _STATE_PAUSE_COUNT;
+ }
+ get _canFire() {
+ return this._state < _STATE_IN_CALLBACK;
+ }
+ get _mayResumeInput() {
+ return dart.notNull(!dart.notNull(this._isPaused)) && dart.notNull(dart.notNull(this._pending === null) || dart.notNull(this._pending.isEmpty));
+ }
+ get _cancelOnError() {
+ return (this._state & _STATE_CANCEL_ON_ERROR) !== 0;
+ }
+ get isPaused() {
+ return this._isPaused;
+ }
_cancel() {
this._state = _STATE_CANCELED;
if (this._hasPending) {
this._pending.cancelSchedule();
}
- if (!dart.notNull(this._inCallback)) this._pending = null;
+ if (!dart.notNull(this._inCallback))
+ this._pending = null;
this._cancelFuture = this._onCancel();
}
_incrementPauseCount() {
- this._state = (this._state + _STATE_PAUSE_COUNT) | _STATE_INPUT_PAUSED;
+ this._state = this._state + _STATE_PAUSE_COUNT | _STATE_INPUT_PAUSED;
}
_decrementPauseCount() {
dart.assert(this._isPaused);
@@ -2511,7 +2661,8 @@ var async;
}
_add(data) {
dart.assert(!dart.notNull(this._isClosed));
- if (this._isCanceled) return;
+ if (this._isCanceled)
+ return;
if (this._canFire) {
this._sendData(data);
} else {
@@ -2519,7 +2670,8 @@ var async;
}
}
_addError(error, stackTrace) {
- if (this._isCanceled) return;
+ if (this._isCanceled)
+ return;
if (this._canFire) {
this._sendError(error, stackTrace);
} else {
@@ -2528,7 +2680,8 @@ var async;
}
_close() {
dart.assert(!dart.notNull(this._isClosed));
- if (this._isCanceled) return;
+ if (this._isCanceled)
+ return;
this._state = _STATE_CLOSED;
if (this._canFire) {
this._sendDone();
@@ -2548,7 +2701,8 @@ var async;
}
_addPending(event) {
let pending = dart.as(this._pending, _StreamImplEvents);
- if (this._pending === null) pending = this._pending = new _StreamImplEvents();
+ if (this._pending === null)
+ pending = this._pending = new _StreamImplEvents();
pending.add(event);
if (!dart.notNull(this._hasPending)) {
this._state = _STATE_HAS_PENDING;
@@ -2563,7 +2717,7 @@ var async;
dart.assert(!dart.notNull(this._inCallback));
let wasInputPaused = this._isInputPaused;
this._state = _STATE_IN_CALLBACK;
- this._zone.runUnaryGuarded(dart.as(this._onData, /* Unimplemented type (dynamic) → dynamic */), data);
+ this._zone.runUnaryGuarded(dart.as(this._onData, dart.throw_("Unimplemented type (dynamic) → dynamic")), data);
this._state = ~_STATE_IN_CALLBACK;
this._checkState(wasInputPaused);
}
@@ -2574,12 +2728,13 @@ var async;
let wasInputPaused = this._isInputPaused;
// Function sendError: () → void
function sendError() {
- if (dart.notNull(this._isCanceled) && dart.notNull(!dart.notNull(this._waitsForCancel))) return;
+ if (dart.notNull(this._isCanceled) && dart.notNull(!dart.notNull(this._waitsForCancel)))
+ return;
this._state = _STATE_IN_CALLBACK;
if (dart.is(this._onError, ZoneBinaryCallback)) {
- this._zone.runBinaryGuarded(dart.as(this._onError, /* Unimplemented type (dynamic, dynamic) → dynamic */), error, stackTrace);
+ this._zone.runBinaryGuarded(dart.as(this._onError, dart.throw_("Unimplemented type (dynamic, dynamic) → dynamic")), error, stackTrace);
} else {
- this._zone.runUnaryGuarded(dart.as(this._onError, /* Unimplemented type (dynamic) → dynamic */), error);
+ this._zone.runUnaryGuarded(dart.as(this._onError, dart.throw_("Unimplemented type (dynamic) → dynamic")), error);
}
this._state = ~_STATE_IN_CALLBACK;
}
@@ -2602,8 +2757,9 @@ var async;
dart.assert(!dart.notNull(this._inCallback));
// Function sendDone: () → void
function sendDone() {
- if (!dart.notNull(this._waitsForCancel)) return;
- this._state = (_STATE_CANCELED | _STATE_CLOSED | _STATE_IN_CALLBACK);
+ if (!dart.notNull(this._waitsForCancel))
+ return;
+ this._state = _STATE_CANCELED | _STATE_CLOSED | _STATE_IN_CALLBACK;
this._zone.runGuarded(this._onDone);
this._state = ~_STATE_IN_CALLBACK;
}
@@ -2637,7 +2793,8 @@ var async;
return;
}
let isInputPaused = this._isInputPaused;
- if (wasInputPaused === isInputPaused) break;
+ if (wasInputPaused === isInputPaused)
+ break;
this._state = _STATE_IN_CALLBACK;
if (isInputPaused) {
this._onPause();
@@ -2664,13 +2821,12 @@ var async;
return _BufferingStreamSubscription;
});
let _BufferingStreamSubscription = _BufferingStreamSubscription$(dynamic);
-
let _StreamImpl$ = dart.generic(function(T) {
class _StreamImpl extends Stream$(T) {
listen(onData, opt$) {
- let onError = opt$.onError === undefined ? null : opt$.onError;
- let onDone = opt$.onDone === undefined ? null : opt$.onDone;
- let cancelOnError = opt$.cancelOnError === undefined ? null : opt$.cancelOnError;
+ let onError = opt$.onError === void 0 ? null : opt$.onError;
+ let onDone = opt$.onDone === void 0 ? null : opt$.onDone;
+ let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOnError;
cancelOnError = core.identical(true, cancelOnError);
let subscription = this._createSubscription(onData, onError, onDone, cancelOnError);
this._onListen(subscription);
@@ -2679,13 +2835,11 @@ var async;
_createSubscription(onData, onError, onDone, cancelOnError) {
return new _BufferingStreamSubscription(onData, onError, onDone, cancelOnError);
}
- _onListen(subscription) {
- }
+ _onListen(subscription) {}
}
return _StreamImpl;
});
let _StreamImpl = _StreamImpl$(dynamic);
-
let _GeneratedStreamImpl$ = dart.generic(function(T) {
class _GeneratedStreamImpl extends _StreamImpl$(T) {
_GeneratedStreamImpl(_pending) {
@@ -2694,7 +2848,8 @@ var async;
super._StreamImpl();
}
_createSubscription(onData, onError, onDone, cancelOnError) {
- if (this._isUsed) throw new core.StateError("Stream has already been listened to.");
+ if (this._isUsed)
+ throw new core.StateError("Stream has already been listened to.");
this._isUsed = true;
return ((_) => {
_._setPendingEvents(this._pending());
@@ -2705,14 +2860,15 @@ var async;
return _GeneratedStreamImpl;
});
let _GeneratedStreamImpl = _GeneratedStreamImpl$(dynamic);
-
let _IterablePendingEvents$ = dart.generic(function(T) {
class _IterablePendingEvents extends _PendingEvents {
_IterablePendingEvents(data) {
this._iterator = data.iterator;
super._PendingEvents();
}
- get isEmpty() { return this._iterator === null; }
+ get isEmpty() {
+ return this._iterator === null;
+ }
handleNext(dispatch) {
if (this._iterator === null) {
throw new core.StateError("No events pending.");
@@ -2720,13 +2876,13 @@ var async;
let isDone = null;
try {
isDone = !dart.notNull(this._iterator.moveNext());
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
this._iterator = null;
dispatch._sendError(e, s);
return;
}
+
if (!dart.notNull(isDone)) {
dispatch._sendData(this._iterator.current);
} else {
@@ -2735,34 +2891,31 @@ var async;
}
}
clear() {
- if (this.isScheduled) this.cancelSchedule();
+ if (this.isScheduled)
+ this.cancelSchedule();
this._iterator = null;
}
}
return _IterablePendingEvents;
});
let _IterablePendingEvents = _IterablePendingEvents$(dynamic);
-
// Function _nullDataHandler: (dynamic) → void
function _nullDataHandler(value) {
}
-
// Function _nullErrorHandler: (dynamic, [StackTrace]) → void
function _nullErrorHandler(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
Zone.current.handleUncaughtError(error, stackTrace);
}
-
// Function _nullDoneHandler: () → void
function _nullDoneHandler() {
}
-
class _DelayedEvent extends dart.Object {
_DelayedEvent() {
this.next = null;
}
}
-
let _DelayedData$ = dart.generic(function(T) {
class _DelayedData extends _DelayedEvent {
_DelayedData(value) {
@@ -2776,7 +2929,6 @@ var async;
return _DelayedData;
});
let _DelayedData = _DelayedData$(dynamic);
-
class _DelayedError extends _DelayedEvent {
_DelayedError(error, stackTrace) {
this.error = error;
@@ -2787,27 +2939,32 @@ var async;
dispatch._sendError(this.error, this.stackTrace);
}
}
-
class _DelayedDone extends dart.Object {
_DelayedDone() {
}
perform(dispatch) {
dispatch._sendDone();
}
- get next() { return null; }
+ get next() {
+ return null;
+ }
set next(_) {
throw new core.StateError("No events after a done.");
}
}
-
class _PendingEvents extends dart.Object {
_PendingEvents() {
this._state = _STATE_UNSCHEDULED;
}
- get isScheduled() { return this._state === _STATE_SCHEDULED; }
- get _eventScheduled() { return this._state >= _STATE_SCHEDULED; }
+ get isScheduled() {
+ return this._state === _STATE_SCHEDULED;
+ }
+ get _eventScheduled() {
+ return this._state >= _STATE_SCHEDULED;
+ }
schedule(dispatch) {
- if (this.isScheduled) return;
+ if (this.isScheduled)
+ return;
dart.assert(!dart.notNull(this.isEmpty));
if (this._eventScheduled) {
dart.assert(this._state === _STATE_CANCELED);
@@ -2817,26 +2974,29 @@ var async;
scheduleMicrotask((() => {
let oldState = this._state;
this._state = _STATE_UNSCHEDULED;
- if (oldState === _STATE_CANCELED) return;
+ if (oldState === _STATE_CANCELED)
+ return;
this.handleNext(dispatch);
}).bind(this));
this._state = _STATE_SCHEDULED;
}
cancelSchedule() {
- if (this.isScheduled) this._state = _STATE_CANCELED;
+ if (this.isScheduled)
+ this._state = _STATE_CANCELED;
}
}
_PendingEvents._STATE_UNSCHEDULED = 0;
_PendingEvents._STATE_SCHEDULED = 1;
_PendingEvents._STATE_CANCELED = 3;
-
class _StreamImplEvents extends _PendingEvents {
_StreamImplEvents() {
this.firstPendingEvent = null;
this.lastPendingEvent = null;
super._PendingEvents();
}
- get isEmpty() { return this.lastPendingEvent === null; }
+ get isEmpty() {
+ return this.lastPendingEvent === null;
+ }
add(event) {
if (this.lastPendingEvent === null) {
this.firstPendingEvent = this.lastPendingEvent = event;
@@ -2854,11 +3014,11 @@ var async;
event.perform(dispatch);
}
clear() {
- if (this.isScheduled) this.cancelSchedule();
+ if (this.isScheduled)
+ this.cancelSchedule();
this.firstPendingEvent = this.lastPendingEvent = null;
}
}
-
class _BroadcastLinkedList extends dart.Object {
_BroadcastLinkedList() {
this._next = null;
@@ -2877,7 +3037,6 @@ var async;
this._previous = newPrevious;
}
}
-
let _DoneStreamSubscription$ = dart.generic(function(T) {
class _DoneStreamSubscription extends dart.Object {
_DoneStreamSubscription(_onDone) {
@@ -2886,25 +3045,32 @@ var async;
this._state = 0;
this._schedule();
}
- get _isSent() { return (this._state & _DONE_SENT) !== 0; }
- get _isScheduled() { return (this._state & _SCHEDULED) !== 0; }
- get isPaused() { return this._state >= _PAUSED; }
+ get _isSent() {
+ return (this._state & _DONE_SENT) !== 0;
+ }
+ get _isScheduled() {
+ return (this._state & _SCHEDULED) !== 0;
+ }
+ get isPaused() {
+ return this._state >= _PAUSED;
+ }
_schedule() {
- if (this._isScheduled) return;
+ if (this._isScheduled)
+ return;
this._zone.scheduleMicrotask(this._sendDone);
this._state = _SCHEDULED;
}
- onData(handleData) {
- }
- onError(handleError) {
- }
+ onData(handleData) {}
+ onError(handleError) {}
onDone(handleDone) {
this._onDone = handleDone;
}
pause(resumeSignal) {
- if (resumeSignal === undefined) resumeSignal = null;
+ if (resumeSignal === void 0)
+ resumeSignal = null;
this._state = _PAUSED;
- if (resumeSignal !== null) resumeSignal.whenComplete(this.resume);
+ if (resumeSignal !== null)
+ resumeSignal.whenComplete(this.resume);
}
resume() {
if (this.isPaused) {
@@ -2914,9 +3080,12 @@ var async;
}
}
}
- cancel() { return null; }
+ cancel() {
+ return null;
+ }
asFuture(futureValue) {
- if (futureValue === undefined) futureValue = null;
+ if (futureValue === void 0)
+ futureValue = null;
let result = new _Future();
this._onDone = (() => {
result._completeWithValue(null);
@@ -2925,9 +3094,11 @@ var async;
}
_sendDone() {
this._state = ~_SCHEDULED;
- if (this.isPaused) return;
+ if (this.isPaused)
+ return;
this._state = _DONE_SENT;
- if (this._onDone !== null) this._zone.runGuarded(this._onDone);
+ if (this._onDone !== null)
+ this._zone.runGuarded(this._onDone);
}
}
_DoneStreamSubscription._DONE_SENT = 1;
@@ -2936,24 +3107,25 @@ var async;
return _DoneStreamSubscription;
});
let _DoneStreamSubscription = _DoneStreamSubscription$(dynamic);
-
let _AsBroadcastStream$ = dart.generic(function(T) {
class _AsBroadcastStream extends Stream$(T) {
_AsBroadcastStream(_source, onListenHandler, onCancelHandler) {
this._source = _source;
- this._onListenHandler = Zone.current.registerUnaryCallback(dart.as(onListenHandler, /* Unimplemented type (dynamic) → dynamic */));
- this._onCancelHandler = Zone.current.registerUnaryCallback(dart.as(onCancelHandler, /* Unimplemented type (dynamic) → dynamic */));
+ this._onListenHandler = Zone.current.registerUnaryCallback(dart.as(onListenHandler, dart.throw_("Unimplemented type (dynamic) → dynamic")));
+ this._onCancelHandler = Zone.current.registerUnaryCallback(dart.as(onCancelHandler, dart.throw_("Unimplemented type (dynamic) → dynamic")));
this._zone = Zone.current;
this._controller = null;
this._subscription = null;
super.Stream();
this._controller = new _AsBroadcastStreamController(this._onListen, this._onCancel);
}
- get isBroadcast() { return true; }
+ get isBroadcast() {
+ return true;
+ }
listen(onData, opt$) {
- let onError = opt$.onError === undefined ? null : opt$.onError;
- let onDone = opt$.onDone === undefined ? null : opt$.onDone;
- let cancelOnError = opt$.cancelOnError === undefined ? null : opt$.cancelOnError;
+ let onError = opt$.onError === void 0 ? null : opt$.onError;
+ let onDone = opt$.onDone === void 0 ? null : opt$.onDone;
+ let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOnError;
if (dart.notNull(this._controller === null) || dart.notNull(this._controller.isClosed)) {
return new _DoneStreamSubscription(onDone);
}
@@ -2964,9 +3136,9 @@ var async;
return this._controller._subscribe(onData, onError, onDone, cancelOnError);
}
_onCancel() {
- let shutdown = dart.notNull((this._controller === null)) || dart.notNull(this._controller.isClosed);
+ let shutdown = dart.notNull(this._controller === null) || dart.notNull(this._controller.isClosed);
if (this._onCancelHandler !== null) {
- this._zone.runUnary(dart.as(this._onCancelHandler, /* Unimplemented type (dynamic) → dynamic */), new _BroadcastSubscriptionWrapper(this));
+ this._zone.runUnary(dart.as(this._onCancelHandler, dart.throw_("Unimplemented type (dynamic) → dynamic")), new _BroadcastSubscriptionWrapper(this));
}
if (shutdown) {
if (this._subscription !== null) {
@@ -2977,33 +3149,36 @@ var async;
}
_onListen() {
if (this._onListenHandler !== null) {
- this._zone.runUnary(dart.as(this._onListenHandler, /* Unimplemented type (dynamic) → dynamic */), new _BroadcastSubscriptionWrapper(this));
+ this._zone.runUnary(dart.as(this._onListenHandler, dart.throw_("Unimplemented type (dynamic) → dynamic")), new _BroadcastSubscriptionWrapper(this));
}
}
_cancelSubscription() {
- if (this._subscription === null) return;
+ if (this._subscription === null)
+ return;
let subscription = this._subscription;
this._subscription = null;
this._controller = null;
subscription.cancel();
}
_pauseSubscription(resumeSignal) {
- if (this._subscription === null) return;
+ if (this._subscription === null)
+ return;
this._subscription.pause(resumeSignal);
}
_resumeSubscription() {
- if (this._subscription === null) return;
+ if (this._subscription === null)
+ return;
this._subscription.resume();
}
get _isSubscriptionPaused() {
- if (this._subscription === null) return false;
+ if (this._subscription === null)
+ return false;
return this._subscription.isPaused;
}
}
return _AsBroadcastStream;
});
let _AsBroadcastStream = _AsBroadcastStream$(dynamic);
-
let _BroadcastSubscriptionWrapper$ = dart.generic(function(T) {
class _BroadcastSubscriptionWrapper extends dart.Object {
_BroadcastSubscriptionWrapper(_stream) {
@@ -3019,7 +3194,8 @@ var async;
throw new core.UnsupportedError("Cannot change handlers of asBroadcastStream source subscription.");
}
pause(resumeSignal) {
- if (resumeSignal === undefined) resumeSignal = null;
+ if (resumeSignal === void 0)
+ resumeSignal = null;
this._stream._pauseSubscription(resumeSignal);
}
resume() {
@@ -3033,14 +3209,14 @@ var async;
return this._stream._isSubscriptionPaused;
}
asFuture(futureValue) {
- if (futureValue === undefined) futureValue = null;
+ if (futureValue === void 0)
+ futureValue = null;
throw new core.UnsupportedError("Cannot change handlers of asBroadcastStream source subscription.");
}
}
return _BroadcastSubscriptionWrapper;
});
let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(dynamic);
-
let _StreamIteratorImpl$ = dart.generic(function(T) {
class _StreamIteratorImpl extends dart.Object {
_StreamIteratorImpl(stream) {
@@ -3050,7 +3226,9 @@ var async;
this._state = _STATE_FOUND;
this._subscription = stream.listen(this._onData, {onError: this._onError, onDone: this._onDone, cancelOnError: true});
}
- get current() { return this._current; }
+ get current() {
+ return this._current;
+ }
moveNext() {
if (this._state === _STATE_DONE) {
return new _Future.immediate(false);
@@ -3114,7 +3292,8 @@ var async;
this._state = _STATE_EXTRA_DATA;
}
_onError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
if (this._state === _STATE_MOVING) {
let hasNext = dart.as(this._futureOrPrefetch, _Future$(core.bool));
this._clear();
@@ -3147,13 +3326,11 @@ var async;
return _StreamIteratorImpl;
});
let _StreamIteratorImpl = _StreamIteratorImpl$(dynamic);
-
// Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackTrace) → dynamic) → dynamic
function _runUserCode(userCode, onSuccess, onError) {
try {
onSuccess(userCode());
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
let replacement = Zone.current.errorCallback(e, s);
if (replacement === null) {
@@ -3164,8 +3341,8 @@ var async;
onError(error, stackTrace);
}
}
- }
+ }
// Function _cancelAndError: (StreamSubscription<dynamic>, _Future<dynamic>, dynamic, StackTrace) → void
function _cancelAndError(subscription, future, error, stackTrace) {
let cancelFuture = subscription.cancel();
@@ -3175,7 +3352,6 @@ var async;
future._completeError(error, stackTrace);
}
}
-
// Function _cancelAndErrorWithReplacement: (StreamSubscription<dynamic>, _Future<dynamic>, dynamic, StackTrace) → void
function _cancelAndErrorWithReplacement(subscription, future, error, stackTrace) {
let replacement = Zone.current.errorCallback(error, stackTrace);
@@ -3185,10 +3361,10 @@ var async;
}
_cancelAndError(subscription, future, error, stackTrace);
}
-
// Function _cancelAndErrorClosure: (StreamSubscription<dynamic>, _Future<dynamic>) → dynamic
- function _cancelAndErrorClosure(subscription, future) { return ((error, stackTrace) => _cancelAndError(subscription, future, error, stackTrace)); }
-
+ function _cancelAndErrorClosure(subscription, future) {
+ return (error, stackTrace) => _cancelAndError(subscription, future, error, stackTrace);
+ }
// Function _cancelAndValue: (StreamSubscription<dynamic>, _Future<dynamic>, dynamic) → void
function _cancelAndValue(subscription, future, value) {
let cancelFuture = subscription.cancel();
@@ -3198,18 +3374,19 @@ var async;
future._complete(value);
}
}
-
let _ForwardingStream$ = dart.generic(function(S, T) {
class _ForwardingStream extends Stream$(T) {
_ForwardingStream(_source) {
this._source = _source;
super.Stream();
}
- get isBroadcast() { return this._source.isBroadcast; }
+ get isBroadcast() {
+ return this._source.isBroadcast;
+ }
listen(onData, opt$) {
- let onError = opt$.onError === undefined ? null : opt$.onError;
- let onDone = opt$.onDone === undefined ? null : opt$.onDone;
- let cancelOnError = opt$.cancelOnError === undefined ? null : opt$.cancelOnError;
+ let onError = opt$.onError === void 0 ? null : opt$.onError;
+ let onDone = opt$.onDone === void 0 ? null : opt$.onDone;
+ let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOnError;
cancelOnError = core.identical(true, cancelOnError);
return this._createSubscription(onData, onError, onDone, cancelOnError);
}
@@ -3230,7 +3407,6 @@ var async;
return _ForwardingStream;
});
let _ForwardingStream = _ForwardingStream$(dynamic, dynamic);
-
let _ForwardingStreamSubscription$ = dart.generic(function(S, T) {
class _ForwardingStreamSubscription extends _BufferingStreamSubscription$(T) {
_ForwardingStreamSubscription(_stream, onData, onError, onDone, cancelOnError) {
@@ -3240,19 +3416,23 @@ var async;
this._subscription = this._stream._source.listen(this._handleData, {onError: this._handleError, onDone: this._handleDone});
}
_add(data) {
- if (this._isClosed) return;
+ if (this._isClosed)
+ return;
super._add(data);
}
_addError(error, stackTrace) {
- if (this._isClosed) return;
+ if (this._isClosed)
+ return;
super._addError(error, stackTrace);
}
_onPause() {
- if (this._subscription === null) return;
+ if (this._subscription === null)
+ return;
this._subscription.pause();
}
_onResume() {
- if (this._subscription === null) return;
+ if (this._subscription === null)
+ return;
this._subscription.resume();
}
_onCancel() {
@@ -3276,7 +3456,6 @@ var async;
return _ForwardingStreamSubscription;
});
let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(dynamic, dynamic);
-
// Function _addErrorWithReplacement: (_EventSink<dynamic>, dynamic, dynamic) → void
function _addErrorWithReplacement(sink, error, stackTrace) {
let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core.StackTrace));
@@ -3286,7 +3465,6 @@ var async;
}
sink._addError(error, dart.as(stackTrace, core.StackTrace));
}
-
let _WhereStream$ = dart.generic(function(T) {
class _WhereStream extends _ForwardingStream$(T, T) {
_WhereStream(source, test) {
@@ -3297,12 +3475,12 @@ var async;
let satisfies = null;
try {
satisfies = this._test(inputEvent);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_addErrorWithReplacement(sink, e, s);
return;
}
+
if (satisfies) {
sink._add(inputEvent);
}
@@ -3311,7 +3489,6 @@ var async;
return _WhereStream;
});
let _WhereStream = _WhereStream$(dynamic);
-
let _MapStream$ = dart.generic(function(S, T) {
class _MapStream extends _ForwardingStream$(S, T) {
_MapStream(source, transform) {
@@ -3322,19 +3499,18 @@ var async;
let outputEvent = null;
try {
outputEvent = dart.as(this._transform(inputEvent), T);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_addErrorWithReplacement(sink, e, s);
return;
}
+
sink._add(outputEvent);
}
}
return _MapStream;
});
let _MapStream = _MapStream$(dynamic, dynamic);
-
let _ExpandStream$ = dart.generic(function(S, T) {
class _ExpandStream extends _ForwardingStream$(S, T) {
_ExpandStream(source, expand) {
@@ -3346,17 +3522,16 @@ var async;
for (let value of this._expand(inputEvent)) {
sink._add(value);
}
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_addErrorWithReplacement(sink, e, s);
}
+
}
}
return _ExpandStream;
});
let _ExpandStream = _ExpandStream$(dynamic, dynamic);
-
let _HandleErrorStream$ = dart.generic(function(T) {
class _HandleErrorStream extends _ForwardingStream$(T, T) {
_HandleErrorStream(source, onError, test) {
@@ -3369,18 +3544,17 @@ var async;
if (this._test !== null) {
try {
matches = this._test(error);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_addErrorWithReplacement(sink, e, s);
return;
}
+
}
if (matches) {
try {
_invokeErrorHandler(this._transform, error, stackTrace);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
if (core.identical(e, error)) {
sink._addError(error, stackTrace);
@@ -3389,6 +3563,7 @@ var async;
}
return;
}
+
} else {
sink._addError(error, stackTrace);
}
@@ -3397,13 +3572,13 @@ var async;
return _HandleErrorStream;
});
let _HandleErrorStream = _HandleErrorStream$(dynamic);
-
let _TakeStream$ = dart.generic(function(T) {
class _TakeStream extends _ForwardingStream$(T, T) {
_TakeStream(source, count) {
this._remaining = count;
super._ForwardingStream(source);
- if (!(typeof count == "number")) throw new core.ArgumentError(count);
+ if (!(typeof count == number))
+ throw new core.ArgumentError(count);
}
_handleData(inputEvent, sink) {
if (this._remaining > 0) {
@@ -3418,7 +3593,6 @@ var async;
return _TakeStream;
});
let _TakeStream = _TakeStream$(dynamic);
-
let _TakeWhileStream$ = dart.generic(function(T) {
class _TakeWhileStream extends _ForwardingStream$(T, T) {
_TakeWhileStream(source, test) {
@@ -3429,13 +3603,13 @@ var async;
let satisfies = null;
try {
satisfies = this._test(inputEvent);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_addErrorWithReplacement(sink, e, s);
sink._close();
return;
}
+
if (satisfies) {
sink._add(inputEvent);
} else {
@@ -3446,13 +3620,13 @@ var async;
return _TakeWhileStream;
});
let _TakeWhileStream = _TakeWhileStream$(dynamic);
-
let _SkipStream$ = dart.generic(function(T) {
class _SkipStream extends _ForwardingStream$(T, T) {
_SkipStream(source, count) {
this._remaining = count;
super._ForwardingStream(source);
- if (dart.notNull(!(typeof count == "number")) || dart.notNull(count < 0)) throw new core.ArgumentError(count);
+ if (dart.notNull(!(typeof count == number)) || dart.notNull(count < 0))
+ throw new core.ArgumentError(count);
}
_handleData(inputEvent, sink) {
if (this._remaining > 0) {
@@ -3465,7 +3639,6 @@ var async;
return _SkipStream;
});
let _SkipStream = _SkipStream$(dynamic);
-
let _SkipWhileStream$ = dart.generic(function(T) {
class _SkipWhileStream extends _ForwardingStream$(T, T) {
_SkipWhileStream(source, test) {
@@ -3481,13 +3654,13 @@ var async;
let satisfies = null;
try {
satisfies = this._test(inputEvent);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_addErrorWithReplacement(sink, e, s);
this._hasFailed = true;
return;
}
+
if (!dart.notNull(satisfies)) {
this._hasFailed = true;
sink._add(inputEvent);
@@ -3497,7 +3670,6 @@ var async;
return _SkipWhileStream;
});
let _SkipWhileStream = _SkipWhileStream$(dynamic);
-
let _DistinctStream$ = dart.generic(function(T) {
class _DistinctStream extends _ForwardingStream$(T, T) {
_DistinctStream(source, equals) {
@@ -3513,16 +3685,16 @@ var async;
let isEqual = null;
try {
if (this._equals === null) {
- isEqual = (dart.equals(this._previous, inputEvent));
+ isEqual = dart.equals(this._previous, inputEvent);
} else {
isEqual = this._equals(dart.as(this._previous, T), inputEvent);
}
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
_addErrorWithReplacement(sink, e, s);
return null;
}
+
if (!dart.notNull(isEqual)) {
sink._add(inputEvent);
this._previous = inputEvent;
@@ -3531,13 +3703,14 @@ var async;
}
}
dart.defineLazyProperties(_DistinctStream, {
- get _SENTINEL() { return new core.Object() },
- set _SENTINEL(x) {},
+ get _SENTINEL() {
+ return new core.Object();
+ },
+ set _SENTINEL() {}
});
return _DistinctStream;
});
let _DistinctStream = _DistinctStream$(dynamic);
-
let _EventSinkWrapper$ = dart.generic(function(T) {
class _EventSinkWrapper extends dart.Object {
_EventSinkWrapper(_sink) {
@@ -3547,7 +3720,8 @@ var async;
this._sink._add(data);
}
addError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
this._sink._addError(error, stackTrace);
}
close() {
@@ -3557,7 +3731,6 @@ var async;
return _EventSinkWrapper;
});
let _EventSinkWrapper = _EventSinkWrapper$(dynamic);
-
let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) {
class _SinkTransformerStreamSubscription extends _BufferingStreamSubscription$(T) {
_SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone, cancelOnError) {
@@ -3568,7 +3741,9 @@ var async;
this._transformerSink = mapper(eventSink);
this._subscription = source.listen(this._handleData, {onError: this._handleError, onDone: this._handleDone});
}
- get _isSubscribed() { return this._subscription !== null; }
+ get _isSubscribed() {
+ return this._subscription !== null;
+ }
_add(data) {
if (this._isClosed) {
throw new core.StateError("Stream is already closed");
@@ -3588,10 +3763,12 @@ var async;
super._close();
}
_onPause() {
- if (this._isSubscribed) this._subscription.pause();
+ if (this._isSubscribed)
+ this._subscription.pause();
}
_onResume() {
- if (this._isSubscribed) this._subscription.resume();
+ if (this._isSubscribed)
+ this._subscription.resume();
}
_onCancel() {
if (this._isSubscribed) {
@@ -3604,18 +3781,18 @@ var async;
_handleData(data) {
try {
this._transformerSink.add(data);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
this._addError(e, s);
}
+
}
_handleError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
+ if (stackTrace === void 0)
+ stackTrace = null;
try {
this._transformerSink.addError(error, dart.as(stackTrace, core.StackTrace));
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
if (core.identical(e, error)) {
this._addError(error, dart.as(stackTrace, core.StackTrace));
@@ -3623,45 +3800,48 @@ var async;
this._addError(e, s);
}
}
+
}
_handleDone() {
try {
this._subscription = null;
this._transformerSink.close();
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
this._addError(e, s);
}
+
}
}
return _SinkTransformerStreamSubscription;
});
let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$(dynamic, dynamic);
-
let _StreamSinkTransformer$ = dart.generic(function(S, T) {
class _StreamSinkTransformer extends dart.Object {
_StreamSinkTransformer(_sinkMapper) {
this._sinkMapper = _sinkMapper;
}
- bind(stream) { return new _BoundSinkStream(stream, this._sinkMapper); }
+ bind(stream) {
+ return new _BoundSinkStream(stream, this._sinkMapper);
+ }
}
return _StreamSinkTransformer;
});
let _StreamSinkTransformer = _StreamSinkTransformer$(dynamic, dynamic);
-
let _BoundSinkStream$ = dart.generic(function(S, T) {
class _BoundSinkStream extends Stream$(T) {
- get isBroadcast() { return this._stream.isBroadcast; }
+ get isBroadcast() {
+ return this._stream.isBroadcast;
+ }
_BoundSinkStream(_stream, _sinkMapper) {
this._stream = _stream;
this._sinkMapper = _sinkMapper;
super.Stream();
}
listen(onData, opt$) {
- let onError = opt$.onError === undefined ? null : opt$.onError;
- let onDone = opt$.onDone === undefined ? null : opt$.onDone;
- let cancelOnError = opt$.cancelOnError === undefined ? null : opt$.cancelOnError;
+ let onError = opt$.onError === void 0 ? null : opt$.onError;
+ let onDone = opt$.onDone === void 0 ? null : opt$.onDone;
+ let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOnError;
cancelOnError = core.identical(true, cancelOnError);
let subscription = dart.as(new _SinkTransformerStreamSubscription(this._stream, this._sinkMapper, onData, onError, onDone, cancelOnError), StreamSubscription$(T));
return subscription;
@@ -3670,7 +3850,6 @@ var async;
return _BoundSinkStream;
});
let _BoundSinkStream = _BoundSinkStream$(dynamic, dynamic);
-
let _HandlerEventSink$ = dart.generic(function(S, T) {
class _HandlerEventSink extends dart.Object {
_HandlerEventSink(_handleData, _handleError, _handleDone, _sink) {
@@ -3679,27 +3858,34 @@ var async;
this._handleDone = _handleDone;
this._sink = _sink;
}
- add(data) { return this._handleData(data, this._sink); }
+ add(data) {
+ return this._handleData(data, this._sink);
+ }
addError(error, stackTrace) {
- if (stackTrace === undefined) stackTrace = null;
- return this._handleError(error, stackTrace, this._sink)
+ if (stackTrace === void 0)
+ stackTrace = null;
+ return this._handleError(error, stackTrace, this._sink);
+ }
+ close() {
+ return this._handleDone(this._sink);
}
- close() { return this._handleDone(this._sink); }
}
return _HandlerEventSink;
});
let _HandlerEventSink = _HandlerEventSink$(dynamic, dynamic);
-
let _StreamHandlerTransformer$ = dart.generic(function(S, T) {
class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) {
_StreamHandlerTransformer(opt$) {
- let handleData = opt$.handleData === undefined ? null : opt$.handleData;
- let handleError = opt$.handleError === undefined ? null : opt$.handleError;
- let handleDone = opt$.handleDone === undefined ? null : opt$.handleDone;
+ let handleData = opt$.handleData === void 0 ? null : opt$.handleData;
+ let handleError = opt$.handleError === void 0 ? null : opt$.handleError;
+ let handleDone = opt$.handleDone === void 0 ? null : opt$.handleDone;
super._StreamSinkTransformer(dart.as((outputSink) => {
- if (handleData === null) handleData = _defaultHandleData;
- if (handleError === null) handleError = _defaultHandleError;
- if (handleDone === null) handleDone = _defaultHandleDone;
+ if (handleData === null)
+ handleData = _defaultHandleData;
+ if (handleError === null)
+ handleError = _defaultHandleError;
+ if (handleDone === null)
+ handleDone = _defaultHandleDone;
return new _HandlerEventSink(handleData, handleError, handleDone, outputSink);
}, _SinkMapper));
}
@@ -3719,18 +3905,18 @@ var async;
return _StreamHandlerTransformer;
});
let _StreamHandlerTransformer = _StreamHandlerTransformer$(dynamic, dynamic);
-
let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) {
class _StreamSubscriptionTransformer extends dart.Object {
_StreamSubscriptionTransformer(_transformer) {
this._transformer = _transformer;
}
- bind(stream) { return new _BoundSubscriptionStream(stream, this._transformer); }
+ bind(stream) {
+ return new _BoundSubscriptionStream(stream, this._transformer);
+ }
}
return _StreamSubscriptionTransformer;
});
let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dynamic, dynamic);
-
let _BoundSubscriptionStream$ = dart.generic(function(S, T) {
class _BoundSubscriptionStream extends Stream$(T) {
_BoundSubscriptionStream(_stream, _transformer) {
@@ -3739,9 +3925,9 @@ var async;
super.Stream();
}
listen(onData, opt$) {
- let onError = opt$.onError === undefined ? null : opt$.onError;
- let onDone = opt$.onDone === undefined ? null : opt$.onDone;
- let cancelOnError = opt$.cancelOnError === undefined ? null : opt$.cancelOnError;
+ let onError = opt$.onError === void 0 ? null : opt$.onError;
+ let onDone = opt$.onDone === void 0 ? null : opt$.onDone;
+ let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOnError;
cancelOnError = core.identical(true, cancelOnError);
let result = this._transformer(this._stream, cancelOnError);
result.onData(onData);
@@ -3753,7 +3939,6 @@ var async;
return _BoundSubscriptionStream;
});
let _BoundSubscriptionStream = _BoundSubscriptionStream$(dynamic, dynamic);
-
class Timer extends dart.Object {
Timer(duration, callback) {
if (dart.equals(Zone.current, Zone.ROOT)) {
@@ -3765,77 +3950,77 @@ var async;
if (dart.equals(Zone.current, Zone.ROOT)) {
return Zone.current.createPeriodicTimer(duration, callback);
}
- return Zone.current.createPeriodicTimer(duration, Zone.current.bindUnaryCallback(dart.as(callback, /* Unimplemented type (dynamic) → dynamic */), {runGuarded: true}));
+ return Zone.current.createPeriodicTimer(duration, Zone.current.bindUnaryCallback(dart.as(callback, dart.throw_("Unimplemented type (dynamic) → dynamic")), {runGuarded: true}));
}
static run(callback) {
new Timer(core.Duration.ZERO, callback);
}
static _createTimer(duration, callback) {
let milliseconds = duration.inMilliseconds;
- if (milliseconds < 0) milliseconds = 0;
+ if (milliseconds < 0)
+ milliseconds = 0;
return dart.as(new TimerImpl(milliseconds, callback), Timer);
}
static _createPeriodicTimer(duration, callback) {
let milliseconds = duration.inMilliseconds;
- if (milliseconds < 0) milliseconds = 0;
- return dart.as(new dart.dload(/* Unimplemented unknown name */TimerImpl, "periodic")(milliseconds, callback), Timer);
+ if (milliseconds < 0)
+ milliseconds = 0;
+ return dart.as(new dart.dload(/* Unimplemented unknown name */TimerImpl, 'periodic')(milliseconds, callback), Timer);
}
}
- dart.defineNamedConstructor(Timer, "periodic");
-
+ dart.defineNamedConstructor(Timer, 'periodic');
class AsyncError extends dart.Object {
AsyncError(error, stackTrace) {
this.error = error;
this.stackTrace = stackTrace;
}
- toString() { return dart.as(dart.dinvoke(this.error, "toString"), core.String); }
+ toString() {
+ return dart.as(dart.dinvoke(this.error, 'toString'), core.String);
+ }
}
-
class _ZoneFunction extends dart.Object {
_ZoneFunction(zone, function) {
this.zone = zone;
- this.function = function;
+ this["function"] = function;
}
}
-
class ZoneSpecification extends dart.Object {
ZoneSpecification(opt$) {
return new _ZoneSpecification(opt$);
}
ZoneSpecification$from(other, opt$) {
- let handleUncaughtError = opt$.handleUncaughtError === undefined ? null : opt$.handleUncaughtError;
- let run = opt$.run === undefined ? null : opt$.run;
- let runUnary = opt$.runUnary === undefined ? null : opt$.runUnary;
- let runBinary = opt$.runBinary === undefined ? null : opt$.runBinary;
- let registerCallback = opt$.registerCallback === undefined ? null : opt$.registerCallback;
- let registerUnaryCallback = opt$.registerUnaryCallback === undefined ? null : opt$.registerUnaryCallback;
- let registerBinaryCallback = opt$.registerBinaryCallback === undefined ? null : opt$.registerBinaryCallback;
- let errorCallback = opt$.errorCallback === undefined ? null : opt$.errorCallback;
- let scheduleMicrotask = opt$.scheduleMicrotask === undefined ? null : opt$.scheduleMicrotask;
- let createTimer = opt$.createTimer === undefined ? null : opt$.createTimer;
- let createPeriodicTimer = opt$.createPeriodicTimer === undefined ? null : opt$.createPeriodicTimer;
- let print = opt$.print === undefined ? null : opt$.print;
- let fork = opt$.fork === undefined ? null : opt$.fork;
+ let handleUncaughtError = opt$.handleUncaughtError === void 0 ? null : opt$.handleUncaughtError;
+ let run = opt$.run === void 0 ? null : opt$.run;
+ let runUnary = opt$.runUnary === void 0 ? null : opt$.runUnary;
+ let runBinary = opt$.runBinary === void 0 ? null : opt$.runBinary;
+ let registerCallback = opt$.registerCallback === void 0 ? null : opt$.registerCallback;
+ let registerUnaryCallback = opt$.registerUnaryCallback === void 0 ? null : opt$.registerUnaryCallback;
+ let registerBinaryCallback = opt$.registerBinaryCallback === void 0 ? null : opt$.registerBinaryCallback;
+ let errorCallback = opt$.errorCallback === void 0 ? null : opt$.errorCallback;
+ let scheduleMicrotask = opt$.scheduleMicrotask === void 0 ? null : opt$.scheduleMicrotask;
+ let createTimer = opt$.createTimer === void 0 ? null : opt$.createTimer;
+ let createPeriodicTimer = opt$.createPeriodicTimer === void 0 ? null : opt$.createPeriodicTimer;
+ let print = opt$.print === void 0 ? null : opt$.print;
+ let fork = opt$.fork === void 0 ? null : opt$.fork;
return new ZoneSpecification({handleUncaughtError: handleUncaughtError !== null ? handleUncaughtError : other.handleUncaughtError, run: run !== null ? run : other.run, runUnary: runUnary !== null ? runUnary : other.runUnary, runBinary: runBinary !== null ? runBinary : other.runBinary, registerCallback: registerCallback !== null ? registerCallback : other.registerCallback, registerUnaryCallback: registerUnaryCallback !== null ? registerUnaryCallback : other.registerUnaryCallback, registerBinaryCallback: registerBinaryCallback !== null ? registerBinaryCallback : other.registerBinaryCallback, errorCallback: errorCallback !== null ? errorCallback : other.errorCallback, scheduleMicrotask: scheduleMicrotask !== null ? scheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer !== null ? createTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer !== null ? createPeriodicTimer : other.createPeriodicTimer, print: print !== null ? print : other.print, fork: fork !== null ? fork : other.fork});
}
}
- dart.defineNamedConstructor(ZoneSpecification, "from");
-
+ dart.defineNamedConstructor(ZoneSpecification, 'from');
class _ZoneSpecification extends dart.Object {
_ZoneSpecification(opt$) {
- let handleUncaughtError = opt$.handleUncaughtError === undefined ? null : opt$.handleUncaughtError;
- let run = opt$.run === undefined ? null : opt$.run;
- let runUnary = opt$.runUnary === undefined ? null : opt$.runUnary;
- let runBinary = opt$.runBinary === undefined ? null : opt$.runBinary;
- let registerCallback = opt$.registerCallback === undefined ? null : opt$.registerCallback;
- let registerUnaryCallback = opt$.registerUnaryCallback === undefined ? null : opt$.registerUnaryCallback;
- let registerBinaryCallback = opt$.registerBinaryCallback === undefined ? null : opt$.registerBinaryCallback;
- let errorCallback = opt$.errorCallback === undefined ? null : opt$.errorCallback;
- let scheduleMicrotask = opt$.scheduleMicrotask === undefined ? null : opt$.scheduleMicrotask;
- let createTimer = opt$.createTimer === undefined ? null : opt$.createTimer;
- let createPeriodicTimer = opt$.createPeriodicTimer === undefined ? null : opt$.createPeriodicTimer;
- let print = opt$.print === undefined ? null : opt$.print;
- let fork = opt$.fork === undefined ? null : opt$.fork;
+ let handleUncaughtError = opt$.handleUncaughtError === void 0 ? null : opt$.handleUncaughtError;
+ let run = opt$.run === void 0 ? null : opt$.run;
+ let runUnary = opt$.runUnary === void 0 ? null : opt$.runUnary;
+ let runBinary = opt$.runBinary === void 0 ? null : opt$.runBinary;
+ let registerCallback = opt$.registerCallback === void 0 ? null : opt$.registerCallback;
+ let registerUnaryCallback = opt$.registerUnaryCallback === void 0 ? null : opt$.registerUnaryCallback;
+ let registerBinaryCallback = opt$.registerBinaryCallback === void 0 ? null : opt$.registerBinaryCallback;
+ let errorCallback = opt$.errorCallback === void 0 ? null : opt$.errorCallback;
+ let scheduleMicrotask = opt$.scheduleMicrotask === void 0 ? null : opt$.scheduleMicrotask;
+ let createTimer = opt$.createTimer === void 0 ? null : opt$.createTimer;
+ let createPeriodicTimer = opt$.createPeriodicTimer === void 0 ? null : opt$.createPeriodicTimer;
+ let print = opt$.print === void 0 ? null : opt$.print;
+ let fork = opt$.fork === void 0 ? null : opt$.fork;
this.handleUncaughtError = handleUncaughtError;
this.run = run;
this.runUnary = runUnary;
@@ -3851,14 +4036,14 @@ var async;
this.fork = fork;
}
}
-
class ZoneDelegate extends dart.Object {
}
-
class Zone extends dart.Object {
Zone$_() {
}
- static get current() { return _current; }
+ static get current() {
+ return _current;
+ }
static _enter(zone) {
dart.assert(zone !== null);
dart.assert(!dart.notNull(core.identical(zone, _current)));
@@ -3871,16 +4056,15 @@ var async;
Zone._current = previous;
}
}
- dart.defineNamedConstructor(Zone, "_");
+ dart.defineNamedConstructor(Zone, '_');
Zone.ROOT = dart.as(_ROOT_ZONE, Zone);
Zone._current = dart.as(_ROOT_ZONE, Zone);
-
// Function _parentDelegate: (_Zone) → ZoneDelegate
function _parentDelegate(zone) {
- if (zone.parent === null) return null;
+ if (zone.parent === null)
+ return null;
return zone.parent._delegate;
}
-
class _ZoneDelegate extends dart.Object {
_ZoneDelegate(_delegationTarget) {
this._delegationTarget = _delegationTarget;
@@ -3888,71 +4072,71 @@ var async;
handleUncaughtError(zone, error, stackTrace) {
let implementation = this._delegationTarget._handleUncaughtError;
let implZone = implementation.zone;
- return dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, error, stackTrace);
+ return dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, error, stackTrace);
}
run(zone, f) {
let implementation = this._delegationTarget._run;
let implZone = implementation.zone;
- return dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, f);
+ return dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, f);
}
runUnary(zone, f, arg) {
let implementation = this._delegationTarget._runUnary;
let implZone = implementation.zone;
- return dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, f, arg);
+ return dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, f, arg);
}
runBinary(zone, f, arg1, arg2) {
let implementation = this._delegationTarget._runBinary;
let implZone = implementation.zone;
- return dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, f, arg1, arg2);
+ return dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, f, arg1, arg2);
}
registerCallback(zone, f) {
let implementation = this._delegationTarget._registerCallback;
let implZone = implementation.zone;
- return dart.as(dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, f), ZoneCallback);
+ return dart.as(dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, f), ZoneCallback);
}
registerUnaryCallback(zone, f) {
let implementation = this._delegationTarget._registerUnaryCallback;
let implZone = implementation.zone;
- return dart.as(dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, f), ZoneUnaryCallback);
+ return dart.as(dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, f), ZoneUnaryCallback);
}
registerBinaryCallback(zone, f) {
let implementation = this._delegationTarget._registerBinaryCallback;
let implZone = implementation.zone;
- return dart.as(dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, f), ZoneBinaryCallback);
+ return dart.as(dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, f), ZoneBinaryCallback);
}
errorCallback(zone, error, stackTrace) {
let implementation = this._delegationTarget._errorCallback;
let implZone = implementation.zone;
- if (core.identical(implZone, _ROOT_ZONE)) return null;
- return dart.as(dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, error, stackTrace), AsyncError);
+ if (core.identical(implZone, _ROOT_ZONE))
+ return null;
+ return dart.as(dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, error, stackTrace), AsyncError);
}
scheduleMicrotask(zone, f) {
let implementation = this._delegationTarget._scheduleMicrotask;
let implZone = implementation.zone;
- dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, f);
+ dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, f);
}
createTimer(zone, duration, f) {
let implementation = this._delegationTarget._createTimer;
let implZone = implementation.zone;
- return dart.as(dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, duration, f), Timer);
+ return dart.as(dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, duration, f), Timer);
}
createPeriodicTimer(zone, period, f) {
let implementation = this._delegationTarget._createPeriodicTimer;
let implZone = implementation.zone;
- return dart.as(dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, period, f), Timer);
+ return dart.as(dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, period, f), Timer);
}
print(zone, line) {
let implementation = this._delegationTarget._print;
let implZone = implementation.zone;
- dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, line);
+ dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, line);
}
fork(zone, specification, zoneValues) {
let implementation = this._delegationTarget._fork;
let implZone = implementation.zone;
- return dart.as(dart.dinvokef((implementation.function), implZone, _parentDelegate(implZone), zone, specification, zoneValues), Zone);
+ return dart.as(dart.dinvokef(implementation["function"], implZone, _parentDelegate(implZone), zone, specification, zoneValues), Zone);
}
}
-
class _Zone extends dart.Object {
_Zone() {
}
@@ -3960,10 +4144,10 @@ var async;
return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core.identical(this.errorZone, otherZone.errorZone));
}
}
-
class _CustomZone extends _Zone {
get _delegate() {
- if (this._delegateCache !== null) return this._delegateCache;
+ if (this._delegateCache !== null)
+ return this._delegateCache;
this._delegateCache = new _ZoneDelegate(this);
return this._delegateCache;
}
@@ -3985,50 +4169,52 @@ var async;
this._handleUncaughtError = null;
this._delegateCache = null;
super._Zone();
- this._run = (specification.run !== null) ? new _ZoneFunction(this, specification.run) : this.parent._run;
- this._runUnary = (specification.runUnary !== null) ? new _ZoneFunction(this, specification.runUnary) : this.parent._runUnary;
- this._runBinary = (specification.runBinary !== null) ? new _ZoneFunction(this, specification.runBinary) : this.parent._runBinary;
- this._registerCallback = (specification.registerCallback !== null) ? new _ZoneFunction(this, specification.registerCallback) : this.parent._registerCallback;
- this._registerUnaryCallback = (specification.registerUnaryCallback !== null) ? new _ZoneFunction(this, specification.registerUnaryCallback) : this.parent._registerUnaryCallback;
- this._registerBinaryCallback = (specification.registerBinaryCallback !== null) ? new _ZoneFunction(this, specification.registerBinaryCallback) : this.parent._registerBinaryCallback;
- this._errorCallback = (specification.errorCallback !== null) ? new _ZoneFunction(this, specification.errorCallback) : this.parent._errorCallback;
- this._scheduleMicrotask = (specification.scheduleMicrotask !== null) ? new _ZoneFunction(this, specification.scheduleMicrotask) : this.parent._scheduleMicrotask;
- this._createTimer = (specification.createTimer !== null) ? new _ZoneFunction(this, specification.createTimer) : this.parent._createTimer;
- this._createPeriodicTimer = (specification.createPeriodicTimer !== null) ? new _ZoneFunction(this, specification.createPeriodicTimer) : this.parent._createPeriodicTimer;
- this._print = (specification.print !== null) ? new _ZoneFunction(this, specification.print) : this.parent._print;
- this._fork = (specification.fork !== null) ? new _ZoneFunction(this, specification.fork) : this.parent._fork;
- this._handleUncaughtError = (specification.handleUncaughtError !== null) ? new _ZoneFunction(this, specification.handleUncaughtError) : this.parent._handleUncaughtError;
- }
- get errorZone() { return this._handleUncaughtError.zone; }
+ this._run = specification.run !== null ? new _ZoneFunction(this, specification.run) : this.parent._run;
+ this._runUnary = specification.runUnary !== null ? new _ZoneFunction(this, specification.runUnary) : this.parent._runUnary;
+ this._runBinary = specification.runBinary !== null ? new _ZoneFunction(this, specification.runBinary) : this.parent._runBinary;
+ this._registerCallback = specification.registerCallback !== null ? new _ZoneFunction(this, specification.registerCallback) : this.parent._registerCallback;
+ this._registerUnaryCallback = specification.registerUnaryCallback !== null ? new _ZoneFunction(this, specification.registerUnaryCallback) : this.parent._registerUnaryCallback;
+ this._registerBinaryCallback = specification.registerBinaryCallback !== null ? new _ZoneFunction(this, specification.registerBinaryCallback) : this.parent._registerBinaryCallback;
+ this._errorCallback = specification.errorCallback !== null ? new _ZoneFunction(this, specification.errorCallback) : this.parent._errorCallback;
+ this._scheduleMicrotask = specification.scheduleMicrotask !== null ? new _ZoneFunction(this, specification.scheduleMicrotask) : this.parent._scheduleMicrotask;
+ this._createTimer = specification.createTimer !== null ? new _ZoneFunction(this, specification.createTimer) : this.parent._createTimer;
+ this._createPeriodicTimer = specification.createPeriodicTimer !== null ? new _ZoneFunction(this, specification.createPeriodicTimer) : this.parent._createPeriodicTimer;
+ this._print = specification.print !== null ? new _ZoneFunction(this, specification.print) : this.parent._print;
+ this._fork = specification.fork !== null ? new _ZoneFunction(this, specification.fork) : this.parent._fork;
+ this._handleUncaughtError = specification.handleUncaughtError !== null ? new _ZoneFunction(this, specification.handleUncaughtError) : this.parent._handleUncaughtError;
+ }
+ get errorZone() {
+ return this._handleUncaughtError.zone;
+ }
runGuarded(f) {
try {
return this.run(f);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
return this.handleUncaughtError(e, s);
}
+
}
runUnaryGuarded(f, arg) {
try {
return this.runUnary(f, arg);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
return this.handleUncaughtError(e, s);
}
+
}
runBinaryGuarded(f, arg1, arg2) {
try {
return this.runBinary(f, arg1, arg2);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
return this.handleUncaughtError(e, s);
}
+
}
bindCallback(f, opt$) {
- let runGuarded = opt$.runGuarded === undefined ? true : opt$.runGuarded;
+ let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded;
let registered = this.registerCallback(f);
if (runGuarded) {
return (() => this.runGuarded(registered)).bind(this);
@@ -4037,7 +4223,7 @@ var async;
}
}
bindUnaryCallback(f, opt$) {
- let runGuarded = opt$.runGuarded === undefined ? true : opt$.runGuarded;
+ let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded;
let registered = this.registerUnaryCallback(f);
if (runGuarded) {
return ((arg) => this.runUnaryGuarded(registered, arg)).bind(this);
@@ -4046,7 +4232,7 @@ var async;
}
}
bindBinaryCallback(f, opt$) {
- let runGuarded = opt$.runGuarded === undefined ? true : opt$.runGuarded;
+ let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded;
let registered = this.registerBinaryCallback(f);
if (runGuarded) {
return ((arg1, arg2) => this.runBinaryGuarded(registered, arg1, arg2)).bind(this);
@@ -4056,7 +4242,8 @@ var async;
}
get(key) {
let result = this._map.get(key);
- if (dart.notNull(result !== null) || dart.notNull(this._map.containsKey(key))) return result;
+ if (dart.notNull(result !== null) || dart.notNull(this._map.containsKey(key)))
+ return result;
if (this.parent !== null) {
let value = this.parent.get(key);
if (value !== null) {
@@ -4071,156 +4258,149 @@ var async;
let implementation = this._handleUncaughtError;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, error, stackTrace);
+ return dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, error, stackTrace);
}
fork(opt$) {
- let specification = opt$.specification === undefined ? null : opt$.specification;
- let zoneValues = opt$.zoneValues === undefined ? null : opt$.zoneValues;
+ let specification = opt$.specification === void 0 ? null : opt$.specification;
+ let zoneValues = opt$.zoneValues === void 0 ? null : opt$.zoneValues;
let implementation = this._fork;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.as(dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, specification, zoneValues), Zone);
+ return dart.as(dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, specification, zoneValues), Zone);
}
run(f) {
let implementation = this._run;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, f);
+ return dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, f);
}
runUnary(f, arg) {
let implementation = this._runUnary;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, f, arg);
+ return dart.dinvokef(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);
- return dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, f, arg1, arg2);
+ return dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, f, arg1, arg2);
}
registerCallback(f) {
let implementation = this._registerCallback;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.as(dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, f), ZoneCallback);
+ return dart.as(dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, f), ZoneCallback);
}
registerUnaryCallback(f) {
let implementation = this._registerUnaryCallback;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.as(dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, f), ZoneUnaryCallback);
+ return dart.as(dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, f), ZoneUnaryCallback);
}
registerBinaryCallback(f) {
let implementation = this._registerBinaryCallback;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.as(dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, f), ZoneBinaryCallback);
+ return dart.as(dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, f), ZoneBinaryCallback);
}
errorCallback(error, stackTrace) {
let implementation = this._errorCallback;
dart.assert(implementation !== null);
let implementationZone = implementation.zone;
- if (core.identical(implementationZone, _ROOT_ZONE)) return null;
+ if (core.identical(implementationZone, _ROOT_ZONE))
+ return null;
let parentDelegate = _parentDelegate(dart.as(implementationZone, _Zone));
- return dart.as(dart.dinvokef((implementation.function), implementationZone, parentDelegate, this, error, stackTrace), AsyncError);
+ return dart.as(dart.dinvokef(implementation["function"], implementationZone, parentDelegate, this, error, stackTrace), AsyncError);
}
scheduleMicrotask(f) {
let implementation = this._scheduleMicrotask;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, f);
+ return dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, f);
}
createTimer(duration, f) {
let implementation = this._createTimer;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.as(dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, duration, f), Timer);
+ return dart.as(dart.dinvokef(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);
- return dart.as(dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, duration, f), Timer);
+ return dart.as(dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, duration, f), Timer);
}
print(line) {
let implementation = this._print;
dart.assert(implementation !== null);
let parentDelegate = _parentDelegate(implementation.zone);
- return dart.dinvokef((implementation.function), implementation.zone, parentDelegate, this, line);
+ return dart.dinvokef(implementation["function"], implementation.zone, parentDelegate, this, line);
}
}
-
// Function _rootHandleUncaughtError: (Zone, ZoneDelegate, Zone, dynamic, StackTrace) → void
function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) {
_schedulePriorityAsyncCallback(() => {
throw new _UncaughtAsyncError(error, stackTrace);
});
}
-
// Function _rootRun: (Zone, ZoneDelegate, Zone, () → dynamic) → dynamic
function _rootRun(self, parent, zone, f) {
- if (dart.equals(Zone._current, zone)) return f();
+ if (dart.equals(Zone._current, zone))
+ return f();
let old = Zone._enter(zone);
try {
return f();
- }
- finally {
+ } finally {
Zone._leave(old);
}
}
-
// Function _rootRunUnary: (Zone, ZoneDelegate, Zone, (dynamic) → dynamic, dynamic) → dynamic
function _rootRunUnary(self, parent, zone, f, arg) {
- if (dart.equals(Zone._current, zone)) return f(arg);
+ if (dart.equals(Zone._current, zone))
+ return f(arg);
let old = Zone._enter(zone);
try {
return f(arg);
- }
- finally {
+ } finally {
Zone._leave(old);
}
}
-
// Function _rootRunBinary: (Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic, dynamic, dynamic) → dynamic
function _rootRunBinary(self, parent, zone, f, arg1, arg2) {
- if (dart.equals(Zone._current, zone)) return f(arg1, arg2);
+ if (dart.equals(Zone._current, zone))
+ return f(arg1, arg2);
let old = Zone._enter(zone);
try {
return f(arg1, arg2);
- }
- finally {
+ } finally {
Zone._leave(old);
}
}
-
// Function _rootRegisterCallback: (Zone, ZoneDelegate, Zone, () → dynamic) → ZoneCallback
function _rootRegisterCallback(self, parent, zone, f) {
return f;
}
-
// Function _rootRegisterUnaryCallback: (Zone, ZoneDelegate, Zone, (dynamic) → dynamic) → ZoneUnaryCallback
function _rootRegisterUnaryCallback(self, parent, zone, f) {
return f;
}
-
// Function _rootRegisterBinaryCallback: (Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic) → ZoneBinaryCallback
function _rootRegisterBinaryCallback(self, parent, zone, f) {
return f;
}
-
// Function _rootErrorCallback: (Zone, ZoneDelegate, Zone, Object, StackTrace) → AsyncError
- function _rootErrorCallback(self, parent, zone, error, stackTrace) { return null; }
-
+ function _rootErrorCallback(self, parent, zone, error, stackTrace) {
+ return null;
+ }
// Function _rootScheduleMicrotask: (Zone, ZoneDelegate, Zone, () → dynamic) → void
function _rootScheduleMicrotask(self, parent, zone, f) {
if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) {
- let hasErrorHandler = /* Unimplemented postfix operator: !_ROOT_ZONE.inSameErrorZone(zone) */;
+ let hasErrorHandler = dart.throw_("Unimplemented PrefixExpression: !_ROOT_ZONE.inSameErrorZone(zone)");
f = zone.bindCallback(f, {runGuarded: hasErrorHandler});
}
_scheduleAsyncCallback(f);
}
-
// Function _rootCreateTimer: (Zone, ZoneDelegate, Zone, Duration, () → void) → Timer
function _rootCreateTimer(self, parent, zone, duration, callback) {
if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) {
@@ -4228,33 +4408,28 @@ var async;
}
return Timer._createTimer(duration, callback);
}
-
// Function _rootCreatePeriodicTimer: (Zone, ZoneDelegate, Zone, Duration, (Timer) → void) → Timer
function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) {
if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) {
- callback = zone.bindUnaryCallback(dart.as(callback, /* Unimplemented type (dynamic) → dynamic */));
+ callback = zone.bindUnaryCallback(dart.as(callback, dart.throw_("Unimplemented type (dynamic) → dynamic")));
}
return Timer._createPeriodicTimer(duration, callback);
}
-
// Function _rootPrint: (Zone, ZoneDelegate, Zone, String) → void
function _rootPrint(self, parent, zone, line) {
_internal.printToConsole(line);
}
-
// Function _printToZone: (String) → void
function _printToZone(line) {
Zone.current.print(line);
}
-
// Function _rootFork: (Zone, ZoneDelegate, Zone, ZoneSpecification, Map<dynamic, dynamic>) → Zone
function _rootFork(self, parent, zone, specification, zoneValues) {
_internal.printToZone = _printToZone;
if (specification === null) {
specification = new ZoneSpecification();
} else if (!dart.is(specification, _ZoneSpecification)) {
- throw new core.ArgumentError("ZoneSpecifications must be instantiated" +
- " with the provided constructor.");
+ throw new core.ArgumentError("ZoneSpecifications must be instantiated" + " with the provided constructor.");
}
let valueMap = null;
if (zoneValues === null) {
@@ -4268,58 +4443,115 @@ var async;
}
return new _CustomZone(zone, specification, valueMap);
}
-
class _RootZoneSpecification extends dart.Object {
- get handleUncaughtError() { return _rootHandleUncaughtError; }
- get run() { return _rootRun; }
- get runUnary() { return _rootRunUnary; }
- get runBinary() { return _rootRunBinary; }
- get registerCallback() { return _rootRegisterCallback; }
- get registerUnaryCallback() { return _rootRegisterUnaryCallback; }
- get registerBinaryCallback() { return _rootRegisterBinaryCallback; }
- get errorCallback() { return _rootErrorCallback; }
- get scheduleMicrotask() { return _rootScheduleMicrotask; }
- get createTimer() { return _rootCreateTimer; }
- get createPeriodicTimer() { return _rootCreatePeriodicTimer; }
- get print() { return _rootPrint; }
- get fork() { return _rootFork; }
+ get handleUncaughtError() {
+ return _rootHandleUncaughtError;
+ }
+ get run() {
+ return _rootRun;
+ }
+ get runUnary() {
+ return _rootRunUnary;
+ }
+ get runBinary() {
+ return _rootRunBinary;
+ }
+ get registerCallback() {
+ return _rootRegisterCallback;
+ }
+ get registerUnaryCallback() {
+ return _rootRegisterUnaryCallback;
+ }
+ get registerBinaryCallback() {
+ return _rootRegisterBinaryCallback;
+ }
+ get errorCallback() {
+ return _rootErrorCallback;
+ }
+ get scheduleMicrotask() {
+ return _rootScheduleMicrotask;
+ }
+ get createTimer() {
+ return _rootCreateTimer;
+ }
+ get createPeriodicTimer() {
+ return _rootCreatePeriodicTimer;
+ }
+ get print() {
+ return _rootPrint;
+ }
+ get fork() {
+ return _rootFork;
+ }
}
-
class _RootZone extends _Zone {
_RootZone() {
super._Zone();
}
- get _run() { return new _ZoneFunction(_ROOT_ZONE, _rootRun); }
- get _runUnary() { return new _ZoneFunction(_ROOT_ZONE, _rootRunUnary); }
- get _runBinary() { return new _ZoneFunction(_ROOT_ZONE, _rootRunBinary); }
- get _registerCallback() { return new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback); }
- get _registerUnaryCallback() { return new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback); }
- get _registerBinaryCallback() { return new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallback); }
- get _errorCallback() { return new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback); }
- get _scheduleMicrotask() { return new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask); }
- get _createTimer() { return new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer); }
- get _createPeriodicTimer() { return new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer); }
- get _print() { return new _ZoneFunction(_ROOT_ZONE, _rootPrint); }
- get _fork() { return new _ZoneFunction(_ROOT_ZONE, _rootFork); }
- get _handleUncaughtError() { return new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError); }
- get parent() { return null; }
- get _map() { return _rootMap; }
+ get _run() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootRun);
+ }
+ get _runUnary() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootRunUnary);
+ }
+ get _runBinary() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootRunBinary);
+ }
+ get _registerCallback() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootRegisterCallback);
+ }
+ get _registerUnaryCallback() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootRegisterUnaryCallback);
+ }
+ get _registerBinaryCallback() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootRegisterBinaryCallback);
+ }
+ get _errorCallback() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootErrorCallback);
+ }
+ get _scheduleMicrotask() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootScheduleMicrotask);
+ }
+ get _createTimer() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootCreateTimer);
+ }
+ get _createPeriodicTimer() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootCreatePeriodicTimer);
+ }
+ get _print() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootPrint);
+ }
+ get _fork() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootFork);
+ }
+ get _handleUncaughtError() {
+ return new _ZoneFunction(_ROOT_ZONE, _rootHandleUncaughtError);
+ }
+ get parent() {
+ return null;
+ }
+ get _map() {
+ return _rootMap;
+ }
get _delegate() {
- if (_rootDelegate !== null) return _rootDelegate;
+ if (_rootDelegate !== null)
+ return _rootDelegate;
return _rootDelegate = new _ZoneDelegate(this);
}
- get errorZone() { return this; }
+ get errorZone() {
+ return this;
+ }
runGuarded(f) {
try {
if (core.identical(_ROOT_ZONE, Zone._current)) {
return f();
}
return _rootRun(null, null, this, f);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
return this.handleUncaughtError(e, s);
}
+
}
runUnaryGuarded(f, arg) {
try {
@@ -4327,11 +4559,11 @@ var async;
return f(arg);
}
return _rootRunUnary(null, null, this, f, arg);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
return this.handleUncaughtError(e, s);
}
+
}
runBinaryGuarded(f, arg1, arg2) {
try {
@@ -4339,14 +4571,14 @@ var async;
return f(arg1, arg2);
}
return _rootRunBinary(null, null, this, f, arg1, arg2);
- }
- catch (e) {
+ } catch (e) {
let s = dart.stackTrace(e);
return this.handleUncaughtError(e, s);
}
+
}
bindCallback(f, opt$) {
- let runGuarded = opt$.runGuarded === undefined ? true : opt$.runGuarded;
+ let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded;
if (runGuarded) {
return (() => this.runGuarded(f)).bind(this);
} else {
@@ -4354,7 +4586,7 @@ var async;
}
}
bindUnaryCallback(f, opt$) {
- let runGuarded = opt$.runGuarded === undefined ? true : opt$.runGuarded;
+ let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded;
if (runGuarded) {
return ((arg) => this.runUnaryGuarded(f, arg)).bind(this);
} else {
@@ -4362,38 +4594,51 @@ var async;
}
}
bindBinaryCallback(f, opt$) {
- let runGuarded = opt$.runGuarded === undefined ? true : opt$.runGuarded;
+ let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded;
if (runGuarded) {
return ((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bind(this);
} else {
return ((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this);
}
}
- get(key) { return null; }
+ get(key) {
+ return null;
+ }
handleUncaughtError(error, stackTrace) {
return _rootHandleUncaughtError(null, null, this, error, stackTrace);
}
fork(opt$) {
- let specification = opt$.specification === undefined ? null : opt$.specification;
- let zoneValues = opt$.zoneValues === undefined ? null : opt$.zoneValues;
+ let specification = opt$.specification === void 0 ? null : opt$.specification;
+ let zoneValues = opt$.zoneValues === void 0 ? null : opt$.zoneValues;
return _rootFork(null, null, this, specification, zoneValues);
}
run(f) {
- if (core.identical(Zone._current, _ROOT_ZONE)) return f();
+ if (core.identical(Zone._current, _ROOT_ZONE))
+ return f();
return _rootRun(null, null, this, f);
}
runUnary(f, arg) {
- if (core.identical(Zone._current, _ROOT_ZONE)) return f(arg);
+ if (core.identical(Zone._current, _ROOT_ZONE))
+ return f(arg);
return _rootRunUnary(null, null, this, f, arg);
}
runBinary(f, arg1, arg2) {
- if (core.identical(Zone._current, _ROOT_ZONE)) return f(arg1, arg2);
+ if (core.identical(Zone._current, _ROOT_ZONE))
+ return f(arg1, arg2);
return _rootRunBinary(null, null, this, f, arg1, arg2);
}
- registerCallback(f) { return f; }
- registerUnaryCallback(f) { return f; }
- registerBinaryCallback(f) { return f; }
- errorCallback(error, stackTrace) { return null; }
+ registerCallback(f) {
+ return f;
+ }
+ registerUnaryCallback(f) {
+ return f;
+ }
+ registerBinaryCallback(f) {
+ return f;
+ }
+ errorCallback(error, stackTrace) {
+ return null;
+ }
scheduleMicrotask(f) {
_rootScheduleMicrotask(null, null, this, f);
}
@@ -4409,16 +4654,17 @@ var async;
}
_RootZone._rootDelegate = null;
dart.defineLazyProperties(_RootZone, {
- get _rootMap() { return new collection.HashMap() },
- set _rootMap(x) {},
+ get _rootMap() {
+ return new collection.HashMap();
+ },
+ set _rootMap() {}
});
-
let _ROOT_ZONE = new _RootZone();
// Function runZoned: (() → dynamic, {zoneValues: Map<dynamic, dynamic>, zoneSpecification: ZoneSpecification, onError: Function}) → dynamic
function runZoned(body, opt$) {
- let zoneValues = opt$.zoneValues === undefined ? null : opt$.zoneValues;
- let zoneSpecification = opt$.zoneSpecification === undefined ? null : opt$.zoneSpecification;
- let onError = opt$.onError === undefined ? null : opt$.onError;
+ let zoneValues = opt$.zoneValues === void 0 ? null : opt$.zoneValues;
+ let zoneSpecification = opt$.zoneSpecification === void 0 ? null : opt$.zoneSpecification;
+ let onError = opt$.onError === void 0 ? null : opt$.onError;
let errorHandler = null;
if (onError !== null) {
errorHandler = (self, parent, zone, error, stackTrace) => {
@@ -4426,9 +4672,8 @@ var async;
if (dart.is(onError, ZoneBinaryCallback)) {
return self.parent.runBinary(onError, error, stackTrace);
}
- return self.parent.runUnary(dart.as(onError, /* Unimplemented type (dynamic) → dynamic */), error);
- }
- catch (e) {
+ return self.parent.runUnary(dart.as(onError, dart.throw_("Unimplemented type (dynamic) → dynamic")), error);
+ } catch (e) {
let s = dart.stackTrace(e);
if (core.identical(e, error)) {
return parent.handleUncaughtError(zone, error, stackTrace);
@@ -4436,6 +4681,7 @@ var async;
return parent.handleUncaughtError(zone, e, s);
}
}
+
};
}
if (zoneSpecification === null) {
@@ -4450,7 +4696,6 @@ var async;
return zone.run(body);
}
}
-
// Exports:
async.DeferredLibrary = DeferredLibrary;
async.DeferredLoadException = DeferredLoadException;
« no previous file with comments | « test/codegen/expect/_internal/_internal.js ('k') | test/codegen/expect/cascade/cascade.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698