| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 = {})); |
| OLD | NEW |