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

Side by Side Diff: lib/runtime/dart/async.js

Issue 1042003002: fix list literal initialization call fix typeof calls for primitive JS types add dart/collection.js… (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 var async; 1 var async;
2 (function(exports) { 2 (function(exports) {
3 'use strict'; 3 'use strict';
4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic
5 function _invokeErrorHandler(errorHandler, error, stackTrace) { 5 function _invokeErrorHandler(errorHandler, error, stackTrace) {
6 if (dart.is(errorHandler, ZoneBinaryCallback)) { 6 if (dart.is(errorHandler, ZoneBinaryCallback)) {
7 return dart.dinvokef(errorHandler, error, stackTrace); 7 return dart.dinvokef(errorHandler, error, stackTrace);
8 } else { 8 } else {
9 return dart.dinvokef(errorHandler, error); 9 return dart.dinvokef(errorHandler, error);
10 } 10 }
(...skipping 353 matching lines...) Expand 10 before | Expand all | Expand 10 after
364 let future = new _Future(); 364 let future = new _Future();
365 let subscription = null; 365 let subscription = null;
366 subscription = this.listen(dart.closureWrap((_) => { 366 subscription = this.listen(dart.closureWrap((_) => {
367 _cancelAndValue(subscription, future, false); 367 _cancelAndValue(subscription, future, false);
368 }, "(T) → void"), {onError: future[_completeError], onDone: (() => { 368 }, "(T) → void"), {onError: future[_completeError], onDone: (() => {
369 future._complete(true); 369 future._complete(true);
370 }).bind(this), cancelOnError: true}); 370 }).bind(this), cancelOnError: true});
371 return future; 371 return future;
372 } 372 }
373 toList() { 373 toList() {
374 let result = new List.from([]); 374 let result = new core.List$(T).from([]);
375 let future = new _Future(); 375 let future = new _Future();
376 this.listen(((data) => { 376 this.listen(((data) => {
377 result.add(data); 377 result.add(data);
378 }).bind(this), {onError: future[_completeError], onDone: (() => { 378 }).bind(this), {onError: future[_completeError], onDone: (() => {
379 future._complete(result); 379 future._complete(result);
380 }).bind(this), cancelOnError: true}); 380 }).bind(this), cancelOnError: true});
381 return future; 381 return future;
382 } 382 }
383 toSet() { 383 toSet() {
384 let result = new core.Set(); 384 let result = new core.Set();
(...skipping 191 matching lines...) Expand 10 before | Expand all | Expand 10 after
576 throw _internal.IterableElementError.noElement(); 576 throw _internal.IterableElementError.noElement();
577 } catch (e) { 577 } catch (e) {
578 let s = dart.stackTrace(e); 578 let s = dart.stackTrace(e);
579 _completeWithErrorCallback(future, e, s); 579 _completeWithErrorCallback(future, e, s);
580 } 580 }
581 581
582 }).bind(this), cancelOnError: true}); 582 }).bind(this), cancelOnError: true});
583 return future; 583 return future;
584 } 584 }
585 elementAt(index) { 585 elementAt(index) {
586 if (dart.notNull(!(typeof index == number)) || dart.notNull(index) < 0) 586 if (dart.notNull(!(typeof index == 'number')) || dart.notNull(index) < 0 )
587 throw new core.ArgumentError(index); 587 throw new core.ArgumentError(index);
588 let future = new _Future(); 588 let future = new _Future();
589 let subscription = null; 589 let subscription = null;
590 let elementIndex = 0; 590 let elementIndex = 0;
591 subscription = this.listen((value) => { 591 subscription = this.listen((value) => {
592 if (index === elementIndex) { 592 if (index === elementIndex) {
593 _cancelAndValue(subscription, future, value); 593 _cancelAndValue(subscription, future, value);
594 return; 594 return;
595 } 595 }
596 elementIndex = 1; 596 elementIndex = 1;
(...skipping 1071 matching lines...) Expand 10 before | Expand all | Expand 10 after
1668 dart.dinvokef(cleanUp, value); 1668 dart.dinvokef(cleanUp, value);
1669 }); 1669 });
1670 } 1670 }
1671 if (remaining === 0 && !dart.notNull(eagerError)) { 1671 if (remaining === 0 && !dart.notNull(eagerError)) {
1672 result._completeError(error, stackTrace); 1672 result._completeError(error, stackTrace);
1673 } 1673 }
1674 } 1674 }
1675 }).bind(this), {onError: handleError}); 1675 }).bind(this), {onError: handleError});
1676 } 1676 }
1677 if (remaining === 0) { 1677 if (remaining === 0) {
1678 return dart.as(new Future.value(/* Unimplemented const */new List.from ([])), Future$(core.List)); 1678 return dart.as(new Future.value(/* Unimplemented const */new core.List .from([])), Future$(core.List));
1679 } 1679 }
1680 values = new core.List(remaining); 1680 values = new core.List(remaining);
1681 return result; 1681 return result;
1682 } 1682 }
1683 static forEach(input, f) { 1683 static forEach(input, f) {
1684 let iterator = input.iterator; 1684 let iterator = input.iterator;
1685 return doWhile((() => { 1685 return doWhile((() => {
1686 if (!dart.notNull(iterator.moveNext())) 1686 if (!dart.notNull(iterator.moveNext()))
1687 return false; 1687 return false;
1688 return new Future.sync((() => dart.dinvokef(f, iterator.current)).bind (this)).then((_) => true); 1688 return new Future.sync((() => dart.dinvokef(f, iterator.current)).bind (this)).then((_) => true);
(...skipping 1738 matching lines...) Expand 10 before | Expand all | Expand 10 after
3427 } 3427 }
3428 if (this[_state] === _StreamIteratorImpl._STATE_FOUND) { 3428 if (this[_state] === _StreamIteratorImpl._STATE_FOUND) {
3429 this[_state] = _StreamIteratorImpl._STATE_MOVING; 3429 this[_state] = _StreamIteratorImpl._STATE_MOVING;
3430 this[_current$] = null; 3430 this[_current$] = null;
3431 this[_futureOrPrefetch] = new _Future(); 3431 this[_futureOrPrefetch] = new _Future();
3432 return dart.as(this[_futureOrPrefetch], Future$(core.bool)); 3432 return dart.as(this[_futureOrPrefetch], Future$(core.bool));
3433 } else { 3433 } else {
3434 dart.assert(dart.notNull(this[_state]) >= dart.notNull(_StreamIterator Impl._STATE_EXTRA_DATA)); 3434 dart.assert(dart.notNull(this[_state]) >= dart.notNull(_StreamIterator Impl._STATE_EXTRA_DATA));
3435 switch (this[_state]) { 3435 switch (this[_state]) {
3436 case _StreamIteratorImpl._STATE_EXTRA_DATA: 3436 case _StreamIteratorImpl._STATE_EXTRA_DATA:
3437 {
3437 this[_state] = _StreamIteratorImpl._STATE_FOUND; 3438 this[_state] = _StreamIteratorImpl._STATE_FOUND;
3438 this[_current$] = dart.as(this[_futureOrPrefetch], T); 3439 this[_current$] = dart.as(this[_futureOrPrefetch], T);
3439 this[_futureOrPrefetch] = null; 3440 this[_futureOrPrefetch] = null;
3440 this[_subscription].resume(); 3441 this[_subscription].resume();
3441 return new _Future.immediate(true); 3442 return new _Future.immediate(true);
3443 }
3442 case _StreamIteratorImpl._STATE_EXTRA_ERROR: 3444 case _StreamIteratorImpl._STATE_EXTRA_ERROR:
3445 {
3443 let prefetch = dart.as(this[_futureOrPrefetch], AsyncError); 3446 let prefetch = dart.as(this[_futureOrPrefetch], AsyncError);
3444 this[_clear](); 3447 this[_clear]();
3445 return new _Future.immediateError(prefetch.error, prefetch.stackTr ace); 3448 return new _Future.immediateError(prefetch.error, prefetch.stackTr ace);
3449 }
3446 case _StreamIteratorImpl._STATE_EXTRA_DONE: 3450 case _StreamIteratorImpl._STATE_EXTRA_DONE:
3451 {
3447 this[_clear](); 3452 this[_clear]();
3448 return new _Future.immediate(false); 3453 return new _Future.immediate(false);
3454 }
3449 } 3455 }
3450 } 3456 }
3451 } 3457 }
3452 [_clear]() { 3458 [_clear]() {
3453 this[_subscription] = null; 3459 this[_subscription] = null;
3454 this[_futureOrPrefetch] = null; 3460 this[_futureOrPrefetch] = null;
3455 this[_current$] = null; 3461 this[_current$] = null;
3456 this[_state] = _StreamIteratorImpl._STATE_DONE; 3462 this[_state] = _StreamIteratorImpl._STATE_DONE;
3457 } 3463 }
3458 cancel() { 3464 cancel() {
(...skipping 307 matching lines...) Expand 10 before | Expand all | Expand 10 after
3766 } 3772 }
3767 return _HandleErrorStream; 3773 return _HandleErrorStream;
3768 }); 3774 });
3769 let _HandleErrorStream = _HandleErrorStream$(dart.dynamic); 3775 let _HandleErrorStream = _HandleErrorStream$(dart.dynamic);
3770 let _remaining = Symbol('_remaining'); 3776 let _remaining = Symbol('_remaining');
3771 let _TakeStream$ = dart.generic(function(T) { 3777 let _TakeStream$ = dart.generic(function(T) {
3772 class _TakeStream extends _ForwardingStream$(T, T) { 3778 class _TakeStream extends _ForwardingStream$(T, T) {
3773 _TakeStream(source, count) { 3779 _TakeStream(source, count) {
3774 this[_remaining] = count; 3780 this[_remaining] = count;
3775 super._ForwardingStream(source); 3781 super._ForwardingStream(source);
3776 if (!(typeof count == number)) 3782 if (!(typeof count == 'number'))
3777 throw new core.ArgumentError(count); 3783 throw new core.ArgumentError(count);
3778 } 3784 }
3779 [_handleData](inputEvent, sink) { 3785 [_handleData](inputEvent, sink) {
3780 if (dart.notNull(this[_remaining]) > 0) { 3786 if (dart.notNull(this[_remaining]) > 0) {
3781 sink._add(inputEvent); 3787 sink._add(inputEvent);
3782 this[_remaining] = 1; 3788 this[_remaining] = 1;
3783 if (this[_remaining] === 0) { 3789 if (this[_remaining] === 0) {
3784 sink._close(); 3790 sink._close();
3785 } 3791 }
3786 } 3792 }
(...skipping 27 matching lines...) Expand all
3814 } 3820 }
3815 } 3821 }
3816 return _TakeWhileStream; 3822 return _TakeWhileStream;
3817 }); 3823 });
3818 let _TakeWhileStream = _TakeWhileStream$(dart.dynamic); 3824 let _TakeWhileStream = _TakeWhileStream$(dart.dynamic);
3819 let _SkipStream$ = dart.generic(function(T) { 3825 let _SkipStream$ = dart.generic(function(T) {
3820 class _SkipStream extends _ForwardingStream$(T, T) { 3826 class _SkipStream extends _ForwardingStream$(T, T) {
3821 _SkipStream(source, count) { 3827 _SkipStream(source, count) {
3822 this[_remaining] = count; 3828 this[_remaining] = count;
3823 super._ForwardingStream(source); 3829 super._ForwardingStream(source);
3824 if (dart.notNull(!(typeof count == number)) || dart.notNull(count) < 0) 3830 if (dart.notNull(!(typeof count == 'number')) || dart.notNull(count) < 0 )
3825 throw new core.ArgumentError(count); 3831 throw new core.ArgumentError(count);
3826 } 3832 }
3827 [_handleData](inputEvent, sink) { 3833 [_handleData](inputEvent, sink) {
3828 if (dart.notNull(this[_remaining]) > 0) { 3834 if (dart.notNull(this[_remaining]) > 0) {
3829 this[_remaining] = dart.notNull(this[_remaining]) - 1; 3835 this[_remaining] = dart.notNull(this[_remaining]) - 1;
3830 return; 3836 return;
3831 } 3837 }
3832 sink._add(inputEvent); 3838 sink._add(inputEvent);
3833 } 3839 }
3834 } 3840 }
(...skipping 1108 matching lines...) Expand 10 before | Expand all | Expand 10 after
4943 exports.StreamIterator = StreamIterator; 4949 exports.StreamIterator = StreamIterator;
4944 exports.StreamIterator$ = StreamIterator$; 4950 exports.StreamIterator$ = StreamIterator$;
4945 exports.StreamController = StreamController; 4951 exports.StreamController = StreamController;
4946 exports.StreamController$ = StreamController$; 4952 exports.StreamController$ = StreamController$;
4947 exports.Timer = Timer; 4953 exports.Timer = Timer;
4948 exports.ZoneSpecification = ZoneSpecification; 4954 exports.ZoneSpecification = ZoneSpecification;
4949 exports.ZoneDelegate = ZoneDelegate; 4955 exports.ZoneDelegate = ZoneDelegate;
4950 exports.Zone = Zone; 4956 exports.Zone = Zone;
4951 exports.runZoned = runZoned; 4957 exports.runZoned = runZoned;
4952 })(async || (async = {})); 4958 })(async || (async = {}));
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698