| Index: lib/runtime/dart/async.js
|
| diff --git a/lib/runtime/dart/async.js b/lib/runtime/dart/async.js
|
| index d4d95b1749afaed4105dd40500bc56f26e4fa922..2c1e2bdb32a9497bd64deea4b17736928a6da52e 100644
|
| --- a/lib/runtime/dart/async.js
|
| +++ b/lib/runtime/dart/async.js
|
| @@ -156,7 +156,7 @@ var async;
|
| // Function onListen: () → void
|
| function onListen() {
|
| let add = controller.add;
|
| - dart.assert(dart.notNull(dart.is(controller, _StreamController)) || dart.notNull(dart.is(controller, _BroadcastStreamController)));
|
| + dart.assert(dart.is(controller, _StreamController) || dart.is(controller, _BroadcastStreamController));
|
| let eventSink = controller;
|
| let addError = eventSink[_addError];
|
| subscription = this.listen(event => {
|
| @@ -171,7 +171,7 @@ var async;
|
|
|
| if (dart.is(newValue, Future)) {
|
| subscription.pause();
|
| - dart.dinvoke(dart.dinvoke(newValue, 'then', add, {onError: addError}), 'whenComplete', subscription.resume);
|
| + dart.dsend(dart.dsend(newValue, 'then', add, {onError: addError}), 'whenComplete', subscription.resume);
|
| } else {
|
| controller.add(newValue);
|
| }
|
| @@ -207,7 +207,7 @@ var async;
|
| let subscription = null;
|
| // Function onListen: () → void
|
| function onListen() {
|
| - dart.assert(dart.notNull(dart.is(controller, _StreamController)) || dart.notNull(dart.is(controller, _BroadcastStreamController)));
|
| + dart.assert(dart.is(controller, _StreamController) || dart.is(controller, _BroadcastStreamController));
|
| let eventSink = controller;
|
| subscription = this.listen(event => {
|
| let newStream = null;
|
| @@ -683,7 +683,7 @@ var async;
|
| return future;
|
| }
|
| elementAt(index) {
|
| - if (dart.notNull(!(typeof index == 'number')) || dart.notNull(index) < 0)
|
| + if (!(typeof index == 'number') || dart.notNull(index) < 0)
|
| throw new core.ArgumentError(index);
|
| let future = new (_Future$(T))();
|
| let subscription = null;
|
| @@ -719,9 +719,9 @@ var async;
|
| // 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)));
|
| + dart.assert(dart.is(controller, _StreamController) || dart.is(controller, _BroadcastStreamController));
|
| let eventSink = controller;
|
| - dart.dinvoke(eventSink, '_addError', error, stackTrace);
|
| + dart.dsend(eventSink, _addError, error, stackTrace);
|
| timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType(dart.void, [])));
|
| }
|
| // Function onDone: () → void
|
| @@ -2368,7 +2368,7 @@ var async;
|
| let result = listener.result;
|
| result[_isChained] = true;
|
| isPropagationAborted = true;
|
| - dart.dinvoke(completeResult, 'then', ignored => {
|
| + dart.dsend(completeResult, 'then', ignored => {
|
| _Future[_propagateToListeners](source, new _FutureListener.chain(result));
|
| }, {
|
| onError: (error, stackTrace) => {
|
| @@ -2376,7 +2376,7 @@ var async;
|
| stackTrace = null;
|
| if (!dart.is(completeResult, _Future)) {
|
| completeResult = new _Future();
|
| - dart.dinvoke(completeResult, '_setError', error, stackTrace);
|
| + dart.dsend(completeResult, _setError, error, stackTrace);
|
| }
|
| _Future[_propagateToListeners](dart.as(completeResult, _Future), new _FutureListener.chain(result));
|
| }
|
| @@ -2397,7 +2397,7 @@ var async;
|
| Zone[_leave](oldZone);
|
| if (isPropagationAborted)
|
| return;
|
| - if (dart.notNull(listenerHasValue) && !dart.notNull(core.identical(sourceValue, listenerValueOrError)) && dart.notNull(dart.is(listenerValueOrError, Future))) {
|
| + if (dart.notNull(listenerHasValue) && !dart.notNull(core.identical(sourceValue, listenerValueOrError)) && dart.is(listenerValueOrError, Future)) {
|
| let chainSource = dart.as(listenerValueOrError, Future);
|
| let result = listener.result;
|
| if (dart.is(chainSource, _Future)) {
|
| @@ -4004,7 +4004,7 @@ var async;
|
| _SkipStream(source, count) {
|
| this[_remaining] = count;
|
| super._ForwardingStream(source);
|
| - if (dart.notNull(!(typeof count == 'number')) || dart.notNull(count) < 0)
|
| + if (!(typeof count == 'number') || dart.notNull(count) < 0)
|
| throw new core.ArgumentError(count);
|
| }
|
| [_handleData](inputEvent, sink) {
|
|
|