OLD | NEW |
1 var async = dart.defineLibrary(async, {}); | 1 var async = dart.defineLibrary(async, {}); |
2 var core = dart.import(core); | 2 var core = dart.import(core); |
3 var _internal = dart.import(_internal); | 3 var _internal = dart.import(_internal); |
4 var _js_helper = dart.lazyImport(_js_helper); | 4 var _js_helper = dart.lazyImport(_js_helper); |
5 var _isolate_helper = dart.lazyImport(_isolate_helper); | 5 var _isolate_helper = dart.lazyImport(_isolate_helper); |
6 var collection = dart.import(collection); | 6 var collection = dart.import(collection); |
7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { | 7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { |
8 'use strict'; | 8 'use strict'; |
9 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 9 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
10 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 10 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
(...skipping 713 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
724 dart.defineNamedConstructor(Stream, 'eventTransformed'); | 724 dart.defineNamedConstructor(Stream, 'eventTransformed'); |
725 dart.setSignature(Stream, { | 725 dart.setSignature(Stream, { |
726 constructors: () => ({ | 726 constructors: () => ({ |
727 Stream: [Stream$(T), []], | 727 Stream: [Stream$(T), []], |
728 fromFuture: [Stream$(T), [Future$(T)]], | 728 fromFuture: [Stream$(T), [Future$(T)]], |
729 fromIterable: [Stream$(T), [core.Iterable$(T)]], | 729 fromIterable: [Stream$(T), [core.Iterable$(T)]], |
730 periodic: [Stream$(T), [core.Duration], [dart.functionType(T, [core.int]
)]], | 730 periodic: [Stream$(T), [core.Duration], [dart.functionType(T, [core.int]
)]], |
731 eventTransformed: [Stream$(T), [Stream$(), dart.functionType(EventSink,
[EventSink$(T)])]] | 731 eventTransformed: [Stream$(T), [Stream$(), dart.functionType(EventSink,
[EventSink$(T)])]] |
732 }), | 732 }), |
733 methods: () => ({ | 733 methods: () => ({ |
734 asBroadcastStream: [Stream$(T), [], {nListe: dart.functionType(dart.void
, [StreamSubscription$(T)]), nCance: dart.functionType(dart.void, [StreamSubscri
ption$(T)])}], | 734 asBroadcastStream: [Stream$(T), [], {onListen: dart.functionType(dart.vo
id, [StreamSubscription$(T)]), onCancel: dart.functionType(dart.void, [StreamSub
scription$(T)])}], |
735 where: [Stream$(T), [dart.functionType(core.bool, [T])]], | 735 where: [Stream$(T), [dart.functionType(core.bool, [T])]], |
736 map: [Stream$(), [dart.functionType(core.Object, [T])]], | 736 map: [Stream$(), [dart.functionType(core.Object, [T])]], |
737 asyncMap: [Stream$(), [dart.functionType(core.Object, [T])]], | 737 asyncMap: [Stream$(), [dart.functionType(core.Object, [T])]], |
738 asyncExpand: [Stream$(), [dart.functionType(Stream$(), [T])]], | 738 asyncExpand: [Stream$(), [dart.functionType(Stream$(), [T])]], |
739 handleError: [Stream$(T), [core.Function], {es: dart.functionType(core.b
ool, [dart.bottom])}], | 739 handleError: [Stream$(T), [core.Function], {test: dart.functionType(core
.bool, [dart.bottom])}], |
740 expand: [Stream$(), [dart.functionType(core.Iterable, [T])]], | 740 expand: [Stream$(), [dart.functionType(core.Iterable, [T])]], |
741 pipe: [Future, [StreamConsumer$(T)]], | 741 pipe: [Future, [StreamConsumer$(T)]], |
742 transform: [Stream$(), [StreamTransformer$(T, core.Object)]], | 742 transform: [Stream$(), [StreamTransformer$(T, core.Object)]], |
743 reduce: [Future$(T), [dart.functionType(T, [T, T])]], | 743 reduce: [Future$(T), [dart.functionType(T, [T, T])]], |
744 fold: [Future, [core.Object, dart.functionType(core.Object, [dart.bottom
, T])]], | 744 fold: [Future, [core.Object, dart.functionType(core.Object, [dart.bottom
, T])]], |
745 join: [Future$(core.String), [], [core.String]], | 745 join: [Future$(core.String), [], [core.String]], |
746 contains: [Future$(core.bool), [core.Object]], | 746 contains: [Future$(core.bool), [core.Object]], |
747 forEach: [Future, [dart.functionType(dart.void, [T])]], | 747 forEach: [Future, [dart.functionType(dart.void, [T])]], |
748 every: [Future$(core.bool), [dart.functionType(core.bool, [T])]], | 748 every: [Future$(core.bool), [dart.functionType(core.bool, [T])]], |
749 any: [Future$(core.bool), [dart.functionType(core.bool, [T])]], | 749 any: [Future$(core.bool), [dart.functionType(core.bool, [T])]], |
750 toList: [Future$(core.List$(T)), []], | 750 toList: [Future$(core.List$(T)), []], |
751 toSet: [Future$(core.Set$(T)), []], | 751 toSet: [Future$(core.Set$(T)), []], |
752 drain: [Future, [], [core.Object]], | 752 drain: [Future, [], [core.Object]], |
753 take: [Stream$(T), [core.int]], | 753 take: [Stream$(T), [core.int]], |
754 takeWhile: [Stream$(T), [dart.functionType(core.bool, [T])]], | 754 takeWhile: [Stream$(T), [dart.functionType(core.bool, [T])]], |
755 skip: [Stream$(T), [core.int]], | 755 skip: [Stream$(T), [core.int]], |
756 skipWhile: [Stream$(T), [dart.functionType(core.bool, [T])]], | 756 skipWhile: [Stream$(T), [dart.functionType(core.bool, [T])]], |
757 distinct: [Stream$(T), [], [dart.functionType(core.bool, [T, T])]], | 757 distinct: [Stream$(T), [], [dart.functionType(core.bool, [T, T])]], |
758 firstWhere: [Future, [dart.functionType(core.bool, [T])], {efaultValu: d
art.functionType(core.Object, [])}], | 758 firstWhere: [Future, [dart.functionType(core.bool, [T])], {defaultValue:
dart.functionType(core.Object, [])}], |
759 lastWhere: [Future, [dart.functionType(core.bool, [T])], {efaultValu: da
rt.functionType(core.Object, [])}], | 759 lastWhere: [Future, [dart.functionType(core.bool, [T])], {defaultValue:
dart.functionType(core.Object, [])}], |
760 singleWhere: [Future$(T), [dart.functionType(core.bool, [T])]], | 760 singleWhere: [Future$(T), [dart.functionType(core.bool, [T])]], |
761 elementAt: [Future$(T), [core.int]], | 761 elementAt: [Future$(T), [core.int]], |
762 timeout: [Stream$(), [core.Duration], {nTimeou: dart.functionType(dart.v
oid, [EventSink])}] | 762 timeout: [Stream$(), [core.Duration], {onTimeout: dart.functionType(dart
.void, [EventSink])}] |
763 }) | 763 }) |
764 }); | 764 }); |
765 return Stream; | 765 return Stream; |
766 }); | 766 }); |
767 let Stream = Stream$(); | 767 let Stream = Stream$(); |
768 let _createSubscription = Symbol('_createSubscription'); | 768 let _createSubscription = Symbol('_createSubscription'); |
769 let _onListen = Symbol('_onListen'); | 769 let _onListen = Symbol('_onListen'); |
770 let _StreamImpl$ = dart.generic(function(T) { | 770 let _StreamImpl$ = dart.generic(function(T) { |
771 class _StreamImpl extends Stream$(T) { | 771 class _StreamImpl extends Stream$(T) { |
772 _StreamImpl() { | 772 _StreamImpl() { |
(...skipping 12 matching lines...) Expand all Loading... |
785 } | 785 } |
786 [_createSubscription](onData, onError, onDone, cancelOnError) { | 786 [_createSubscription](onData, onError, onDone, cancelOnError) { |
787 dart.as(onData, dart.functionType(dart.void, [T])); | 787 dart.as(onData, dart.functionType(dart.void, [T])); |
788 dart.as(onDone, dart.functionType(dart.void, [])); | 788 dart.as(onDone, dart.functionType(dart.void, [])); |
789 return new (_BufferingStreamSubscription$(T))(onData, onError, onDone, c
ancelOnError); | 789 return new (_BufferingStreamSubscription$(T))(onData, onError, onDone, c
ancelOnError); |
790 } | 790 } |
791 [_onListen](subscription) {} | 791 [_onListen](subscription) {} |
792 } | 792 } |
793 dart.setSignature(_StreamImpl, { | 793 dart.setSignature(_StreamImpl, { |
794 methods: () => ({ | 794 methods: () => ({ |
795 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n
Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b
ool}], | 795 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {o
nError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnError:
core.bool}], |
796 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart.
void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]], | 796 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart.
void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]], |
797 [_onListen]: [dart.void, [StreamSubscription]] | 797 [_onListen]: [dart.void, [StreamSubscription]] |
798 }) | 798 }) |
799 }); | 799 }); |
800 return _StreamImpl; | 800 return _StreamImpl; |
801 }); | 801 }); |
802 let _StreamImpl = _StreamImpl$(); | 802 let _StreamImpl = _StreamImpl$(); |
803 let _controller = Symbol('_controller'); | 803 let _controller = Symbol('_controller'); |
804 let _subscribe = Symbol('_subscribe'); | 804 let _subscribe = Symbol('_subscribe'); |
805 let _ControllerStream$ = dart.generic(function(T) { | 805 let _ControllerStream$ = dart.generic(function(T) { |
(...skipping 721 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1527 [_addListener]: [dart.void, [_BroadcastSubscription$(T)]], | 1527 [_addListener]: [dart.void, [_BroadcastSubscription$(T)]], |
1528 [_removeListener]: [dart.void, [_BroadcastSubscription$(T)]], | 1528 [_removeListener]: [dart.void, [_BroadcastSubscription$(T)]], |
1529 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T]
), core.Function, dart.functionType(dart.void, []), core.bool]], | 1529 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T]
), core.Function, dart.functionType(dart.void, []), core.bool]], |
1530 [_recordCancel]: [Future, [StreamSubscription$(T)]], | 1530 [_recordCancel]: [Future, [StreamSubscription$(T)]], |
1531 [_recordPause]: [dart.void, [StreamSubscription$(T)]], | 1531 [_recordPause]: [dart.void, [StreamSubscription$(T)]], |
1532 [_recordResume]: [dart.void, [StreamSubscription$(T)]], | 1532 [_recordResume]: [dart.void, [StreamSubscription$(T)]], |
1533 [_addEventError]: [core.Error, []], | 1533 [_addEventError]: [core.Error, []], |
1534 add: [dart.void, [T]], | 1534 add: [dart.void, [T]], |
1535 addError: [dart.void, [core.Object], [core.StackTrace]], | 1535 addError: [dart.void, [core.Object], [core.StackTrace]], |
1536 close: [Future, []], | 1536 close: [Future, []], |
1537 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}], | 1537 addStream: [Future, [Stream$(T)], {cancelOnError: core.bool}], |
1538 [_add]: [dart.void, [T]], | 1538 [_add]: [dart.void, [T]], |
1539 [_addError]: [dart.void, [core.Object, core.StackTrace]], | 1539 [_addError]: [dart.void, [core.Object, core.StackTrace]], |
1540 [_close]: [dart.void, []], | 1540 [_close]: [dart.void, []], |
1541 [_forEachListener]: [dart.void, [dart.functionType(dart.void, [_Bufferin
gStreamSubscription$(T)])]], | 1541 [_forEachListener]: [dart.void, [dart.functionType(dart.void, [_Bufferin
gStreamSubscription$(T)])]], |
1542 [_callOnCancel]: [dart.void, []] | 1542 [_callOnCancel]: [dart.void, []] |
1543 }) | 1543 }) |
1544 }); | 1544 }); |
1545 return _BroadcastStreamController; | 1545 return _BroadcastStreamController; |
1546 }); | 1546 }); |
1547 let _BroadcastStreamController = _BroadcastStreamController$(); | 1547 let _BroadcastStreamController = _BroadcastStreamController$(); |
(...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1784 DeferredLibrary(libraryName, opts) { | 1784 DeferredLibrary(libraryName, opts) { |
1785 let uri = opts && 'uri' in opts ? opts.uri : null; | 1785 let uri = opts && 'uri' in opts ? opts.uri : null; |
1786 this.libraryName = libraryName; | 1786 this.libraryName = libraryName; |
1787 this.uri = uri; | 1787 this.uri = uri; |
1788 } | 1788 } |
1789 load() { | 1789 load() { |
1790 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; | 1790 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; |
1791 } | 1791 } |
1792 } | 1792 } |
1793 dart.setSignature(DeferredLibrary, { | 1793 dart.setSignature(DeferredLibrary, { |
1794 constructors: () => ({DeferredLibrary: [DeferredLibrary, [core.String], {r:
core.String}]}), | 1794 constructors: () => ({DeferredLibrary: [DeferredLibrary, [core.String], {uri
: core.String}]}), |
1795 methods: () => ({load: [Future$(core.Null), []]}) | 1795 methods: () => ({load: [Future$(core.Null), []]}) |
1796 }); | 1796 }); |
1797 let _s = Symbol('_s'); | 1797 let _s = Symbol('_s'); |
1798 class DeferredLoadException extends core.Object { | 1798 class DeferredLoadException extends core.Object { |
1799 DeferredLoadException(s) { | 1799 DeferredLoadException(s) { |
1800 this[_s] = s; | 1800 this[_s] = s; |
1801 } | 1801 } |
1802 toString() { | 1802 toString() { |
1803 return `DeferredLoadException: '${this[_s]}'`; | 1803 return `DeferredLoadException: '${this[_s]}'`; |
1804 } | 1804 } |
(...skipping 167 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1972 dart.setSignature(Future, { | 1972 dart.setSignature(Future, { |
1973 constructors: () => ({ | 1973 constructors: () => ({ |
1974 Future: [Future$(T), [dart.functionType(core.Object, [])]], | 1974 Future: [Future$(T), [dart.functionType(core.Object, [])]], |
1975 microtask: [Future$(T), [dart.functionType(core.Object, [])]], | 1975 microtask: [Future$(T), [dart.functionType(core.Object, [])]], |
1976 sync: [Future$(T), [dart.functionType(core.Object, [])]], | 1976 sync: [Future$(T), [dart.functionType(core.Object, [])]], |
1977 value: [Future$(T), [], [core.Object]], | 1977 value: [Future$(T), [], [core.Object]], |
1978 error: [Future$(T), [core.Object], [core.StackTrace]], | 1978 error: [Future$(T), [core.Object], [core.StackTrace]], |
1979 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]] | 1979 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]] |
1980 }), | 1980 }), |
1981 statics: () => ({ | 1981 statics: () => ({ |
1982 wait: [Future$(core.List), [core.Iterable$(Future$())], {agerErro: core.
bool, leanU: dart.functionType(dart.void, [dart.bottom])}], | 1982 wait: [Future$(core.List), [core.Iterable$(Future$())], {eagerError: cor
e.bool, cleanUp: dart.functionType(dart.void, [dart.bottom])}], |
1983 forEach: [Future$(), [core.Iterable, dart.functionType(core.Object, [dar
t.bottom])]], | 1983 forEach: [Future$(), [core.Iterable, dart.functionType(core.Object, [dar
t.bottom])]], |
1984 doWhile: [Future$(), [dart.functionType(core.Object, [])]] | 1984 doWhile: [Future$(), [dart.functionType(core.Object, [])]] |
1985 }), | 1985 }), |
1986 names: ['wait', 'forEach', 'doWhile'] | 1986 names: ['wait', 'forEach', 'doWhile'] |
1987 }); | 1987 }); |
1988 return Future; | 1988 return Future; |
1989 }); | 1989 }); |
1990 let Future = Future$(); | 1990 let Future = Future$(); |
1991 dart.defineLazyProperties(Future, { | 1991 dart.defineLazyProperties(Future, { |
1992 get _nullFuture() { | 1992 get _nullFuture() { |
(...skipping 659 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2652 _Future[dart.implements] = () => [Future$(T)]; | 2652 _Future[dart.implements] = () => [Future$(T)]; |
2653 dart.defineNamedConstructor(_Future, 'immediate'); | 2653 dart.defineNamedConstructor(_Future, 'immediate'); |
2654 dart.defineNamedConstructor(_Future, 'immediateError'); | 2654 dart.defineNamedConstructor(_Future, 'immediateError'); |
2655 dart.setSignature(_Future, { | 2655 dart.setSignature(_Future, { |
2656 constructors: () => ({ | 2656 constructors: () => ({ |
2657 _Future: [_Future$(T), []], | 2657 _Future: [_Future$(T), []], |
2658 immediate: [_Future$(T), [core.Object]], | 2658 immediate: [_Future$(T), [core.Object]], |
2659 immediateError: [_Future$(T), [core.Object], [core.StackTrace]] | 2659 immediateError: [_Future$(T), [core.Object], [core.StackTrace]] |
2660 }), | 2660 }), |
2661 methods: () => ({ | 2661 methods: () => ({ |
2662 then: [Future, [dart.functionType(core.Object, [T])], {nErro: core.Funct
ion}], | 2662 then: [Future, [dart.functionType(core.Object, [T])], {onError: core.Fun
ction}], |
2663 catchError: [Future, [core.Function], {es: dart.functionType(core.bool,
[dart.bottom])}], | 2663 catchError: [Future, [core.Function], {test: dart.functionType(core.bool
, [dart.bottom])}], |
2664 whenComplete: [Future$(T), [dart.functionType(core.Object, [])]], | 2664 whenComplete: [Future$(T), [dart.functionType(core.Object, [])]], |
2665 asStream: [Stream$(T), []], | 2665 asStream: [Stream$(T), []], |
2666 [_markPendingCompletion]: [dart.void, []], | 2666 [_markPendingCompletion]: [dart.void, []], |
2667 [_setValue]: [dart.void, [T]], | 2667 [_setValue]: [dart.void, [T]], |
2668 [_setErrorObject]: [dart.void, [AsyncError]], | 2668 [_setErrorObject]: [dart.void, [AsyncError]], |
2669 [_setError]: [dart.void, [core.Object, core.StackTrace]], | 2669 [_setError]: [dart.void, [core.Object, core.StackTrace]], |
2670 [_addListener]: [dart.void, [_FutureListener]], | 2670 [_addListener]: [dart.void, [_FutureListener]], |
2671 [_removeListeners]: [_FutureListener, []], | 2671 [_removeListeners]: [_FutureListener, []], |
2672 [_complete]: [dart.void, [core.Object]], | 2672 [_complete]: [dart.void, [core.Object]], |
2673 [_completeWithValue]: [dart.void, [core.Object]], | 2673 [_completeWithValue]: [dart.void, [core.Object]], |
2674 [_completeError]: [dart.void, [core.Object], [core.StackTrace]], | 2674 [_completeError]: [dart.void, [core.Object], [core.StackTrace]], |
2675 [_asyncComplete]: [dart.void, [core.Object]], | 2675 [_asyncComplete]: [dart.void, [core.Object]], |
2676 [_asyncCompleteError]: [dart.void, [core.Object, core.StackTrace]], | 2676 [_asyncCompleteError]: [dart.void, [core.Object, core.StackTrace]], |
2677 timeout: [Future, [core.Duration], {nTimeou: dart.functionType(core.Obje
ct, [])}] | 2677 timeout: [Future, [core.Duration], {onTimeout: dart.functionType(core.Ob
ject, [])}] |
2678 }), | 2678 }), |
2679 statics: () => ({ | 2679 statics: () => ({ |
2680 _chainForeignFuture: [dart.void, [Future, _Future$()]], | 2680 _chainForeignFuture: [dart.void, [Future, _Future$()]], |
2681 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]], | 2681 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]], |
2682 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]] | 2682 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]] |
2683 }), | 2683 }), |
2684 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] | 2684 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] |
2685 }); | 2685 }); |
2686 return _Future; | 2686 return _Future; |
2687 }); | 2687 }); |
(...skipping 192 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2880 let onError = opts && 'onError' in opts ? opts.onError : null; | 2880 let onError = opts && 'onError' in opts ? opts.onError : null; |
2881 let onDone = opts && 'onDone' in opts ? opts.onDone : null; | 2881 let onDone = opts && 'onDone' in opts ? opts.onDone : null; |
2882 dart.as(onDone, dart.functionType(dart.void, [])); | 2882 dart.as(onDone, dart.functionType(dart.void, [])); |
2883 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 2883 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
2884 return this[_stream].listen(onData, {onError: onError, onDone: onDone, c
ancelOnError: cancelOnError}); | 2884 return this[_stream].listen(onData, {onError: onError, onDone: onDone, c
ancelOnError: cancelOnError}); |
2885 } | 2885 } |
2886 } | 2886 } |
2887 dart.setSignature(StreamView, { | 2887 dart.setSignature(StreamView, { |
2888 constructors: () => ({StreamView: [StreamView$(T), [Stream$(T)]]}), | 2888 constructors: () => ({StreamView: [StreamView$(T), [Stream$(T)]]}), |
2889 methods: () => ({ | 2889 methods: () => ({ |
2890 asBroadcastStream: [Stream$(T), [], {nListe: dart.functionType(dart.void
, [StreamSubscription$(T)]), nCance: dart.functionType(dart.void, [StreamSubscri
ption$(T)])}], | 2890 asBroadcastStream: [Stream$(T), [], {onListen: dart.functionType(dart.vo
id, [StreamSubscription$(T)]), onCancel: dart.functionType(dart.void, [StreamSub
scription$(T)])}], |
2891 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n
Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b
ool}] | 2891 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {o
nError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnError:
core.bool}] |
2892 }) | 2892 }) |
2893 }); | 2893 }); |
2894 return StreamView; | 2894 return StreamView; |
2895 }); | 2895 }); |
2896 let StreamView = StreamView$(); | 2896 let StreamView = StreamView$(); |
2897 let StreamConsumer$ = dart.generic(function(S) { | 2897 let StreamConsumer$ = dart.generic(function(S) { |
2898 class StreamConsumer extends core.Object {} | 2898 class StreamConsumer extends core.Object {} |
2899 return StreamConsumer; | 2899 return StreamConsumer; |
2900 }); | 2900 }); |
2901 let StreamConsumer = StreamConsumer$(); | 2901 let StreamConsumer = StreamConsumer$(); |
2902 let StreamSink$ = dart.generic(function(S) { | 2902 let StreamSink$ = dart.generic(function(S) { |
2903 class StreamSink extends core.Object {} | 2903 class StreamSink extends core.Object {} |
2904 StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)]; | 2904 StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)]; |
2905 return StreamSink; | 2905 return StreamSink; |
2906 }); | 2906 }); |
2907 let StreamSink = StreamSink$(); | 2907 let StreamSink = StreamSink$(); |
2908 let StreamTransformer$ = dart.generic(function(S, T) { | 2908 let StreamTransformer$ = dart.generic(function(S, T) { |
2909 class StreamTransformer extends core.Object { | 2909 class StreamTransformer extends core.Object { |
2910 StreamTransformer(transformer) { | 2910 StreamTransformer(transformer) { |
2911 return new _StreamSubscriptionTransformer(transformer); | 2911 return new _StreamSubscriptionTransformer(transformer); |
2912 } | 2912 } |
2913 fromHandlers(opts) { | 2913 fromHandlers(opts) { |
2914 return new _StreamHandlerTransformer(opts); | 2914 return new _StreamHandlerTransformer(opts); |
2915 } | 2915 } |
2916 } | 2916 } |
2917 dart.defineNamedConstructor(StreamTransformer, 'fromHandlers'); | 2917 dart.defineNamedConstructor(StreamTransformer, 'fromHandlers'); |
2918 dart.setSignature(StreamTransformer, { | 2918 dart.setSignature(StreamTransformer, { |
2919 constructors: () => ({ | 2919 constructors: () => ({ |
2920 StreamTransformer: [StreamTransformer$(S, T), [dart.functionType(StreamS
ubscription$(T), [Stream$(S), core.bool])]], | 2920 StreamTransformer: [StreamTransformer$(S, T), [dart.functionType(StreamS
ubscription$(T), [Stream$(S), core.bool])]], |
2921 fromHandlers: [StreamTransformer$(S, T), [], {andleDat: dart.functionTyp
e(dart.void, [S, EventSink$(T)]), andleErro: dart.functionType(dart.void, [core.
Object, core.StackTrace, EventSink$(T)]), andleDon: dart.functionType(dart.void,
[EventSink$(T)])}] | 2921 fromHandlers: [StreamTransformer$(S, T), [], {handleData: dart.functionT
ype(dart.void, [S, EventSink$(T)]), handleError: dart.functionType(dart.void, [c
ore.Object, core.StackTrace, EventSink$(T)]), handleDone: dart.functionType(dart
.void, [EventSink$(T)])}] |
2922 }) | 2922 }) |
2923 }); | 2923 }); |
2924 return StreamTransformer; | 2924 return StreamTransformer; |
2925 }); | 2925 }); |
2926 let StreamTransformer = StreamTransformer$(); | 2926 let StreamTransformer = StreamTransformer$(); |
2927 let StreamIterator$ = dart.generic(function(T) { | 2927 let StreamIterator$ = dart.generic(function(T) { |
2928 class StreamIterator extends core.Object { | 2928 class StreamIterator extends core.Object { |
2929 StreamIterator(stream) { | 2929 StreamIterator(stream) { |
2930 return new (_StreamIteratorImpl$(T))(stream); | 2930 return new (_StreamIteratorImpl$(T))(stream); |
2931 } | 2931 } |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2987 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2987 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
2988 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2988 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
2989 let sync = opts && 'sync' in opts ? opts.sync : false; | 2989 let sync = opts && 'sync' in opts ? opts.sync : false; |
2990 return sync ? new (_SyncBroadcastStreamController$(T))(onListen, onCance
l) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel); | 2990 return sync ? new (_SyncBroadcastStreamController$(T))(onListen, onCance
l) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel); |
2991 } | 2991 } |
2992 } | 2992 } |
2993 StreamController[dart.implements] = () => [StreamSink$(T)]; | 2993 StreamController[dart.implements] = () => [StreamSink$(T)]; |
2994 dart.defineNamedConstructor(StreamController, 'broadcast'); | 2994 dart.defineNamedConstructor(StreamController, 'broadcast'); |
2995 dart.setSignature(StreamController, { | 2995 dart.setSignature(StreamController, { |
2996 constructors: () => ({ | 2996 constructors: () => ({ |
2997 StreamController: [StreamController$(T), [], {nListe: dart.functionType(
dart.void, []), nPaus: dart.functionType(dart.void, []), nResum: dart.functionTy
pe(dart.void, []), nCance: dart.functionType(core.Object, []), yn: core.bool}], | 2997 StreamController: [StreamController$(T), [], {onListen: dart.functionTyp
e(dart.void, []), onPause: dart.functionType(dart.void, []), onResume: dart.func
tionType(dart.void, []), onCancel: dart.functionType(core.Object, []), sync: cor
e.bool}], |
2998 broadcast: [StreamController$(T), [], {nListe: dart.functionType(dart.vo
id, []), nCance: dart.functionType(dart.void, []), yn: core.bool}] | 2998 broadcast: [StreamController$(T), [], {onListen: dart.functionType(dart.
void, []), onCancel: dart.functionType(dart.void, []), sync: core.bool}] |
2999 }) | 2999 }) |
3000 }); | 3000 }); |
3001 return StreamController; | 3001 return StreamController; |
3002 }); | 3002 }); |
3003 let StreamController = StreamController$(); | 3003 let StreamController = StreamController$(); |
3004 let _StreamControllerLifecycle$ = dart.generic(function(T) { | 3004 let _StreamControllerLifecycle$ = dart.generic(function(T) { |
3005 class _StreamControllerLifecycle extends core.Object { | 3005 class _StreamControllerLifecycle extends core.Object { |
3006 [_recordPause](subscription) { | 3006 [_recordPause](subscription) { |
3007 dart.as(subscription, StreamSubscription$(T)); | 3007 dart.as(subscription, StreamSubscription$(T)); |
3008 } | 3008 } |
(...skipping 243 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3252 } | 3252 } |
3253 _runGuarded(this[_onResume]); | 3253 _runGuarded(this[_onResume]); |
3254 } | 3254 } |
3255 } | 3255 } |
3256 _StreamController[dart.implements] = () => [StreamController$(T), _StreamCon
trollerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)]; | 3256 _StreamController[dart.implements] = () => [StreamController$(T), _StreamCon
trollerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)]; |
3257 dart.setSignature(_StreamController, { | 3257 dart.setSignature(_StreamController, { |
3258 constructors: () => ({_StreamController: [_StreamController$(T), []]}), | 3258 constructors: () => ({_StreamController: [_StreamController$(T), []]}), |
3259 methods: () => ({ | 3259 methods: () => ({ |
3260 [_ensurePendingEvents]: [_StreamImplEvents, []], | 3260 [_ensurePendingEvents]: [_StreamImplEvents, []], |
3261 [_badEventState]: [core.Error, []], | 3261 [_badEventState]: [core.Error, []], |
3262 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}], | 3262 addStream: [Future, [Stream$(T)], {cancelOnError: core.bool}], |
3263 [_ensureDoneFuture]: [Future, []], | 3263 [_ensureDoneFuture]: [Future, []], |
3264 add: [dart.void, [T]], | 3264 add: [dart.void, [T]], |
3265 addError: [dart.void, [core.Object], [core.StackTrace]], | 3265 addError: [dart.void, [core.Object], [core.StackTrace]], |
3266 close: [Future, []], | 3266 close: [Future, []], |
3267 [_closeUnchecked]: [dart.void, []], | 3267 [_closeUnchecked]: [dart.void, []], |
3268 [_add]: [dart.void, [T]], | 3268 [_add]: [dart.void, [T]], |
3269 [_addError]: [dart.void, [core.Object, core.StackTrace]], | 3269 [_addError]: [dart.void, [core.Object, core.StackTrace]], |
3270 [_close]: [dart.void, []], | 3270 [_close]: [dart.void, []], |
3271 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T]
), core.Function, dart.functionType(dart.void, []), core.bool]], | 3271 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T]
), core.Function, dart.functionType(dart.void, []), core.bool]], |
3272 [_recordCancel]: [Future, [StreamSubscription$(T)]], | 3272 [_recordCancel]: [Future, [StreamSubscription$(T)]], |
(...skipping 149 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3422 return this[_target].done; | 3422 return this[_target].done; |
3423 } | 3423 } |
3424 } | 3424 } |
3425 _StreamSinkWrapper[dart.implements] = () => [StreamSink$(T)]; | 3425 _StreamSinkWrapper[dart.implements] = () => [StreamSink$(T)]; |
3426 dart.setSignature(_StreamSinkWrapper, { | 3426 dart.setSignature(_StreamSinkWrapper, { |
3427 constructors: () => ({_StreamSinkWrapper: [_StreamSinkWrapper$(T), [Stream
Controller]]}), | 3427 constructors: () => ({_StreamSinkWrapper: [_StreamSinkWrapper$(T), [Stream
Controller]]}), |
3428 methods: () => ({ | 3428 methods: () => ({ |
3429 add: [dart.void, [T]], | 3429 add: [dart.void, [T]], |
3430 addError: [dart.void, [core.Object], [core.StackTrace]], | 3430 addError: [dart.void, [core.Object], [core.StackTrace]], |
3431 close: [Future, []], | 3431 close: [Future, []], |
3432 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}] | 3432 addStream: [Future, [Stream$(T)], {cancelOnError: core.bool}] |
3433 }) | 3433 }) |
3434 }); | 3434 }); |
3435 return _StreamSinkWrapper; | 3435 return _StreamSinkWrapper; |
3436 }); | 3436 }); |
3437 let _StreamSinkWrapper = _StreamSinkWrapper$(); | 3437 let _StreamSinkWrapper = _StreamSinkWrapper$(); |
3438 let _AddStreamState$ = dart.generic(function(T) { | 3438 let _AddStreamState$ = dart.generic(function(T) { |
3439 class _AddStreamState extends core.Object { | 3439 class _AddStreamState extends core.Object { |
3440 _AddStreamState(controller, source, cancelOnError) { | 3440 _AddStreamState(controller, source, cancelOnError) { |
3441 this.addStreamFuture = new _Future(); | 3441 this.addStreamFuture = new _Future(); |
3442 this.addSubscription = source.listen(dart.bind(controller, _add), {onErr
or: cancelOnError ? dart.as(_AddStreamState$().makeErrorHandler(controller), cor
e.Function) : dart.bind(controller, _addError), onDone: dart.bind(controller, _c
lose), cancelOnError: cancelOnError}); | 3442 this.addSubscription = source.listen(dart.bind(controller, _add), {onErr
or: cancelOnError ? dart.as(_AddStreamState$().makeErrorHandler(controller), cor
e.Function) : dart.bind(controller, _addError), onDone: dart.bind(controller, _c
lose), cancelOnError: cancelOnError}); |
(...skipping 498 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3941 } | 3941 } |
3942 get [_isSubscriptionPaused]() { | 3942 get [_isSubscriptionPaused]() { |
3943 if (this[_subscription] == null) | 3943 if (this[_subscription] == null) |
3944 return false; | 3944 return false; |
3945 return this[_subscription].isPaused; | 3945 return this[_subscription].isPaused; |
3946 } | 3946 } |
3947 } | 3947 } |
3948 dart.setSignature(_AsBroadcastStream, { | 3948 dart.setSignature(_AsBroadcastStream, { |
3949 constructors: () => ({_AsBroadcastStream: [_AsBroadcastStream$(T), [Stream
$(T), dart.functionType(dart.void, [StreamSubscription]), dart.functionType(dart
.void, [StreamSubscription])]]}), | 3949 constructors: () => ({_AsBroadcastStream: [_AsBroadcastStream$(T), [Stream
$(T), dart.functionType(dart.void, [StreamSubscription]), dart.functionType(dart
.void, [StreamSubscription])]]}), |
3950 methods: () => ({ | 3950 methods: () => ({ |
3951 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n
Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b
ool}], | 3951 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {o
nError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnError:
core.bool}], |
3952 [_onCancel]: [dart.void, []], | 3952 [_onCancel]: [dart.void, []], |
3953 [_onListen]: [dart.void, []], | 3953 [_onListen]: [dart.void, []], |
3954 [_cancelSubscription]: [dart.void, []], | 3954 [_cancelSubscription]: [dart.void, []], |
3955 [_pauseSubscription]: [dart.void, [Future]], | 3955 [_pauseSubscription]: [dart.void, [Future]], |
3956 [_resumeSubscription]: [dart.void, []] | 3956 [_resumeSubscription]: [dart.void, []] |
3957 }) | 3957 }) |
3958 }); | 3958 }); |
3959 return _AsBroadcastStream; | 3959 return _AsBroadcastStream; |
3960 }); | 3960 }); |
3961 let _AsBroadcastStream = _AsBroadcastStream$(); | 3961 let _AsBroadcastStream = _AsBroadcastStream$(); |
(...skipping 273 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4235 sink[_addError](error, stackTrace); | 4235 sink[_addError](error, stackTrace); |
4236 } | 4236 } |
4237 [_handleDone](sink) { | 4237 [_handleDone](sink) { |
4238 dart.as(sink, _EventSink$(T)); | 4238 dart.as(sink, _EventSink$(T)); |
4239 sink[_close](); | 4239 sink[_close](); |
4240 } | 4240 } |
4241 } | 4241 } |
4242 dart.setSignature(_ForwardingStream, { | 4242 dart.setSignature(_ForwardingStream, { |
4243 constructors: () => ({_ForwardingStream: [_ForwardingStream$(S, T), [Strea
m$(S)]]}), | 4243 constructors: () => ({_ForwardingStream: [_ForwardingStream$(S, T), [Strea
m$(S)]]}), |
4244 methods: () => ({ | 4244 methods: () => ({ |
4245 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n
Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b
ool}], | 4245 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {o
nError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnError:
core.bool}], |
4246 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart.
void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]], | 4246 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart.
void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]], |
4247 [_handleData]: [dart.void, [S, _EventSink$(T)]], | 4247 [_handleData]: [dart.void, [S, _EventSink$(T)]], |
4248 [_handleError]: [dart.void, [core.Object, core.StackTrace, _EventSink$(T
)]], | 4248 [_handleError]: [dart.void, [core.Object, core.StackTrace, _EventSink$(T
)]], |
4249 [_handleDone]: [dart.void, [_EventSink$(T)]] | 4249 [_handleDone]: [dart.void, [_EventSink$(T)]] |
4250 }) | 4250 }) |
4251 }); | 4251 }); |
4252 return _ForwardingStream; | 4252 return _ForwardingStream; |
4253 }); | 4253 }); |
4254 let _ForwardingStream = _ForwardingStream$(); | 4254 let _ForwardingStream = _ForwardingStream$(); |
4255 let _ForwardingStreamSubscription$ = dart.generic(function(S, T) { | 4255 let _ForwardingStreamSubscription$ = dart.generic(function(S, T) { |
(...skipping 554 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4810 let onDone = opts && 'onDone' in opts ? opts.onDone : null; | 4810 let onDone = opts && 'onDone' in opts ? opts.onDone : null; |
4811 dart.as(onDone, dart.functionType(dart.void, [])); | 4811 dart.as(onDone, dart.functionType(dart.void, [])); |
4812 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 4812 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
4813 cancelOnError = core.identical(true, cancelOnError); | 4813 cancelOnError = core.identical(true, cancelOnError); |
4814 let subscription = new (_SinkTransformerStreamSubscription$(core.Object,
T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, on
Done, cancelOnError); | 4814 let subscription = new (_SinkTransformerStreamSubscription$(core.Object,
T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, on
Done, cancelOnError); |
4815 return subscription; | 4815 return subscription; |
4816 } | 4816 } |
4817 } | 4817 } |
4818 dart.setSignature(_BoundSinkStream, { | 4818 dart.setSignature(_BoundSinkStream, { |
4819 constructors: () => ({_BoundSinkStream: [_BoundSinkStream$(S, T), [Stream$
(S), _SinkMapper$(S, T)]]}), | 4819 constructors: () => ({_BoundSinkStream: [_BoundSinkStream$(S, T), [Stream$
(S), _SinkMapper$(S, T)]]}), |
4820 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart.
void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ance
lOnErro: core.bool}]}) | 4820 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart.
void, [T])], {onError: core.Function, onDone: dart.functionType(dart.void, []),
cancelOnError: core.bool}]}) |
4821 }); | 4821 }); |
4822 return _BoundSinkStream; | 4822 return _BoundSinkStream; |
4823 }); | 4823 }); |
4824 let _BoundSinkStream = _BoundSinkStream$(); | 4824 let _BoundSinkStream = _BoundSinkStream$(); |
4825 let _TransformDataHandler$ = dart.generic(function(S, T) { | 4825 let _TransformDataHandler$ = dart.generic(function(S, T) { |
4826 let _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart
.functionType(dart.void, [S, EventSink$(T)])); | 4826 let _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart
.functionType(dart.void, [S, EventSink$(T)])); |
4827 return _TransformDataHandler; | 4827 return _TransformDataHandler; |
4828 }); | 4828 }); |
4829 let _TransformDataHandler = _TransformDataHandler$(); | 4829 let _TransformDataHandler = _TransformDataHandler$(); |
4830 let _TransformErrorHandler$ = dart.generic(function(T) { | 4830 let _TransformErrorHandler$ = dart.generic(function(T) { |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4895 sink.add(data); | 4895 sink.add(data); |
4896 } | 4896 } |
4897 static _defaultHandleError(error, stackTrace, sink) { | 4897 static _defaultHandleError(error, stackTrace, sink) { |
4898 sink.addError(error); | 4898 sink.addError(error); |
4899 } | 4899 } |
4900 static _defaultHandleDone(sink) { | 4900 static _defaultHandleDone(sink) { |
4901 sink.close(); | 4901 sink.close(); |
4902 } | 4902 } |
4903 } | 4903 } |
4904 dart.setSignature(_StreamHandlerTransformer, { | 4904 dart.setSignature(_StreamHandlerTransformer, { |
4905 constructors: () => ({_StreamHandlerTransformer: [_StreamHandlerTransforme
r$(S, T), [], {andleDat: dart.functionType(dart.void, [S, EventSink$(T)]), andle
Erro: dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)]
), andleDon: dart.functionType(dart.void, [EventSink$(T)])}]}), | 4905 constructors: () => ({_StreamHandlerTransformer: [_StreamHandlerTransforme
r$(S, T), [], {handleData: dart.functionType(dart.void, [S, EventSink$(T)]), han
dleError: dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$
(T)]), handleDone: dart.functionType(dart.void, [EventSink$(T)])}]}), |
4906 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}), | 4906 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}), |
4907 statics: () => ({ | 4907 statics: () => ({ |
4908 _defaultHandleData: [dart.void, [core.Object, EventSink]], | 4908 _defaultHandleData: [dart.void, [core.Object, EventSink]], |
4909 _defaultHandleError: [dart.void, [core.Object, core.StackTrace, EventSin
k]], | 4909 _defaultHandleError: [dart.void, [core.Object, core.StackTrace, EventSin
k]], |
4910 _defaultHandleDone: [dart.void, [EventSink]] | 4910 _defaultHandleDone: [dart.void, [EventSink]] |
4911 }), | 4911 }), |
4912 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone'] | 4912 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone'] |
4913 }); | 4913 }); |
4914 return _StreamHandlerTransformer; | 4914 return _StreamHandlerTransformer; |
4915 }); | 4915 }); |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4954 cancelOnError = core.identical(true, cancelOnError); | 4954 cancelOnError = core.identical(true, cancelOnError); |
4955 let result = this[_transformer](this[_stream], cancelOnError); | 4955 let result = this[_transformer](this[_stream], cancelOnError); |
4956 result.onData(onData); | 4956 result.onData(onData); |
4957 result.onError(onError); | 4957 result.onError(onError); |
4958 result.onDone(onDone); | 4958 result.onDone(onDone); |
4959 return result; | 4959 return result; |
4960 } | 4960 } |
4961 } | 4961 } |
4962 dart.setSignature(_BoundSubscriptionStream, { | 4962 dart.setSignature(_BoundSubscriptionStream, { |
4963 constructors: () => ({_BoundSubscriptionStream: [_BoundSubscriptionStream$
(S, T), [Stream$(S), _SubscriptionTransformer$(S, T)]]}), | 4963 constructors: () => ({_BoundSubscriptionStream: [_BoundSubscriptionStream$
(S, T), [Stream$(S), _SubscriptionTransformer$(S, T)]]}), |
4964 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart.
void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ance
lOnErro: core.bool}]}) | 4964 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart.
void, [T])], {onError: core.Function, onDone: dart.functionType(dart.void, []),
cancelOnError: core.bool}]}) |
4965 }); | 4965 }); |
4966 return _BoundSubscriptionStream; | 4966 return _BoundSubscriptionStream; |
4967 }); | 4967 }); |
4968 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); | 4968 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); |
4969 let __CastType27$ = dart.generic(function(S, T) { | 4969 let __CastType27$ = dart.generic(function(S, T) { |
4970 let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart
.void, [S, EventSink$(T)])); | 4970 let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart
.void, [S, EventSink$(T)])); |
4971 return __CastType27; | 4971 return __CastType27; |
4972 }); | 4972 }); |
4973 let __CastType27 = __CastType27$(); | 4973 let __CastType27 = __CastType27$(); |
4974 let __CastType30$ = dart.generic(function(T) { | 4974 let __CastType30$ = dart.generic(function(T) { |
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5061 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; | 5061 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; |
5062 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; | 5062 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; |
5063 let print = opts && 'print' in opts ? opts.print : null; | 5063 let print = opts && 'print' in opts ? opts.print : null; |
5064 let fork = opts && 'fork' in opts ? opts.fork : null; | 5064 let fork = opts && 'fork' in opts ? opts.fork : null; |
5065 return new ZoneSpecification({handleUncaughtError: handleUncaughtError !=
null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run :
other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r
unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba
ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r
egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba
ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb
ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error
Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s
cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c
reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null
? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print
: other.print, fork: fork != null ? fork : other.fork}); | 5065 return new ZoneSpecification({handleUncaughtError: handleUncaughtError !=
null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run :
other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r
unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba
ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r
egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba
ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb
ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error
Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s
cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c
reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null
? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print
: other.print, fork: fork != null ? fork : other.fork}); |
5066 } | 5066 } |
5067 } | 5067 } |
5068 dart.defineNamedConstructor(ZoneSpecification, 'from'); | 5068 dart.defineNamedConstructor(ZoneSpecification, 'from'); |
5069 dart.setSignature(ZoneSpecification, { | 5069 dart.setSignature(ZoneSpecification, { |
5070 constructors: () => ({ | 5070 constructors: () => ({ |
5071 ZoneSpecification: [ZoneSpecification, [], {andleUncaughtErro: dart.functi
onType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.StackTrace]), u
: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(co
re.Object, [])]), unUnar: dart.functionType(core.Object, [Zone, ZoneDelegate, Zo
ne, dart.functionType(core.Object, [dart.bottom]), dart.bottom]), unBinar: dart.
functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core.Obje
ct, [dart.bottom, dart.bottom]), dart.bottom, dart.bottom]), egisterCallbac: dar
t.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(core.O
bject, [])]), egisterUnaryCallbac: dart.functionType(ZoneUnaryCallback, [Zone, Z
oneDelegate, Zone, dart.functionType(core.Object, [dart.bottom])]), egisterBinar
yCallbac: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.
functionType(core.Object, [dart.bottom, dart.bottom])]), rrorCallbac: dart.funct
ionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]), c
heduleMicrotas: dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(core.Object, [])]), reateTime: dart.functionType(Timer, [Zone, ZoneDel
egate, Zone, core.Duration, dart.functionType(dart.void, [])]), reatePeriodicTim
e: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.funct
ionType(dart.void, [Timer])]), rin: dart.functionType(dart.void, [Zone, ZoneDele
gate, Zone, core.String]), or: dart.functionType(Zone, [Zone, ZoneDelegate, Zone
, ZoneSpecification, core.Map])}], | 5071 ZoneSpecification: [ZoneSpecification, [], {handleUncaughtError: dart.func
tionType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.StackTrace]),
run: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionTyp
e(core.Object, [])]), runUnary: dart.functionType(core.Object, [Zone, ZoneDelega
te, Zone, dart.functionType(core.Object, [dart.bottom]), dart.bottom]), runBinar
y: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(c
ore.Object, [dart.bottom, dart.bottom]), dart.bottom, dart.bottom]), registerCal
lback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionT
ype(core.Object, [])]), registerUnaryCallback: dart.functionType(ZoneUnaryCallba
ck, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [dart.bottom])]),
registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegat
e, Zone, dart.functionType(core.Object, [dart.bottom, dart.bottom])]), errorCall
back: dart.functionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core
.StackTrace]), scheduleMicrotask: dart.functionType(dart.void, [Zone, ZoneDelega
te, Zone, dart.functionType(core.Object, [])]), createTimer: dart.functionType(T
imer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [])
]), createPeriodicTimer: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, cor
e.Duration, dart.functionType(dart.void, [Timer])]), print: dart.functionType(da
rt.void, [Zone, ZoneDelegate, Zone, core.String]), fork: dart.functionType(Zone,
[Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])}], |
5072 from: [ZoneSpecification, [ZoneSpecification], {andleUncaughtErro: dart.fu
nctionType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.StackTrace]
), u: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionTyp
e(core.Object, [])]), unUnar: dart.functionType(core.Object, [Zone, ZoneDelegate
, Zone, dart.functionType(core.Object, [dart.bottom]), dart.bottom]), unBinar: d
art.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core.
Object, [dart.bottom, dart.bottom]), dart.bottom, dart.bottom]), egisterCallbac:
dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(co
re.Object, [])]), egisterUnaryCallbac: dart.functionType(ZoneUnaryCallback, [Zon
e, ZoneDelegate, Zone, dart.functionType(core.Object, [dart.bottom])]), egisterB
inaryCallbac: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, d
art.functionType(core.Object, [dart.bottom, dart.bottom])]), rrorCallbac: dart.f
unctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]
), cheduleMicrotas: dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart
.functionType(core.Object, [])]), reateTime: dart.functionType(Timer, [Zone, Zon
eDelegate, Zone, core.Duration, dart.functionType(dart.void, [])]), reatePeriodi
cTime: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.f
unctionType(dart.void, [Timer])]), rin: dart.functionType(dart.void, [Zone, Zone
Delegate, Zone, core.String]), or: dart.functionType(Zone, [Zone, ZoneDelegate,
Zone, ZoneSpecification, core.Map])}] | 5072 from: [ZoneSpecification, [ZoneSpecification], {handleUncaughtError: dart.
functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.StackTrac
e]), run: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functio
nType(core.Object, [])]), runUnary: dart.functionType(core.Object, [Zone, ZoneDe
legate, Zone, dart.functionType(core.Object, [dart.bottom]), dart.bottom]), runB
inary: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionTy
pe(core.Object, [dart.bottom, dart.bottom]), dart.bottom, dart.bottom]), registe
rCallback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.funct
ionType(core.Object, [])]), registerUnaryCallback: dart.functionType(ZoneUnaryCa
llback, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [dart.bottom])
]), registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDel
egate, Zone, dart.functionType(core.Object, [dart.bottom, dart.bottom])]), error
Callback: dart.functionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object,
core.StackTrace]), scheduleMicrotask: dart.functionType(dart.void, [Zone, ZoneDe
legate, Zone, dart.functionType(core.Object, [])]), createTimer: dart.functionTy
pe(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void,
[])]), createPeriodicTimer: dart.functionType(Timer, [Zone, ZoneDelegate, Zone,
core.Duration, dart.functionType(dart.void, [Timer])]), print: dart.functionTyp
e(dart.void, [Zone, ZoneDelegate, Zone, core.String]), fork: dart.functionType(Z
one, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])}] |
5073 }) | 5073 }) |
5074 }); | 5074 }); |
5075 class _ZoneSpecification extends core.Object { | 5075 class _ZoneSpecification extends core.Object { |
5076 _ZoneSpecification(opts) { | 5076 _ZoneSpecification(opts) { |
5077 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; | 5077 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; |
5078 let run = opts && 'run' in opts ? opts.run : null; | 5078 let run = opts && 'run' in opts ? opts.run : null; |
5079 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; | 5079 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; |
5080 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; | 5080 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; |
5081 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; | 5081 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; |
5082 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; | 5082 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; |
(...skipping 14 matching lines...) Expand all Loading... |
5097 this.errorCallback = errorCallback; | 5097 this.errorCallback = errorCallback; |
5098 this.scheduleMicrotask = scheduleMicrotask; | 5098 this.scheduleMicrotask = scheduleMicrotask; |
5099 this.createTimer = createTimer; | 5099 this.createTimer = createTimer; |
5100 this.createPeriodicTimer = createPeriodicTimer; | 5100 this.createPeriodicTimer = createPeriodicTimer; |
5101 this.print = print; | 5101 this.print = print; |
5102 this.fork = fork; | 5102 this.fork = fork; |
5103 } | 5103 } |
5104 } | 5104 } |
5105 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; | 5105 _ZoneSpecification[dart.implements] = () => [ZoneSpecification]; |
5106 dart.setSignature(_ZoneSpecification, { | 5106 dart.setSignature(_ZoneSpecification, { |
5107 constructors: () => ({_ZoneSpecification: [_ZoneSpecification, [], {andleUnc
aughtErro: core.Object, u: core.Object, unUnar: core.Object, unBinar: core.Objec
t, egisterCallbac: core.Object, egisterUnaryCallbac: core.Object, egisterBinaryC
allbac: core.Object, rrorCallbac: core.Object, cheduleMicrotas: core.Object, rea
teTime: core.Object, reatePeriodicTime: core.Object, rin: core.Object, or: core.
Object}]}) | 5107 constructors: () => ({_ZoneSpecification: [_ZoneSpecification, [], {handleUn
caughtError: core.Object, run: core.Object, runUnary: core.Object, runBinary: co
re.Object, registerCallback: core.Object, registerUnaryCallback: core.Object, re
gisterBinaryCallback: core.Object, errorCallback: core.Object, scheduleMicrotask
: core.Object, createTimer: core.Object, createPeriodicTimer: core.Object, print
: core.Object, fork: core.Object}]}) |
5108 }); | 5108 }); |
5109 class ZoneDelegate extends core.Object {} | 5109 class ZoneDelegate extends core.Object {} |
5110 class Zone extends core.Object { | 5110 class Zone extends core.Object { |
5111 _() { | 5111 _() { |
5112 } | 5112 } |
5113 static get current() { | 5113 static get current() { |
5114 return Zone._current; | 5114 return Zone._current; |
5115 } | 5115 } |
5116 static _enter(zone) { | 5116 static _enter(zone) { |
5117 dart.assert(zone != null); | 5117 dart.assert(zone != null); |
(...skipping 210 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5328 print(line) { | 5328 print(line) { |
5329 _internal.printToConsole(line); | 5329 _internal.printToConsole(line); |
5330 } | 5330 } |
5331 } | 5331 } |
5332 dart.setSignature(_RootZone, { | 5332 dart.setSignature(_RootZone, { |
5333 constructors: () => ({_RootZone: [_RootZone, []]}), | 5333 constructors: () => ({_RootZone: [_RootZone, []]}), |
5334 methods: () => ({ | 5334 methods: () => ({ |
5335 runGuarded: [core.Object, [dart.functionType(core.Object, [])]], | 5335 runGuarded: [core.Object, [dart.functionType(core.Object, [])]], |
5336 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto
m]), core.Object]], | 5336 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto
m]), core.Object]], |
5337 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott
om, dart.bottom]), core.Object, core.Object]], | 5337 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott
om, dart.bottom]), core.Object, core.Object]], |
5338 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {unGuar
de: core.bool}], | 5338 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {runGua
rded: core.bool}], |
5339 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da
rt.bottom])], {unGuarde: core.bool}], | 5339 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da
rt.bottom])], {runGuarded: core.bool}], |
5340 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [
dart.bottom, dart.bottom])], {unGuarde: core.bool}], | 5340 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [
dart.bottom, dart.bottom])], {runGuarded: core.bool}], |
5341 get: [core.Object, [core.Object]], | 5341 get: [core.Object, [core.Object]], |
5342 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]], | 5342 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]], |
5343 fork: [Zone, [], {pecificatio: ZoneSpecification, oneValue: core.Map}], | 5343 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}]
, |
5344 run: [core.Object, [dart.functionType(core.Object, [])]], | 5344 run: [core.Object, [dart.functionType(core.Object, [])]], |
5345 runUnary: [core.Object, [dart.functionType(core.Object, [dart.bottom]), co
re.Object]], | 5345 runUnary: [core.Object, [dart.functionType(core.Object, [dart.bottom]), co
re.Object]], |
5346 runBinary: [core.Object, [dart.functionType(core.Object, [dart.bottom, dar
t.bottom]), core.Object, core.Object]], | 5346 runBinary: [core.Object, [dart.functionType(core.Object, [dart.bottom, dar
t.bottom]), core.Object, core.Object]], |
5347 registerCallback: [ZoneCallback, [dart.functionType(core.Object, [])]], | 5347 registerCallback: [ZoneCallback, [dart.functionType(core.Object, [])]], |
5348 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object,
[dart.bottom])]], | 5348 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object,
[dart.bottom])]], |
5349 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Objec
t, [dart.bottom, dart.bottom])]], | 5349 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Objec
t, [dart.bottom, dart.bottom])]], |
5350 errorCallback: [AsyncError, [core.Object, core.StackTrace]], | 5350 errorCallback: [AsyncError, [core.Object, core.StackTrace]], |
5351 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], | 5351 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], |
5352 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 5352 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
5353 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], | 5353 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], |
(...skipping 295 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5649 let parentDelegate = _parentDelegate(implementation.zone); | 5649 let parentDelegate = _parentDelegate(implementation.zone); |
5650 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, line); | 5650 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, line); |
5651 } | 5651 } |
5652 } | 5652 } |
5653 dart.setSignature(_CustomZone, { | 5653 dart.setSignature(_CustomZone, { |
5654 constructors: () => ({_CustomZone: [_CustomZone, [_Zone, ZoneSpecification,
core.Map]]}), | 5654 constructors: () => ({_CustomZone: [_CustomZone, [_Zone, ZoneSpecification,
core.Map]]}), |
5655 methods: () => ({ | 5655 methods: () => ({ |
5656 runGuarded: [core.Object, [dart.functionType(core.Object, [])]], | 5656 runGuarded: [core.Object, [dart.functionType(core.Object, [])]], |
5657 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto
m]), core.Object]], | 5657 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto
m]), core.Object]], |
5658 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott
om, dart.bottom]), core.Object, core.Object]], | 5658 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott
om, dart.bottom]), core.Object, core.Object]], |
5659 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {unGuar
de: core.bool}], | 5659 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {runGua
rded: core.bool}], |
5660 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da
rt.bottom])], {unGuarde: core.bool}], | 5660 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da
rt.bottom])], {runGuarded: core.bool}], |
5661 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [
dart.bottom, dart.bottom])], {unGuarde: core.bool}], | 5661 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [
dart.bottom, dart.bottom])], {runGuarded: core.bool}], |
5662 get: [core.Object, [core.Object]], | 5662 get: [core.Object, [core.Object]], |
5663 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]], | 5663 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]], |
5664 fork: [Zone, [], {pecificatio: ZoneSpecification, oneValue: core.Map}], | 5664 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}]
, |
5665 run: [core.Object, [dart.functionType(core.Object, [])]], | 5665 run: [core.Object, [dart.functionType(core.Object, [])]], |
5666 runUnary: [core.Object, [dart.functionType(core.Object, [dart.bottom]), co
re.Object]], | 5666 runUnary: [core.Object, [dart.functionType(core.Object, [dart.bottom]), co
re.Object]], |
5667 runBinary: [core.Object, [dart.functionType(core.Object, [dart.bottom, dar
t.bottom]), core.Object, core.Object]], | 5667 runBinary: [core.Object, [dart.functionType(core.Object, [dart.bottom, dar
t.bottom]), core.Object, core.Object]], |
5668 registerCallback: [ZoneCallback, [dart.functionType(core.Object, [])]], | 5668 registerCallback: [ZoneCallback, [dart.functionType(core.Object, [])]], |
5669 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object,
[dart.bottom])]], | 5669 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object,
[dart.bottom])]], |
5670 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Objec
t, [dart.bottom, dart.bottom])]], | 5670 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Objec
t, [dart.bottom, dart.bottom])]], |
5671 errorCallback: [AsyncError, [core.Object, core.StackTrace]], | 5671 errorCallback: [AsyncError, [core.Object, core.StackTrace]], |
5672 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], | 5672 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], |
5673 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 5673 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
5674 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], | 5674 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], |
(...skipping 182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5857 } else if (errorHandler != null) { | 5857 } else if (errorHandler != null) { |
5858 zoneSpecification = new ZoneSpecification.from(zoneSpecification, {handleU
ncaughtError: errorHandler}); | 5858 zoneSpecification = new ZoneSpecification.from(zoneSpecification, {handleU
ncaughtError: errorHandler}); |
5859 } | 5859 } |
5860 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); | 5860 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); |
5861 if (onError != null) { | 5861 if (onError != null) { |
5862 return zone.runGuarded(body); | 5862 return zone.runGuarded(body); |
5863 } else { | 5863 } else { |
5864 return zone.run(body); | 5864 return zone.run(body); |
5865 } | 5865 } |
5866 } | 5866 } |
5867 dart.fn(runZoned, core.Object, [dart.functionType(core.Object, [])], {oneValue
: core.Map, oneSpecificatio: ZoneSpecification, nErro: core.Function}); | 5867 dart.fn(runZoned, core.Object, [dart.functionType(core.Object, [])], {zoneValu
es: core.Map, zoneSpecification: ZoneSpecification, onError: core.Function}); |
5868 let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.v
oid, [Timer])); | 5868 let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.v
oid, [Timer])); |
5869 let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(core.O
bject, [dart.bottom])); | 5869 let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(core.O
bject, [dart.bottom])); |
5870 dart.copyProperties(exports, { | 5870 dart.copyProperties(exports, { |
5871 get _hasDocument() { | 5871 get _hasDocument() { |
5872 return typeof document == 'object'; | 5872 return typeof document == 'object'; |
5873 } | 5873 } |
5874 }); | 5874 }); |
5875 // Exports: | 5875 // Exports: |
5876 exports.AsyncError = AsyncError; | 5876 exports.AsyncError = AsyncError; |
5877 exports.Stream$ = Stream$; | 5877 exports.Stream$ = Stream$; |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5915 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5915 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5916 exports.CreateTimerHandler = CreateTimerHandler; | 5916 exports.CreateTimerHandler = CreateTimerHandler; |
5917 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5917 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5918 exports.PrintHandler = PrintHandler; | 5918 exports.PrintHandler = PrintHandler; |
5919 exports.ForkHandler = ForkHandler; | 5919 exports.ForkHandler = ForkHandler; |
5920 exports.ZoneSpecification = ZoneSpecification; | 5920 exports.ZoneSpecification = ZoneSpecification; |
5921 exports.ZoneDelegate = ZoneDelegate; | 5921 exports.ZoneDelegate = ZoneDelegate; |
5922 exports.Zone = Zone; | 5922 exports.Zone = Zone; |
5923 exports.runZoned = runZoned; | 5923 exports.runZoned = runZoned; |
5924 })(async, core, _internal, _js_helper, _isolate_helper, collection); | 5924 })(async, core, _internal, _js_helper, _isolate_helper, collection); |
OLD | NEW |