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 |