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

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

Issue 1145283002: Use short array syntax in method signatures (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 7 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 = 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 15 matching lines...) Expand all
26 AsyncError(error, stackTrace) { 26 AsyncError(error, stackTrace) {
27 this.error = error; 27 this.error = error;
28 this.stackTrace = stackTrace; 28 this.stackTrace = stackTrace;
29 } 29 }
30 toString() { 30 toString() {
31 return dart.toString(this.error); 31 return dart.toString(this.error);
32 } 32 }
33 } 33 }
34 AsyncError[dart.implements] = () => [core.Error]; 34 AsyncError[dart.implements] = () => [core.Error];
35 dart.setSignature(AsyncError, { 35 dart.setSignature(AsyncError, {
36 methods: () => ({toString: dart.functionType(core.String, [])}) 36 methods: () => ({toString: [core.String, []]})
37 }); 37 });
38 class _UncaughtAsyncError extends AsyncError { 38 class _UncaughtAsyncError extends AsyncError {
39 _UncaughtAsyncError(error, stackTrace) { 39 _UncaughtAsyncError(error, stackTrace) {
40 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac kTrace)); 40 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac kTrace));
41 } 41 }
42 static _getBestStackTrace(error, stackTrace) { 42 static _getBestStackTrace(error, stackTrace) {
43 if (stackTrace != null) 43 if (stackTrace != null)
44 return stackTrace; 44 return stackTrace;
45 if (dart.is(error, core.Error)) { 45 if (dart.is(error, core.Error)) {
46 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); 46 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace);
47 } 47 }
48 return null; 48 return null;
49 } 49 }
50 toString() { 50 toString() {
51 let result = `Uncaught Error: ${this.error}`; 51 let result = `Uncaught Error: ${this.error}`;
52 if (this.stackTrace != null) { 52 if (this.stackTrace != null) {
53 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; 53 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`;
54 } 54 }
55 return result; 55 return result;
56 } 56 }
57 } 57 }
58 dart.setSignature(_UncaughtAsyncError, { 58 dart.setSignature(_UncaughtAsyncError, {
59 methods: () => ({toString: dart.functionType(core.String, [])}), 59 methods: () => ({toString: [core.String, []]}),
60 statics: () => ({_getBestStackTrace: dart.functionType(core.StackTrace, [dar t.dynamic, core.StackTrace])}), 60 statics: () => ({_getBestStackTrace: [core.StackTrace, [dart.dynamic, core.S tackTrace]]}),
61 names: ['_getBestStackTrace'] 61 names: ['_getBestStackTrace']
62 }); 62 });
63 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn amic, [dart.dynamic])); 63 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn amic, [dart.dynamic]));
64 let _add = Symbol('_add'); 64 let _add = Symbol('_add');
65 let _closeUnchecked = Symbol('_closeUnchecked'); 65 let _closeUnchecked = Symbol('_closeUnchecked');
66 let _addError = Symbol('_addError'); 66 let _addError = Symbol('_addError');
67 let _completeError = Symbol('_completeError'); 67 let _completeError = Symbol('_completeError');
68 let _complete = Symbol('_complete'); 68 let _complete = Symbol('_complete');
69 let _sink = Symbol('_sink'); 69 let _sink = Symbol('_sink');
70 let Stream$ = dart.generic(function(T) { 70 let Stream$ = dart.generic(function(T) {
(...skipping 646 matching lines...) Expand 10 before | Expand all | Expand 10 after
717 }), onCancel); 717 }), onCancel);
718 return controller.stream; 718 return controller.stream;
719 } 719 }
720 } 720 }
721 dart.defineNamedConstructor(Stream, 'fromFuture'); 721 dart.defineNamedConstructor(Stream, 'fromFuture');
722 dart.defineNamedConstructor(Stream, 'fromIterable'); 722 dart.defineNamedConstructor(Stream, 'fromIterable');
723 dart.defineNamedConstructor(Stream, 'periodic'); 723 dart.defineNamedConstructor(Stream, 'periodic');
724 dart.defineNamedConstructor(Stream, 'eventTransformed'); 724 dart.defineNamedConstructor(Stream, 'eventTransformed');
725 dart.setSignature(Stream, { 725 dart.setSignature(Stream, {
726 methods: () => ({ 726 methods: () => ({
727 asBroadcastStream: dart.functionType(Stream$(T), [], {nListe: dart.funct ionType(dart.void, [StreamSubscription$(T)]), nCance: dart.functionType(dart.voi d, [StreamSubscription$(T)])}), 727 asBroadcastStream: [Stream$(T), [], {nListe: dart.functionType(dart.void , [StreamSubscription$(T)]), nCance: dart.functionType(dart.void, [StreamSubscri ption$(T)])}],
728 where: dart.functionType(Stream$(T), [dart.functionType(core.bool, [T])] ), 728 where: [Stream$(T), [dart.functionType(core.bool, [T])]],
729 map: dart.functionType(Stream$(), [dart.functionType(dart.dynamic, [T])] ), 729 map: [Stream$(), [dart.functionType(dart.dynamic, [T])]],
730 asyncMap: dart.functionType(Stream$(), [dart.functionType(dart.dynamic, [T])]), 730 asyncMap: [Stream$(), [dart.functionType(dart.dynamic, [T])]],
731 asyncExpand: dart.functionType(Stream$(), [dart.functionType(Stream$(), [T])]), 731 asyncExpand: [Stream$(), [dart.functionType(Stream$(), [T])]],
732 handleError: dart.functionType(Stream$(T), [core.Function], {es: dart.fu nctionType(core.bool, [dart.dynamic])}), 732 handleError: [Stream$(T), [core.Function], {es: dart.functionType(core.b ool, [dart.dynamic])}],
733 expand: dart.functionType(Stream$(), [dart.functionType(core.Iterable, [ T])]), 733 expand: [Stream$(), [dart.functionType(core.Iterable, [T])]],
734 pipe: dart.functionType(Future, [StreamConsumer$(T)]), 734 pipe: [Future, [StreamConsumer$(T)]],
735 transform: dart.functionType(Stream$(), [StreamTransformer$(T, dart.dyna mic)]), 735 transform: [Stream$(), [StreamTransformer$(T, dart.dynamic)]],
736 reduce: dart.functionType(Future$(T), [dart.functionType(T, [T, T])]), 736 reduce: [Future$(T), [dart.functionType(T, [T, T])]],
737 fold: dart.functionType(Future, [dart.dynamic, dart.functionType(dart.dy namic, [dart.dynamic, T])]), 737 fold: [Future, [dart.dynamic, dart.functionType(dart.dynamic, [dart.dyna mic, T])]],
738 join: dart.functionType(Future$(core.String), [], [core.String]), 738 join: [Future$(core.String), [], [core.String]],
739 contains: dart.functionType(Future$(core.bool), [core.Object]), 739 contains: [Future$(core.bool), [core.Object]],
740 forEach: dart.functionType(Future, [dart.functionType(dart.void, [T])]), 740 forEach: [Future, [dart.functionType(dart.void, [T])]],
741 every: dart.functionType(Future$(core.bool), [dart.functionType(core.boo l, [T])]), 741 every: [Future$(core.bool), [dart.functionType(core.bool, [T])]],
742 any: dart.functionType(Future$(core.bool), [dart.functionType(core.bool, [T])]), 742 any: [Future$(core.bool), [dart.functionType(core.bool, [T])]],
743 toList: dart.functionType(Future$(core.List$(T)), []), 743 toList: [Future$(core.List$(T)), []],
744 toSet: dart.functionType(Future$(core.Set$(T)), []), 744 toSet: [Future$(core.Set$(T)), []],
745 drain: dart.functionType(Future, [], [dart.dynamic]), 745 drain: [Future, [], [dart.dynamic]],
746 take: dart.functionType(Stream$(T), [core.int]), 746 take: [Stream$(T), [core.int]],
747 takeWhile: dart.functionType(Stream$(T), [dart.functionType(core.bool, [ T])]), 747 takeWhile: [Stream$(T), [dart.functionType(core.bool, [T])]],
748 skip: dart.functionType(Stream$(T), [core.int]), 748 skip: [Stream$(T), [core.int]],
749 skipWhile: dart.functionType(Stream$(T), [dart.functionType(core.bool, [ T])]), 749 skipWhile: [Stream$(T), [dart.functionType(core.bool, [T])]],
750 distinct: dart.functionType(Stream$(T), [], [dart.functionType(core.bool , [T, T])]), 750 distinct: [Stream$(T), [], [dart.functionType(core.bool, [T, T])]],
751 firstWhere: dart.functionType(Future, [dart.functionType(core.bool, [T]) ], {efaultValu: dart.functionType(core.Object, [])}), 751 firstWhere: [Future, [dart.functionType(core.bool, [T])], {efaultValu: d art.functionType(core.Object, [])}],
752 lastWhere: dart.functionType(Future, [dart.functionType(core.bool, [T])] , {efaultValu: dart.functionType(core.Object, [])}), 752 lastWhere: [Future, [dart.functionType(core.bool, [T])], {efaultValu: da rt.functionType(core.Object, [])}],
753 singleWhere: dart.functionType(Future$(T), [dart.functionType(core.bool, [T])]), 753 singleWhere: [Future$(T), [dart.functionType(core.bool, [T])]],
754 elementAt: dart.functionType(Future$(T), [core.int]), 754 elementAt: [Future$(T), [core.int]],
755 timeout: dart.functionType(Stream$(), [core.Duration], {nTimeou: dart.fu nctionType(dart.void, [EventSink])}) 755 timeout: [Stream$(), [core.Duration], {nTimeou: dart.functionType(dart.v oid, [EventSink])}]
756 }) 756 })
757 }); 757 });
758 return Stream; 758 return Stream;
759 }); 759 });
760 let Stream = Stream$(); 760 let Stream = Stream$();
761 let _createSubscription = Symbol('_createSubscription'); 761 let _createSubscription = Symbol('_createSubscription');
762 let _onListen = Symbol('_onListen'); 762 let _onListen = Symbol('_onListen');
763 let _StreamImpl$ = dart.generic(function(T) { 763 let _StreamImpl$ = dart.generic(function(T) {
764 class _StreamImpl extends Stream$(T) { 764 class _StreamImpl extends Stream$(T) {
765 _StreamImpl() { 765 _StreamImpl() {
(...skipping 12 matching lines...) Expand all
778 } 778 }
779 [_createSubscription](onData, onError, onDone, cancelOnError) { 779 [_createSubscription](onData, onError, onDone, cancelOnError) {
780 dart.as(onData, dart.functionType(dart.void, [T])); 780 dart.as(onData, dart.functionType(dart.void, [T]));
781 dart.as(onDone, dart.functionType(dart.void, [])); 781 dart.as(onDone, dart.functionType(dart.void, []));
782 return new (_BufferingStreamSubscription$(T))(onData, onError, onDone, c ancelOnError); 782 return new (_BufferingStreamSubscription$(T))(onData, onError, onDone, c ancelOnError);
783 } 783 }
784 [_onListen](subscription) {} 784 [_onListen](subscription) {}
785 } 785 }
786 dart.setSignature(_StreamImpl, { 786 dart.setSignature(_StreamImpl, {
787 methods: () => ({ 787 methods: () => ({
788 listen: dart.functionType(StreamSubscription$(T), [dart.functionType(dar t.void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), an celOnErro: core.bool}), 788 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}],
789 [_createSubscription]: dart.functionType(StreamSubscription$(T), [dart.f unctionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), co re.bool]), 789 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart. void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]],
790 [_onListen]: dart.functionType(dart.void, [StreamSubscription]) 790 [_onListen]: [dart.void, [StreamSubscription]]
791 }) 791 })
792 }); 792 });
793 return _StreamImpl; 793 return _StreamImpl;
794 }); 794 });
795 let _StreamImpl = _StreamImpl$(); 795 let _StreamImpl = _StreamImpl$();
796 let _controller = Symbol('_controller'); 796 let _controller = Symbol('_controller');
797 let _subscribe = Symbol('_subscribe'); 797 let _subscribe = Symbol('_subscribe');
798 let _ControllerStream$ = dart.generic(function(T) { 798 let _ControllerStream$ = dart.generic(function(T) {
799 class _ControllerStream extends _StreamImpl$(T) { 799 class _ControllerStream extends _StreamImpl$(T) {
800 _ControllerStream(controller) { 800 _ControllerStream(controller) {
(...skipping 11 matching lines...) Expand all
812 if (core.identical(this, other)) 812 if (core.identical(this, other))
813 return true; 813 return true;
814 if (!dart.is(other, _ControllerStream$())) 814 if (!dart.is(other, _ControllerStream$()))
815 return false; 815 return false;
816 let otherStream = dart.as(other, _ControllerStream$()); 816 let otherStream = dart.as(other, _ControllerStream$());
817 return core.identical(otherStream[_controller], this[_controller]); 817 return core.identical(otherStream[_controller], this[_controller]);
818 } 818 }
819 } 819 }
820 dart.setSignature(_ControllerStream, { 820 dart.setSignature(_ControllerStream, {
821 methods: () => ({ 821 methods: () => ({
822 [_createSubscription]: dart.functionType(StreamSubscription$(T), [dart.f unctionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), co re.bool]), 822 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart. void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]],
823 '==': dart.functionType(core.bool, [core.Object]) 823 '==': [core.bool, [core.Object]]
824 }) 824 })
825 }); 825 });
826 return _ControllerStream; 826 return _ControllerStream;
827 }); 827 });
828 let _ControllerStream = _ControllerStream$(); 828 let _ControllerStream = _ControllerStream$();
829 let _BroadcastStream$ = dart.generic(function(T) { 829 let _BroadcastStream$ = dart.generic(function(T) {
830 class _BroadcastStream extends _ControllerStream$(T) { 830 class _BroadcastStream extends _ControllerStream$(T) {
831 _BroadcastStream(controller) { 831 _BroadcastStream(controller) {
832 super._ControllerStream(dart.as(controller, _StreamControllerLifecycle$( T))); 832 super._ControllerStream(dart.as(controller, _StreamControllerLifecycle$( T)));
833 } 833 }
(...skipping 342 matching lines...) Expand 10 before | Expand all | Expand 10 after
1176 wasInputPaused = isInputPaused; 1176 wasInputPaused = isInputPaused;
1177 } 1177 }
1178 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) { 1178 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) {
1179 this[_pending].schedule(this); 1179 this[_pending].schedule(this);
1180 } 1180 }
1181 } 1181 }
1182 } 1182 }
1183 _BufferingStreamSubscription[dart.implements] = () => [StreamSubscription$(T ), _EventSink$(T), _EventDispatch$(T)]; 1183 _BufferingStreamSubscription[dart.implements] = () => [StreamSubscription$(T ), _EventSink$(T), _EventDispatch$(T)];
1184 dart.setSignature(_BufferingStreamSubscription, { 1184 dart.setSignature(_BufferingStreamSubscription, {
1185 methods: () => ({ 1185 methods: () => ({
1186 [_setPendingEvents]: dart.functionType(dart.void, [_PendingEvents]), 1186 [_setPendingEvents]: [dart.void, [_PendingEvents]],
1187 [_extractPending]: dart.functionType(_PendingEvents, []), 1187 [_extractPending]: [_PendingEvents, []],
1188 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])] ), 1188 onData: [dart.void, [dart.functionType(dart.void, [T])]],
1189 onError: dart.functionType(dart.void, [core.Function]), 1189 onError: [dart.void, [core.Function]],
1190 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])]) , 1190 onDone: [dart.void, [dart.functionType(dart.void, [])]],
1191 pause: dart.functionType(dart.void, [], [Future]), 1191 pause: [dart.void, [], [Future]],
1192 resume: dart.functionType(dart.void, []), 1192 resume: [dart.void, []],
1193 cancel: dart.functionType(Future, []), 1193 cancel: [Future, []],
1194 asFuture: dart.functionType(Future, [], [dart.dynamic]), 1194 asFuture: [Future, [], [dart.dynamic]],
1195 [_cancel]: dart.functionType(dart.void, []), 1195 [_cancel]: [dart.void, []],
1196 [_incrementPauseCount]: dart.functionType(dart.void, []), 1196 [_incrementPauseCount]: [dart.void, []],
1197 [_decrementPauseCount]: dart.functionType(dart.void, []), 1197 [_decrementPauseCount]: [dart.void, []],
1198 [_add]: dart.functionType(dart.void, [T]), 1198 [_add]: [dart.void, [T]],
1199 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace] ), 1199 [_addError]: [dart.void, [core.Object, core.StackTrace]],
1200 [_close]: dart.functionType(dart.void, []), 1200 [_close]: [dart.void, []],
1201 [_onPause]: dart.functionType(dart.void, []), 1201 [_onPause]: [dart.void, []],
1202 [_onResume]: dart.functionType(dart.void, []), 1202 [_onResume]: [dart.void, []],
1203 [_onCancel]: dart.functionType(Future, []), 1203 [_onCancel]: [Future, []],
1204 [_addPending]: dart.functionType(dart.void, [_DelayedEvent]), 1204 [_addPending]: [dart.void, [_DelayedEvent]],
1205 [_sendData]: dart.functionType(dart.void, [T]), 1205 [_sendData]: [dart.void, [T]],
1206 [_sendError]: dart.functionType(dart.void, [core.Object, core.StackTrace ]), 1206 [_sendError]: [dart.void, [core.Object, core.StackTrace]],
1207 [_sendDone]: dart.functionType(dart.void, []), 1207 [_sendDone]: [dart.void, []],
1208 [_guardCallback]: dart.functionType(dart.void, [dart.dynamic]), 1208 [_guardCallback]: [dart.void, [dart.dynamic]],
1209 [_checkState]: dart.functionType(dart.void, [core.bool]) 1209 [_checkState]: [dart.void, [core.bool]]
1210 }) 1210 })
1211 }); 1211 });
1212 return _BufferingStreamSubscription; 1212 return _BufferingStreamSubscription;
1213 }); 1213 });
1214 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); 1214 let _BufferingStreamSubscription = _BufferingStreamSubscription$();
1215 let _recordCancel = Symbol('_recordCancel'); 1215 let _recordCancel = Symbol('_recordCancel');
1216 let _recordPause = Symbol('_recordPause'); 1216 let _recordPause = Symbol('_recordPause');
1217 let _recordResume = Symbol('_recordResume'); 1217 let _recordResume = Symbol('_recordResume');
1218 let _ControllerSubscription$ = dart.generic(function(T) { 1218 let _ControllerSubscription$ = dart.generic(function(T) {
1219 class _ControllerSubscription extends _BufferingStreamSubscription$(T) { 1219 class _ControllerSubscription extends _BufferingStreamSubscription$(T) {
1220 _ControllerSubscription(controller, onData, onError, onDone, cancelOnError ) { 1220 _ControllerSubscription(controller, onData, onError, onDone, cancelOnError ) {
1221 this[_controller] = controller; 1221 this[_controller] = controller;
1222 super._BufferingStreamSubscription(onData, onError, onDone, cancelOnErro r); 1222 super._BufferingStreamSubscription(onData, onError, onDone, cancelOnErro r);
1223 } 1223 }
1224 [_onCancel]() { 1224 [_onCancel]() {
1225 return this[_controller][_recordCancel](this); 1225 return this[_controller][_recordCancel](this);
1226 } 1226 }
1227 [_onPause]() { 1227 [_onPause]() {
1228 this[_controller][_recordPause](this); 1228 this[_controller][_recordPause](this);
1229 } 1229 }
1230 [_onResume]() { 1230 [_onResume]() {
1231 this[_controller][_recordResume](this); 1231 this[_controller][_recordResume](this);
1232 } 1232 }
1233 } 1233 }
1234 dart.setSignature(_ControllerSubscription, { 1234 dart.setSignature(_ControllerSubscription, {
1235 methods: () => ({ 1235 methods: () => ({
1236 [_onCancel]: dart.functionType(Future, []), 1236 [_onCancel]: [Future, []],
1237 [_onPause]: dart.functionType(dart.void, []), 1237 [_onPause]: [dart.void, []],
1238 [_onResume]: dart.functionType(dart.void, []) 1238 [_onResume]: [dart.void, []]
1239 }) 1239 })
1240 }); 1240 });
1241 return _ControllerSubscription; 1241 return _ControllerSubscription;
1242 }); 1242 });
1243 let _ControllerSubscription = _ControllerSubscription$(); 1243 let _ControllerSubscription = _ControllerSubscription$();
1244 let _eventState = Symbol('_eventState'); 1244 let _eventState = Symbol('_eventState');
1245 let _expectsEvent = Symbol('_expectsEvent'); 1245 let _expectsEvent = Symbol('_expectsEvent');
1246 let _toggleEventId = Symbol('_toggleEventId'); 1246 let _toggleEventId = Symbol('_toggleEventId');
1247 let _isFiring = Symbol('_isFiring'); 1247 let _isFiring = Symbol('_isFiring');
1248 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); 1248 let _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring');
(...skipping 25 matching lines...) Expand all
1274 } 1274 }
1275 get [_removeAfterFiring]() { 1275 get [_removeAfterFiring]() {
1276 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri ption$()._STATE_REMOVE_AFTER_FIRING)) != 0; 1276 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri ption$()._STATE_REMOVE_AFTER_FIRING)) != 0;
1277 } 1277 }
1278 [_onPause]() {} 1278 [_onPause]() {}
1279 [_onResume]() {} 1279 [_onResume]() {}
1280 } 1280 }
1281 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink] ; 1281 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink] ;
1282 dart.setSignature(_BroadcastSubscription, { 1282 dart.setSignature(_BroadcastSubscription, {
1283 methods: () => ({ 1283 methods: () => ({
1284 [_expectsEvent]: dart.functionType(core.bool, [core.int]), 1284 [_expectsEvent]: [core.bool, [core.int]],
1285 [_toggleEventId]: dart.functionType(dart.void, []), 1285 [_toggleEventId]: [dart.void, []],
1286 [_setRemoveAfterFiring]: dart.functionType(dart.void, []), 1286 [_setRemoveAfterFiring]: [dart.void, []],
1287 [_onPause]: dart.functionType(dart.void, []), 1287 [_onPause]: [dart.void, []],
1288 [_onResume]: dart.functionType(dart.void, []) 1288 [_onResume]: [dart.void, []]
1289 }) 1289 })
1290 }); 1290 });
1291 return _BroadcastSubscription; 1291 return _BroadcastSubscription;
1292 }); 1292 });
1293 let _BroadcastSubscription = _BroadcastSubscription$(); 1293 let _BroadcastSubscription = _BroadcastSubscription$();
1294 _BroadcastSubscription._STATE_EVENT_ID = 1; 1294 _BroadcastSubscription._STATE_EVENT_ID = 1;
1295 _BroadcastSubscription._STATE_FIRING = 2; 1295 _BroadcastSubscription._STATE_FIRING = 2;
1296 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; 1296 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4;
1297 let _addStreamState = Symbol('_addStreamState'); 1297 let _addStreamState = Symbol('_addStreamState');
1298 let _doneFuture = Symbol('_doneFuture'); 1298 let _doneFuture = Symbol('_doneFuture');
(...skipping 211 matching lines...) Expand 10 before | Expand all | Expand 10 after
1510 dart.assert(this[_isEmpty]); 1510 dart.assert(this[_isEmpty]);
1511 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo mplete])) { 1511 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo mplete])) {
1512 this[_doneFuture][_asyncComplete](null); 1512 this[_doneFuture][_asyncComplete](null);
1513 } 1513 }
1514 _runGuarded(this[_onCancel]); 1514 _runGuarded(this[_onCancel]);
1515 } 1515 }
1516 } 1516 }
1517 _BroadcastStreamController[dart.implements] = () => [StreamController$(T), _ StreamControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _Even tDispatch$(T)]; 1517 _BroadcastStreamController[dart.implements] = () => [StreamController$(T), _ StreamControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _Even tDispatch$(T)];
1518 dart.setSignature(_BroadcastStreamController, { 1518 dart.setSignature(_BroadcastStreamController, {
1519 methods: () => ({ 1519 methods: () => ({
1520 [_ensureDoneFuture]: dart.functionType(_Future, []), 1520 [_ensureDoneFuture]: [_Future, []],
1521 [_addListener]: dart.functionType(dart.void, [_BroadcastSubscription$(T) ]), 1521 [_addListener]: [dart.void, [_BroadcastSubscription$(T)]],
1522 [_removeListener]: dart.functionType(dart.void, [_BroadcastSubscription$ (T)]), 1522 [_removeListener]: [dart.void, [_BroadcastSubscription$(T)]],
1523 [_subscribe]: dart.functionType(StreamSubscription$(T), [dart.functionTy pe(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]) , 1523 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T] ), core.Function, dart.functionType(dart.void, []), core.bool]],
1524 [_recordCancel]: dart.functionType(Future, [StreamSubscription$(T)]), 1524 [_recordCancel]: [Future, [StreamSubscription$(T)]],
1525 [_recordPause]: dart.functionType(dart.void, [StreamSubscription$(T)]), 1525 [_recordPause]: [dart.void, [StreamSubscription$(T)]],
1526 [_recordResume]: dart.functionType(dart.void, [StreamSubscription$(T)]), 1526 [_recordResume]: [dart.void, [StreamSubscription$(T)]],
1527 [_addEventError]: dart.functionType(core.Error, []), 1527 [_addEventError]: [core.Error, []],
1528 add: dart.functionType(dart.void, [T]), 1528 add: [dart.void, [T]],
1529 addError: dart.functionType(dart.void, [core.Object], [core.StackTrace]) , 1529 addError: [dart.void, [core.Object], [core.StackTrace]],
1530 close: dart.functionType(Future, []), 1530 close: [Future, []],
1531 addStream: dart.functionType(Future, [Stream$(T)], {ancelOnErro: core.bo ol}), 1531 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}],
1532 [_add]: dart.functionType(dart.void, [T]), 1532 [_add]: [dart.void, [T]],
1533 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace] ), 1533 [_addError]: [dart.void, [core.Object, core.StackTrace]],
1534 [_close]: dart.functionType(dart.void, []), 1534 [_close]: [dart.void, []],
1535 [_forEachListener]: dart.functionType(dart.void, [dart.functionType(dart .void, [_BufferingStreamSubscription$(T)])]), 1535 [_forEachListener]: [dart.void, [dart.functionType(dart.void, [_Bufferin gStreamSubscription$(T)])]],
1536 [_callOnCancel]: dart.functionType(dart.void, []) 1536 [_callOnCancel]: [dart.void, []]
1537 }) 1537 })
1538 }); 1538 });
1539 return _BroadcastStreamController; 1539 return _BroadcastStreamController;
1540 }); 1540 });
1541 let _BroadcastStreamController = _BroadcastStreamController$(); 1541 let _BroadcastStreamController = _BroadcastStreamController$();
1542 _BroadcastStreamController._STATE_INITIAL = 0; 1542 _BroadcastStreamController._STATE_INITIAL = 0;
1543 _BroadcastStreamController._STATE_EVENT_ID = 1; 1543 _BroadcastStreamController._STATE_EVENT_ID = 1;
1544 _BroadcastStreamController._STATE_FIRING = 2; 1544 _BroadcastStreamController._STATE_FIRING = 2;
1545 _BroadcastStreamController._STATE_CLOSED = 4; 1545 _BroadcastStreamController._STATE_CLOSED = 4;
1546 _BroadcastStreamController._STATE_ADDSTREAM = 8; 1546 _BroadcastStreamController._STATE_ADDSTREAM = 8;
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after
1584 }, dart.dynamic, [_BroadcastSubscription$(T)]), __CastType2)); 1584 }, dart.dynamic, [_BroadcastSubscription$(T)]), __CastType2));
1585 } else { 1585 } else {
1586 dart.assert(this[_doneFuture] != null); 1586 dart.assert(this[_doneFuture] != null);
1587 dart.assert(this[_doneFuture][_mayComplete]); 1587 dart.assert(this[_doneFuture][_mayComplete]);
1588 this[_doneFuture][_asyncComplete](null); 1588 this[_doneFuture][_asyncComplete](null);
1589 } 1589 }
1590 } 1590 }
1591 } 1591 }
1592 dart.setSignature(_SyncBroadcastStreamController, { 1592 dart.setSignature(_SyncBroadcastStreamController, {
1593 methods: () => ({ 1593 methods: () => ({
1594 [_sendData]: dart.functionType(dart.void, [T]), 1594 [_sendData]: [dart.void, [T]],
1595 [_sendError]: dart.functionType(dart.void, [core.Object, core.StackTrace ]), 1595 [_sendError]: [dart.void, [core.Object, core.StackTrace]],
1596 [_sendDone]: dart.functionType(dart.void, []) 1596 [_sendDone]: [dart.void, []]
1597 }) 1597 })
1598 }); 1598 });
1599 return _SyncBroadcastStreamController; 1599 return _SyncBroadcastStreamController;
1600 }); 1600 });
1601 let _SyncBroadcastStreamController = _SyncBroadcastStreamController$(); 1601 let _SyncBroadcastStreamController = _SyncBroadcastStreamController$();
1602 let _AsyncBroadcastStreamController$ = dart.generic(function(T) { 1602 let _AsyncBroadcastStreamController$ = dart.generic(function(T) {
1603 class _AsyncBroadcastStreamController extends _BroadcastStreamController$(T) { 1603 class _AsyncBroadcastStreamController extends _BroadcastStreamController$(T) {
1604 _AsyncBroadcastStreamController(onListen, onCancel) { 1604 _AsyncBroadcastStreamController(onListen, onCancel) {
1605 super._BroadcastStreamController(onListen, onCancel); 1605 super._BroadcastStreamController(onListen, onCancel);
1606 } 1606 }
(...skipping 18 matching lines...) Expand all
1625 } 1625 }
1626 } else { 1626 } else {
1627 dart.assert(this[_doneFuture] != null); 1627 dart.assert(this[_doneFuture] != null);
1628 dart.assert(this[_doneFuture][_mayComplete]); 1628 dart.assert(this[_doneFuture][_mayComplete]);
1629 this[_doneFuture][_asyncComplete](null); 1629 this[_doneFuture][_asyncComplete](null);
1630 } 1630 }
1631 } 1631 }
1632 } 1632 }
1633 dart.setSignature(_AsyncBroadcastStreamController, { 1633 dart.setSignature(_AsyncBroadcastStreamController, {
1634 methods: () => ({ 1634 methods: () => ({
1635 [_sendData]: dart.functionType(dart.void, [T]), 1635 [_sendData]: [dart.void, [T]],
1636 [_sendError]: dart.functionType(dart.void, [core.Object, core.StackTrace ]), 1636 [_sendError]: [dart.void, [core.Object, core.StackTrace]],
1637 [_sendDone]: dart.functionType(dart.void, []) 1637 [_sendDone]: [dart.void, []]
1638 }) 1638 })
1639 }); 1639 });
1640 return _AsyncBroadcastStreamController; 1640 return _AsyncBroadcastStreamController;
1641 }); 1641 });
1642 let _AsyncBroadcastStreamController = _AsyncBroadcastStreamController$(); 1642 let _AsyncBroadcastStreamController = _AsyncBroadcastStreamController$();
1643 let _addPendingEvent = Symbol('_addPendingEvent'); 1643 let _addPendingEvent = Symbol('_addPendingEvent');
1644 let _AsBroadcastStreamController$ = dart.generic(function(T) { 1644 let _AsBroadcastStreamController$ = dart.generic(function(T) {
1645 class _AsBroadcastStreamController extends _SyncBroadcastStreamController$(T ) { 1645 class _AsBroadcastStreamController extends _SyncBroadcastStreamController$(T ) {
1646 _AsBroadcastStreamController(onListen, onCancel) { 1646 _AsBroadcastStreamController(onListen, onCancel) {
1647 this[_pending] = null; 1647 this[_pending] = null;
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after
1695 if (this[_hasPending]) { 1695 if (this[_hasPending]) {
1696 this[_pending].clear(); 1696 this[_pending].clear();
1697 this[_pending] = null; 1697 this[_pending] = null;
1698 } 1698 }
1699 super[_callOnCancel](); 1699 super[_callOnCancel]();
1700 } 1700 }
1701 } 1701 }
1702 _AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)]; 1702 _AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)];
1703 dart.setSignature(_AsBroadcastStreamController, { 1703 dart.setSignature(_AsBroadcastStreamController, {
1704 methods: () => ({ 1704 methods: () => ({
1705 [_addPendingEvent]: dart.functionType(dart.void, [_DelayedEvent]), 1705 [_addPendingEvent]: [dart.void, [_DelayedEvent]],
1706 add: dart.functionType(dart.void, [T]), 1706 add: [dart.void, [T]],
1707 addError: dart.functionType(dart.void, [core.Object], [core.StackTrace]) , 1707 addError: [dart.void, [core.Object], [core.StackTrace]],
1708 close: dart.functionType(Future, []), 1708 close: [Future, []],
1709 [_callOnCancel]: dart.functionType(dart.void, []) 1709 [_callOnCancel]: [dart.void, []]
1710 }) 1710 })
1711 }); 1711 });
1712 return _AsBroadcastStreamController; 1712 return _AsBroadcastStreamController;
1713 }); 1713 });
1714 let _AsBroadcastStreamController = _AsBroadcastStreamController$(); 1714 let _AsBroadcastStreamController = _AsBroadcastStreamController$();
1715 let _pauseCount = Symbol('_pauseCount'); 1715 let _pauseCount = Symbol('_pauseCount');
1716 let _resume = Symbol('_resume'); 1716 let _resume = Symbol('_resume');
1717 let _DoneSubscription$ = dart.generic(function(T) { 1717 let _DoneSubscription$ = dart.generic(function(T) {
1718 class _DoneSubscription extends core.Object { 1718 class _DoneSubscription extends core.Object {
1719 _DoneSubscription() { 1719 _DoneSubscription() {
(...skipping 29 matching lines...) Expand all
1749 } 1749 }
1750 asFuture(value) { 1750 asFuture(value) {
1751 if (value === void 0) 1751 if (value === void 0)
1752 value = null; 1752 value = null;
1753 return new _Future(); 1753 return new _Future();
1754 } 1754 }
1755 } 1755 }
1756 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; 1756 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)];
1757 dart.setSignature(_DoneSubscription, { 1757 dart.setSignature(_DoneSubscription, {
1758 methods: () => ({ 1758 methods: () => ({
1759 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])] ), 1759 onData: [dart.void, [dart.functionType(dart.void, [T])]],
1760 onError: dart.functionType(dart.void, [core.Function]), 1760 onError: [dart.void, [core.Function]],
1761 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])]) , 1761 onDone: [dart.void, [dart.functionType(dart.void, [])]],
1762 pause: dart.functionType(dart.void, [], [Future]), 1762 pause: [dart.void, [], [Future]],
1763 resume: dart.functionType(dart.void, []), 1763 resume: [dart.void, []],
1764 [_resume]: dart.functionType(dart.void, [dart.dynamic]), 1764 [_resume]: [dart.void, [dart.dynamic]],
1765 cancel: dart.functionType(Future, []), 1765 cancel: [Future, []],
1766 asFuture: dart.functionType(Future, [], [core.Object]) 1766 asFuture: [Future, [], [core.Object]]
1767 }) 1767 })
1768 }); 1768 });
1769 return _DoneSubscription; 1769 return _DoneSubscription;
1770 }); 1770 });
1771 let _DoneSubscription = _DoneSubscription$(); 1771 let _DoneSubscription = _DoneSubscription$();
1772 let __CastType2$ = dart.generic(function(T) { 1772 let __CastType2$ = dart.generic(function(T) {
1773 let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.v oid, [_BufferingStreamSubscription$(T)])); 1773 let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.v oid, [_BufferingStreamSubscription$(T)]));
1774 return __CastType2; 1774 return __CastType2;
1775 }); 1775 });
1776 let __CastType2 = __CastType2$(); 1776 let __CastType2 = __CastType2$();
1777 class DeferredLibrary extends core.Object { 1777 class DeferredLibrary extends core.Object {
1778 DeferredLibrary(libraryName, opts) { 1778 DeferredLibrary(libraryName, opts) {
1779 let uri = opts && 'uri' in opts ? opts.uri : null; 1779 let uri = opts && 'uri' in opts ? opts.uri : null;
1780 this.libraryName = libraryName; 1780 this.libraryName = libraryName;
1781 this.uri = uri; 1781 this.uri = uri;
1782 } 1782 }
1783 load() { 1783 load() {
1784 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar t" deferred as lib` syntax.'; 1784 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar t" deferred as lib` syntax.';
1785 } 1785 }
1786 } 1786 }
1787 dart.setSignature(DeferredLibrary, { 1787 dart.setSignature(DeferredLibrary, {
1788 methods: () => ({load: dart.functionType(Future$(core.Null), [])}) 1788 methods: () => ({load: [Future$(core.Null), []]})
1789 }); 1789 });
1790 let _s = Symbol('_s'); 1790 let _s = Symbol('_s');
1791 class DeferredLoadException extends core.Object { 1791 class DeferredLoadException extends core.Object {
1792 DeferredLoadException(s) { 1792 DeferredLoadException(s) {
1793 this[_s] = s; 1793 this[_s] = s;
1794 } 1794 }
1795 toString() { 1795 toString() {
1796 return `DeferredLoadException: '${this[_s]}'`; 1796 return `DeferredLoadException: '${this[_s]}'`;
1797 } 1797 }
1798 } 1798 }
1799 DeferredLoadException[dart.implements] = () => [core.Exception]; 1799 DeferredLoadException[dart.implements] = () => [core.Exception];
1800 dart.setSignature(DeferredLoadException, { 1800 dart.setSignature(DeferredLoadException, {
1801 methods: () => ({toString: dart.functionType(core.String, [])}) 1801 methods: () => ({toString: [core.String, []]})
1802 }); 1802 });
1803 let _completeWithValue = Symbol('_completeWithValue'); 1803 let _completeWithValue = Symbol('_completeWithValue');
1804 let Future$ = dart.generic(function(T) { 1804 let Future$ = dart.generic(function(T) {
1805 class Future extends core.Object { 1805 class Future extends core.Object {
1806 Future(computation) { 1806 Future(computation) {
1807 let result = new (_Future$(T))(); 1807 let result = new (_Future$(T))();
1808 Timer.run(dart.fn(() => { 1808 Timer.run(dart.fn(() => {
1809 try { 1809 try {
1810 result[_complete](computation()); 1810 result[_complete](computation());
1811 } catch (e) { 1811 } catch (e) {
(...skipping 145 matching lines...) Expand 10 before | Expand all | Expand 10 after
1957 return doneSignal; 1957 return doneSignal;
1958 } 1958 }
1959 } 1959 }
1960 dart.defineNamedConstructor(Future, 'microtask'); 1960 dart.defineNamedConstructor(Future, 'microtask');
1961 dart.defineNamedConstructor(Future, 'sync'); 1961 dart.defineNamedConstructor(Future, 'sync');
1962 dart.defineNamedConstructor(Future, 'value'); 1962 dart.defineNamedConstructor(Future, 'value');
1963 dart.defineNamedConstructor(Future, 'error'); 1963 dart.defineNamedConstructor(Future, 'error');
1964 dart.defineNamedConstructor(Future, 'delayed'); 1964 dart.defineNamedConstructor(Future, 'delayed');
1965 dart.setSignature(Future, { 1965 dart.setSignature(Future, {
1966 statics: () => ({ 1966 statics: () => ({
1967 wait: dart.functionType(Future$(core.List), [core.Iterable$(Future$())], {agerErro: core.bool, leanU: dart.functionType(dart.void, [dart.dynamic])}), 1967 wait: [Future$(core.List), [core.Iterable$(Future$())], {agerErro: core. bool, leanU: dart.functionType(dart.void, [dart.dynamic])}],
1968 forEach: dart.functionType(Future$(), [core.Iterable, dart.functionType( dart.dynamic, [dart.dynamic])]), 1968 forEach: [Future$(), [core.Iterable, dart.functionType(dart.dynamic, [da rt.dynamic])]],
1969 doWhile: dart.functionType(Future$(), [dart.functionType(dart.dynamic, [ ])]) 1969 doWhile: [Future$(), [dart.functionType(dart.dynamic, [])]]
1970 }), 1970 }),
1971 names: ['wait', 'forEach', 'doWhile'] 1971 names: ['wait', 'forEach', 'doWhile']
1972 }); 1972 });
1973 return Future; 1973 return Future;
1974 }); 1974 });
1975 let Future = Future$(); 1975 let Future = Future$();
1976 dart.defineLazyProperties(Future, { 1976 dart.defineLazyProperties(Future, {
1977 get _nullFuture() { 1977 get _nullFuture() {
1978 return new _Future.immediate(null); 1978 return new _Future.immediate(null);
1979 } 1979 }
1980 }); 1980 });
1981 class TimeoutException extends core.Object { 1981 class TimeoutException extends core.Object {
1982 TimeoutException(message, duration) { 1982 TimeoutException(message, duration) {
1983 if (duration === void 0) 1983 if (duration === void 0)
1984 duration = null; 1984 duration = null;
1985 this.message = message; 1985 this.message = message;
1986 this.duration = duration; 1986 this.duration = duration;
1987 } 1987 }
1988 toString() { 1988 toString() {
1989 let result = "TimeoutException"; 1989 let result = "TimeoutException";
1990 if (this.duration != null) 1990 if (this.duration != null)
1991 result = `TimeoutException after ${this.duration}`; 1991 result = `TimeoutException after ${this.duration}`;
1992 if (this.message != null) 1992 if (this.message != null)
1993 result = `${result}: ${this.message}`; 1993 result = `${result}: ${this.message}`;
1994 return result; 1994 return result;
1995 } 1995 }
1996 } 1996 }
1997 TimeoutException[dart.implements] = () => [core.Exception]; 1997 TimeoutException[dart.implements] = () => [core.Exception];
1998 dart.setSignature(TimeoutException, { 1998 dart.setSignature(TimeoutException, {
1999 methods: () => ({toString: dart.functionType(core.String, [])}) 1999 methods: () => ({toString: [core.String, []]})
2000 }); 2000 });
2001 let Completer$ = dart.generic(function(T) { 2001 let Completer$ = dart.generic(function(T) {
2002 class Completer extends core.Object { 2002 class Completer extends core.Object {
2003 Completer() { 2003 Completer() {
2004 return new (_AsyncCompleter$(T))(); 2004 return new (_AsyncCompleter$(T))();
2005 } 2005 }
2006 sync() { 2006 sync() {
2007 return new (_SyncCompleter$(T))(); 2007 return new (_SyncCompleter$(T))();
2008 } 2008 }
2009 } 2009 }
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
2050 stackTrace = replacement.stackTrace; 2050 stackTrace = replacement.stackTrace;
2051 } 2051 }
2052 this[_completeError](error, stackTrace); 2052 this[_completeError](error, stackTrace);
2053 } 2053 }
2054 get isCompleted() { 2054 get isCompleted() {
2055 return !dart.notNull(this.future[_mayComplete]); 2055 return !dart.notNull(this.future[_mayComplete]);
2056 } 2056 }
2057 } 2057 }
2058 _Completer[dart.implements] = () => [Completer$(T)]; 2058 _Completer[dart.implements] = () => [Completer$(T)];
2059 dart.setSignature(_Completer, { 2059 dart.setSignature(_Completer, {
2060 methods: () => ({completeError: dart.functionType(dart.void, [core.Object] , [core.StackTrace])}) 2060 methods: () => ({completeError: [dart.void, [core.Object], [core.StackTrac e]]})
2061 }); 2061 });
2062 return _Completer; 2062 return _Completer;
2063 }); 2063 });
2064 let _Completer = _Completer$(); 2064 let _Completer = _Completer$();
2065 let _asyncCompleteError = Symbol('_asyncCompleteError'); 2065 let _asyncCompleteError = Symbol('_asyncCompleteError');
2066 let _AsyncCompleter$ = dart.generic(function(T) { 2066 let _AsyncCompleter$ = dart.generic(function(T) {
2067 class _AsyncCompleter extends _Completer$(T) { 2067 class _AsyncCompleter extends _Completer$(T) {
2068 _AsyncCompleter() { 2068 _AsyncCompleter() {
2069 super._Completer(); 2069 super._Completer();
2070 } 2070 }
2071 complete(value) { 2071 complete(value) {
2072 if (value === void 0) 2072 if (value === void 0)
2073 value = null; 2073 value = null;
2074 if (!dart.notNull(this.future[_mayComplete])) 2074 if (!dart.notNull(this.future[_mayComplete]))
2075 throw new core.StateError("Future already completed"); 2075 throw new core.StateError("Future already completed");
2076 this.future[_asyncComplete](value); 2076 this.future[_asyncComplete](value);
2077 } 2077 }
2078 [_completeError](error, stackTrace) { 2078 [_completeError](error, stackTrace) {
2079 this.future[_asyncCompleteError](error, stackTrace); 2079 this.future[_asyncCompleteError](error, stackTrace);
2080 } 2080 }
2081 } 2081 }
2082 dart.setSignature(_AsyncCompleter, { 2082 dart.setSignature(_AsyncCompleter, {
2083 methods: () => ({ 2083 methods: () => ({
2084 complete: dart.functionType(dart.void, [], [dart.dynamic]), 2084 complete: [dart.void, [], [dart.dynamic]],
2085 [_completeError]: dart.functionType(dart.void, [core.Object, core.StackT race]) 2085 [_completeError]: [dart.void, [core.Object, core.StackTrace]]
2086 }) 2086 })
2087 }); 2087 });
2088 return _AsyncCompleter; 2088 return _AsyncCompleter;
2089 }); 2089 });
2090 let _AsyncCompleter = _AsyncCompleter$(); 2090 let _AsyncCompleter = _AsyncCompleter$();
2091 let _SyncCompleter$ = dart.generic(function(T) { 2091 let _SyncCompleter$ = dart.generic(function(T) {
2092 class _SyncCompleter extends _Completer$(T) { 2092 class _SyncCompleter extends _Completer$(T) {
2093 _SyncCompleter() { 2093 _SyncCompleter() {
2094 super._Completer(); 2094 super._Completer();
2095 } 2095 }
2096 complete(value) { 2096 complete(value) {
2097 if (value === void 0) 2097 if (value === void 0)
2098 value = null; 2098 value = null;
2099 if (!dart.notNull(this.future[_mayComplete])) 2099 if (!dart.notNull(this.future[_mayComplete]))
2100 throw new core.StateError("Future already completed"); 2100 throw new core.StateError("Future already completed");
2101 this.future[_complete](value); 2101 this.future[_complete](value);
2102 } 2102 }
2103 [_completeError](error, stackTrace) { 2103 [_completeError](error, stackTrace) {
2104 this.future[_completeError](error, stackTrace); 2104 this.future[_completeError](error, stackTrace);
2105 } 2105 }
2106 } 2106 }
2107 dart.setSignature(_SyncCompleter, { 2107 dart.setSignature(_SyncCompleter, {
2108 methods: () => ({ 2108 methods: () => ({
2109 complete: dart.functionType(dart.void, [], [dart.dynamic]), 2109 complete: [dart.void, [], [dart.dynamic]],
2110 [_completeError]: dart.functionType(dart.void, [core.Object, core.StackT race]) 2110 [_completeError]: [dart.void, [core.Object, core.StackTrace]]
2111 }) 2111 })
2112 }); 2112 });
2113 return _SyncCompleter; 2113 return _SyncCompleter;
2114 }); 2114 });
2115 let _SyncCompleter = _SyncCompleter$(); 2115 let _SyncCompleter = _SyncCompleter$();
2116 let _nextListener = Symbol('_nextListener'); 2116 let _nextListener = Symbol('_nextListener');
2117 let _onValue = Symbol('_onValue'); 2117 let _onValue = Symbol('_onValue');
2118 let _errorTest = Symbol('_errorTest'); 2118 let _errorTest = Symbol('_errorTest');
2119 let _whenCompleteAction = Symbol('_whenCompleteAction'); 2119 let _whenCompleteAction = Symbol('_whenCompleteAction');
2120 class _FutureListener extends core.Object { 2120 class _FutureListener extends core.Object {
(...skipping 499 matching lines...) Expand 10 before | Expand all | Expand 10 after
2620 } 2620 }
2621 })}); 2621 })});
2622 return result; 2622 return result;
2623 } 2623 }
2624 } 2624 }
2625 _Future[dart.implements] = () => [Future$(T)]; 2625 _Future[dart.implements] = () => [Future$(T)];
2626 dart.defineNamedConstructor(_Future, 'immediate'); 2626 dart.defineNamedConstructor(_Future, 'immediate');
2627 dart.defineNamedConstructor(_Future, 'immediateError'); 2627 dart.defineNamedConstructor(_Future, 'immediateError');
2628 dart.setSignature(_Future, { 2628 dart.setSignature(_Future, {
2629 methods: () => ({ 2629 methods: () => ({
2630 then: dart.functionType(Future, [dart.functionType(dart.dynamic, [T])], {nErro: core.Function}), 2630 then: [Future, [dart.functionType(dart.dynamic, [T])], {nErro: core.Func tion}],
2631 catchError: dart.functionType(Future, [core.Function], {es: dart.functio nType(core.bool, [dart.dynamic])}), 2631 catchError: [Future, [core.Function], {es: dart.functionType(core.bool, [dart.dynamic])}],
2632 whenComplete: dart.functionType(Future$(T), [dart.functionType(dart.dyna mic, [])]), 2632 whenComplete: [Future$(T), [dart.functionType(dart.dynamic, [])]],
2633 asStream: dart.functionType(Stream$(T), []), 2633 asStream: [Stream$(T), []],
2634 [_markPendingCompletion]: dart.functionType(dart.void, []), 2634 [_markPendingCompletion]: [dart.void, []],
2635 [_setValue]: dart.functionType(dart.void, [T]), 2635 [_setValue]: [dart.void, [T]],
2636 [_setErrorObject]: dart.functionType(dart.void, [AsyncError]), 2636 [_setErrorObject]: [dart.void, [AsyncError]],
2637 [_setError]: dart.functionType(dart.void, [core.Object, core.StackTrace] ), 2637 [_setError]: [dart.void, [core.Object, core.StackTrace]],
2638 [_addListener]: dart.functionType(dart.void, [_FutureListener]), 2638 [_addListener]: [dart.void, [_FutureListener]],
2639 [_removeListeners]: dart.functionType(_FutureListener, []), 2639 [_removeListeners]: [_FutureListener, []],
2640 [_complete]: dart.functionType(dart.void, [dart.dynamic]), 2640 [_complete]: [dart.void, [dart.dynamic]],
2641 [_completeWithValue]: dart.functionType(dart.void, [dart.dynamic]), 2641 [_completeWithValue]: [dart.void, [dart.dynamic]],
2642 [_completeError]: dart.functionType(dart.void, [dart.dynamic], [core.Sta ckTrace]), 2642 [_completeError]: [dart.void, [dart.dynamic], [core.StackTrace]],
2643 [_asyncComplete]: dart.functionType(dart.void, [dart.dynamic]), 2643 [_asyncComplete]: [dart.void, [dart.dynamic]],
2644 [_asyncCompleteError]: dart.functionType(dart.void, [dart.dynamic, core. StackTrace]), 2644 [_asyncCompleteError]: [dart.void, [dart.dynamic, core.StackTrace]],
2645 timeout: dart.functionType(Future, [core.Duration], {nTimeou: dart.funct ionType(dart.dynamic, [])}) 2645 timeout: [Future, [core.Duration], {nTimeou: dart.functionType(dart.dyna mic, [])}]
2646 }), 2646 }),
2647 statics: () => ({ 2647 statics: () => ({
2648 _chainForeignFuture: dart.functionType(dart.void, [Future, _Future$()]), 2648 _chainForeignFuture: [dart.void, [Future, _Future$()]],
2649 _chainCoreFuture: dart.functionType(dart.void, [_Future$(), _Future$()]) , 2649 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]],
2650 _propagateToListeners: dart.functionType(dart.void, [_Future$(), _Future Listener]) 2650 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]]
2651 }), 2651 }),
2652 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners' ] 2652 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners' ]
2653 }); 2653 });
2654 return _Future; 2654 return _Future;
2655 }); 2655 });
2656 let _Future = _Future$(); 2656 let _Future = _Future$();
2657 _Future._INCOMPLETE = 0; 2657 _Future._INCOMPLETE = 0;
2658 _Future._PENDING_COMPLETE = 1; 2658 _Future._PENDING_COMPLETE = 1;
2659 _Future._CHAINED = 2; 2659 _Future._CHAINED = 2;
2660 _Future._VALUE = 4; 2660 _Future._VALUE = 4;
(...skipping 132 matching lines...) Expand 10 before | Expand all | Expand 10 after
2793 ; 2793 ;
2794 _isolate_helper.enterJsAsync(); 2794 _isolate_helper.enterJsAsync();
2795 self.setImmediate(_js_helper.convertDartClosureToJS(internalCallback, 0)); 2795 self.setImmediate(_js_helper.convertDartClosureToJS(internalCallback, 0));
2796 } 2796 }
2797 static _scheduleImmediateWithTimer(callback) { 2797 static _scheduleImmediateWithTimer(callback) {
2798 Timer._createTimer(core.Duration.ZERO, callback); 2798 Timer._createTimer(core.Duration.ZERO, callback);
2799 } 2799 }
2800 } 2800 }
2801 dart.setSignature(_AsyncRun, { 2801 dart.setSignature(_AsyncRun, {
2802 statics: () => ({ 2802 statics: () => ({
2803 _scheduleImmediate: dart.functionType(dart.void, [dart.functionType(dart.v oid, [])]), 2803 _scheduleImmediate: [dart.void, [dart.functionType(dart.void, [])]],
2804 _initializeScheduleImmediate: dart.functionType(core.Function, []), 2804 _initializeScheduleImmediate: [core.Function, []],
2805 _scheduleImmediateJsOverride: dart.functionType(dart.void, [dart.functionT ype(dart.void, [])]), 2805 _scheduleImmediateJsOverride: [dart.void, [dart.functionType(dart.void, [] )]],
2806 _scheduleImmediateWithSetImmediate: dart.functionType(dart.void, [dart.fun ctionType(dart.void, [])]), 2806 _scheduleImmediateWithSetImmediate: [dart.void, [dart.functionType(dart.vo id, [])]],
2807 _scheduleImmediateWithTimer: dart.functionType(dart.void, [dart.functionTy pe(dart.void, [])]) 2807 _scheduleImmediateWithTimer: [dart.void, [dart.functionType(dart.void, []) ]]
2808 }), 2808 }),
2809 names: ['_scheduleImmediate', '_initializeScheduleImmediate', '_scheduleImme diateJsOverride', '_scheduleImmediateWithSetImmediate', '_scheduleImmediateWithT imer'] 2809 names: ['_scheduleImmediate', '_initializeScheduleImmediate', '_scheduleImme diateJsOverride', '_scheduleImmediateWithSetImmediate', '_scheduleImmediateWithT imer']
2810 }); 2810 });
2811 dart.defineLazyProperties(_AsyncRun, { 2811 dart.defineLazyProperties(_AsyncRun, {
2812 get scheduleImmediateClosure() { 2812 get scheduleImmediateClosure() {
2813 return _AsyncRun._initializeScheduleImmediate(); 2813 return _AsyncRun._initializeScheduleImmediate();
2814 } 2814 }
2815 }); 2815 });
2816 let StreamSubscription$ = dart.generic(function(T) { 2816 let StreamSubscription$ = dart.generic(function(T) {
2817 class StreamSubscription extends core.Object {} 2817 class StreamSubscription extends core.Object {}
(...skipping 29 matching lines...) Expand all
2847 dart.as(onData, dart.functionType(dart.void, [T])); 2847 dart.as(onData, dart.functionType(dart.void, [T]));
2848 let onError = opts && 'onError' in opts ? opts.onError : null; 2848 let onError = opts && 'onError' in opts ? opts.onError : null;
2849 let onDone = opts && 'onDone' in opts ? opts.onDone : null; 2849 let onDone = opts && 'onDone' in opts ? opts.onDone : null;
2850 dart.as(onDone, dart.functionType(dart.void, [])); 2850 dart.as(onDone, dart.functionType(dart.void, []));
2851 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null; 2851 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
2852 return this[_stream].listen(onData, {onError: onError, onDone: onDone, c ancelOnError: cancelOnError}); 2852 return this[_stream].listen(onData, {onError: onError, onDone: onDone, c ancelOnError: cancelOnError});
2853 } 2853 }
2854 } 2854 }
2855 dart.setSignature(StreamView, { 2855 dart.setSignature(StreamView, {
2856 methods: () => ({ 2856 methods: () => ({
2857 asBroadcastStream: dart.functionType(Stream$(T), [], {nListe: dart.funct ionType(dart.void, [StreamSubscription$(T)]), nCance: dart.functionType(dart.voi d, [StreamSubscription$(T)])}), 2857 asBroadcastStream: [Stream$(T), [], {nListe: dart.functionType(dart.void , [StreamSubscription$(T)]), nCance: dart.functionType(dart.void, [StreamSubscri ption$(T)])}],
2858 listen: dart.functionType(StreamSubscription$(T), [dart.functionType(dar t.void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), an celOnErro: core.bool}) 2858 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}]
2859 }) 2859 })
2860 }); 2860 });
2861 return StreamView; 2861 return StreamView;
2862 }); 2862 });
2863 let StreamView = StreamView$(); 2863 let StreamView = StreamView$();
2864 let StreamConsumer$ = dart.generic(function(S) { 2864 let StreamConsumer$ = dart.generic(function(S) {
2865 class StreamConsumer extends core.Object {} 2865 class StreamConsumer extends core.Object {}
2866 dart.setSignature(StreamConsumer, {}); 2866 dart.setSignature(StreamConsumer, {});
2867 return StreamConsumer; 2867 return StreamConsumer;
2868 }); 2868 });
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after
2912 stackTrace = null; 2912 stackTrace = null;
2913 this[_sink].addError(error, stackTrace); 2913 this[_sink].addError(error, stackTrace);
2914 } 2914 }
2915 close() { 2915 close() {
2916 this[_sink].close(); 2916 this[_sink].close();
2917 } 2917 }
2918 } 2918 }
2919 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; 2919 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)];
2920 dart.setSignature(_ControllerEventSinkWrapper, { 2920 dart.setSignature(_ControllerEventSinkWrapper, {
2921 methods: () => ({ 2921 methods: () => ({
2922 add: dart.functionType(dart.void, [T]), 2922 add: [dart.void, [T]],
2923 addError: dart.functionType(dart.void, [dart.dynamic], [core.StackTrace] ), 2923 addError: [dart.void, [dart.dynamic], [core.StackTrace]],
2924 close: dart.functionType(dart.void, []) 2924 close: [dart.void, []]
2925 }) 2925 })
2926 }); 2926 });
2927 return _ControllerEventSinkWrapper; 2927 return _ControllerEventSinkWrapper;
2928 }); 2928 });
2929 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); 2929 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$();
2930 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v oid, [StreamSubscription])); 2930 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v oid, [StreamSubscription]));
2931 let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart.d ynamic, [dart.dynamic, core.StackTrace])); 2931 let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart.d ynamic, [dart.dynamic, core.StackTrace]));
2932 let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.v oid, [])); 2932 let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.v oid, []));
2933 let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.v oid, [EventSink])); 2933 let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.v oid, [EventSink]));
2934 let StreamController$ = dart.generic(function(T) { 2934 let StreamController$ = dart.generic(function(T) {
(...skipping 30 matching lines...) Expand all
2965 [_recordResume](subscription) { 2965 [_recordResume](subscription) {
2966 dart.as(subscription, StreamSubscription$(T)); 2966 dart.as(subscription, StreamSubscription$(T));
2967 } 2967 }
2968 [_recordCancel](subscription) { 2968 [_recordCancel](subscription) {
2969 dart.as(subscription, StreamSubscription$(T)); 2969 dart.as(subscription, StreamSubscription$(T));
2970 return null; 2970 return null;
2971 } 2971 }
2972 } 2972 }
2973 dart.setSignature(_StreamControllerLifecycle, { 2973 dart.setSignature(_StreamControllerLifecycle, {
2974 methods: () => ({ 2974 methods: () => ({
2975 [_recordPause]: dart.functionType(dart.void, [StreamSubscription$(T)]), 2975 [_recordPause]: [dart.void, [StreamSubscription$(T)]],
2976 [_recordResume]: dart.functionType(dart.void, [StreamSubscription$(T)]), 2976 [_recordResume]: [dart.void, [StreamSubscription$(T)]],
2977 [_recordCancel]: dart.functionType(Future, [StreamSubscription$(T)]) 2977 [_recordCancel]: [Future, [StreamSubscription$(T)]]
2978 }) 2978 })
2979 }); 2979 });
2980 return _StreamControllerLifecycle; 2980 return _StreamControllerLifecycle;
2981 }); 2981 });
2982 let _StreamControllerLifecycle = _StreamControllerLifecycle$(); 2982 let _StreamControllerLifecycle = _StreamControllerLifecycle$();
2983 let _varData = Symbol('_varData'); 2983 let _varData = Symbol('_varData');
2984 let _isInitialState = Symbol('_isInitialState'); 2984 let _isInitialState = Symbol('_isInitialState');
2985 let _subscription = Symbol('_subscription'); 2985 let _subscription = Symbol('_subscription');
2986 let _pendingEvents = Symbol('_pendingEvents'); 2986 let _pendingEvents = Symbol('_pendingEvents');
2987 let _ensurePendingEvents = Symbol('_ensurePendingEvents'); 2987 let _ensurePendingEvents = Symbol('_ensurePendingEvents');
(...skipping 217 matching lines...) Expand 10 before | Expand all | Expand 10 after
3205 if (this[_isAddingStream]) { 3205 if (this[_isAddingStream]) {
3206 let addState = dart.as(this[_varData], _StreamControllerAddStreamState ); 3206 let addState = dart.as(this[_varData], _StreamControllerAddStreamState );
3207 addState.resume(); 3207 addState.resume();
3208 } 3208 }
3209 _runGuarded(this[_onResume]); 3209 _runGuarded(this[_onResume]);
3210 } 3210 }
3211 } 3211 }
3212 _StreamController[dart.implements] = () => [StreamController$(T), _StreamCon trollerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)]; 3212 _StreamController[dart.implements] = () => [StreamController$(T), _StreamCon trollerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)];
3213 dart.setSignature(_StreamController, { 3213 dart.setSignature(_StreamController, {
3214 methods: () => ({ 3214 methods: () => ({
3215 [_ensurePendingEvents]: dart.functionType(_StreamImplEvents, []), 3215 [_ensurePendingEvents]: [_StreamImplEvents, []],
3216 [_badEventState]: dart.functionType(core.Error, []), 3216 [_badEventState]: [core.Error, []],
3217 addStream: dart.functionType(Future, [Stream$(T)], {ancelOnErro: core.bo ol}), 3217 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}],
3218 [_ensureDoneFuture]: dart.functionType(Future, []), 3218 [_ensureDoneFuture]: [Future, []],
3219 add: dart.functionType(dart.void, [T]), 3219 add: [dart.void, [T]],
3220 addError: dart.functionType(dart.void, [core.Object], [core.StackTrace]) , 3220 addError: [dart.void, [core.Object], [core.StackTrace]],
3221 close: dart.functionType(Future, []), 3221 close: [Future, []],
3222 [_closeUnchecked]: dart.functionType(dart.void, []), 3222 [_closeUnchecked]: [dart.void, []],
3223 [_add]: dart.functionType(dart.void, [T]), 3223 [_add]: [dart.void, [T]],
3224 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace] ), 3224 [_addError]: [dart.void, [core.Object, core.StackTrace]],
3225 [_close]: dart.functionType(dart.void, []), 3225 [_close]: [dart.void, []],
3226 [_subscribe]: dart.functionType(StreamSubscription$(T), [dart.functionTy pe(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]) , 3226 [_subscribe]: [StreamSubscription$(T), [dart.functionType(dart.void, [T] ), core.Function, dart.functionType(dart.void, []), core.bool]],
3227 [_recordCancel]: dart.functionType(Future, [StreamSubscription$(T)]), 3227 [_recordCancel]: [Future, [StreamSubscription$(T)]],
3228 [_recordPause]: dart.functionType(dart.void, [StreamSubscription$(T)]), 3228 [_recordPause]: [dart.void, [StreamSubscription$(T)]],
3229 [_recordResume]: dart.functionType(dart.void, [StreamSubscription$(T)]) 3229 [_recordResume]: [dart.void, [StreamSubscription$(T)]]
3230 }) 3230 })
3231 }); 3231 });
3232 return _StreamController; 3232 return _StreamController;
3233 }); 3233 });
3234 let _StreamController = _StreamController$(); 3234 let _StreamController = _StreamController$();
3235 _StreamController._STATE_INITIAL = 0; 3235 _StreamController._STATE_INITIAL = 0;
3236 _StreamController._STATE_SUBSCRIBED = 1; 3236 _StreamController._STATE_SUBSCRIBED = 1;
3237 _StreamController._STATE_CANCELED = 2; 3237 _StreamController._STATE_CANCELED = 2;
3238 _StreamController._STATE_SUBSCRIPTION_MASK = 3; 3238 _StreamController._STATE_SUBSCRIPTION_MASK = 3;
3239 _StreamController._STATE_CLOSED = 4; 3239 _StreamController._STATE_CLOSED = 4;
3240 _StreamController._STATE_ADDSTREAM = 8; 3240 _StreamController._STATE_ADDSTREAM = 8;
3241 let _SyncStreamControllerDispatch$ = dart.generic(function(T) { 3241 let _SyncStreamControllerDispatch$ = dart.generic(function(T) {
3242 class _SyncStreamControllerDispatch extends core.Object { 3242 class _SyncStreamControllerDispatch extends core.Object {
3243 [_sendData](data) { 3243 [_sendData](data) {
3244 dart.as(data, T); 3244 dart.as(data, T);
3245 this[_subscription][_add](data); 3245 this[_subscription][_add](data);
3246 } 3246 }
3247 [_sendError](error, stackTrace) { 3247 [_sendError](error, stackTrace) {
3248 this[_subscription][_addError](error, stackTrace); 3248 this[_subscription][_addError](error, stackTrace);
3249 } 3249 }
3250 [_sendDone]() { 3250 [_sendDone]() {
3251 this[_subscription][_close](); 3251 this[_subscription][_close]();
3252 } 3252 }
3253 } 3253 }
3254 _SyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(T )]; 3254 _SyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(T )];
3255 dart.setSignature(_SyncStreamControllerDispatch, { 3255 dart.setSignature(_SyncStreamControllerDispatch, {
3256 methods: () => ({ 3256 methods: () => ({
3257 [_sendData]: dart.functionType(dart.void, [T]), 3257 [_sendData]: [dart.void, [T]],
3258 [_sendError]: dart.functionType(dart.void, [core.Object, core.StackTrace ]), 3258 [_sendError]: [dart.void, [core.Object, core.StackTrace]],
3259 [_sendDone]: dart.functionType(dart.void, []) 3259 [_sendDone]: [dart.void, []]
3260 }) 3260 })
3261 }); 3261 });
3262 return _SyncStreamControllerDispatch; 3262 return _SyncStreamControllerDispatch;
3263 }); 3263 });
3264 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(); 3264 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$();
3265 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) { 3265 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) {
3266 class _AsyncStreamControllerDispatch extends core.Object { 3266 class _AsyncStreamControllerDispatch extends core.Object {
3267 [_sendData](data) { 3267 [_sendData](data) {
3268 dart.as(data, T); 3268 dart.as(data, T);
3269 this[_subscription][_addPending](new _DelayedData(data)); 3269 this[_subscription][_addPending](new _DelayedData(data));
3270 } 3270 }
3271 [_sendError](error, stackTrace) { 3271 [_sendError](error, stackTrace) {
3272 this[_subscription][_addPending](new _DelayedError(error, stackTrace)); 3272 this[_subscription][_addPending](new _DelayedError(error, stackTrace));
3273 } 3273 }
3274 [_sendDone]() { 3274 [_sendDone]() {
3275 this[_subscription][_addPending](dart.const(new _DelayedDone())); 3275 this[_subscription][_addPending](dart.const(new _DelayedDone()));
3276 } 3276 }
3277 } 3277 }
3278 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$( T)]; 3278 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$( T)];
3279 dart.setSignature(_AsyncStreamControllerDispatch, { 3279 dart.setSignature(_AsyncStreamControllerDispatch, {
3280 methods: () => ({ 3280 methods: () => ({
3281 [_sendData]: dart.functionType(dart.void, [T]), 3281 [_sendData]: [dart.void, [T]],
3282 [_sendError]: dart.functionType(dart.void, [core.Object, core.StackTrace ]), 3282 [_sendError]: [dart.void, [core.Object, core.StackTrace]],
3283 [_sendDone]: dart.functionType(dart.void, []) 3283 [_sendDone]: [dart.void, []]
3284 }) 3284 })
3285 }); 3285 });
3286 return _AsyncStreamControllerDispatch; 3286 return _AsyncStreamControllerDispatch;
3287 }); 3287 });
3288 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(); 3288 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$();
3289 let _AsyncStreamController$ = dart.generic(function(T) { 3289 let _AsyncStreamController$ = dart.generic(function(T) {
3290 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) { 3290 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) {
3291 _AsyncStreamController(onListen, onPause, onResume, onCancel) { 3291 _AsyncStreamController(onListen, onPause, onResume, onCancel) {
3292 this[_onListen] = onListen; 3292 this[_onListen] = onListen;
3293 this[_onPause] = onPause; 3293 this[_onPause] = onPause;
(...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after
3370 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true; 3370 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
3371 return this[_target].addStream(source, {cancelOnError: cancelOnError}); 3371 return this[_target].addStream(source, {cancelOnError: cancelOnError});
3372 } 3372 }
3373 get done() { 3373 get done() {
3374 return this[_target].done; 3374 return this[_target].done;
3375 } 3375 }
3376 } 3376 }
3377 _StreamSinkWrapper[dart.implements] = () => [StreamSink$(T)]; 3377 _StreamSinkWrapper[dart.implements] = () => [StreamSink$(T)];
3378 dart.setSignature(_StreamSinkWrapper, { 3378 dart.setSignature(_StreamSinkWrapper, {
3379 methods: () => ({ 3379 methods: () => ({
3380 add: dart.functionType(dart.void, [T]), 3380 add: [dart.void, [T]],
3381 addError: dart.functionType(dart.void, [core.Object], [core.StackTrace]) , 3381 addError: [dart.void, [core.Object], [core.StackTrace]],
3382 close: dart.functionType(Future, []), 3382 close: [Future, []],
3383 addStream: dart.functionType(Future, [Stream$(T)], {ancelOnErro: core.bo ol}) 3383 addStream: [Future, [Stream$(T)], {ancelOnErro: core.bool}]
3384 }) 3384 })
3385 }); 3385 });
3386 return _StreamSinkWrapper; 3386 return _StreamSinkWrapper;
3387 }); 3387 });
3388 let _StreamSinkWrapper = _StreamSinkWrapper$(); 3388 let _StreamSinkWrapper = _StreamSinkWrapper$();
3389 let _AddStreamState$ = dart.generic(function(T) { 3389 let _AddStreamState$ = dart.generic(function(T) {
3390 class _AddStreamState extends core.Object { 3390 class _AddStreamState extends core.Object {
3391 _AddStreamState(controller, source, cancelOnError) { 3391 _AddStreamState(controller, source, cancelOnError) {
3392 this.addStreamFuture = new _Future(); 3392 this.addStreamFuture = new _Future();
3393 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}); 3393 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 19 matching lines...) Expand all
3413 return cancel.whenComplete(dart.fn((() => { 3413 return cancel.whenComplete(dart.fn((() => {
3414 this.addStreamFuture[_asyncComplete](null); 3414 this.addStreamFuture[_asyncComplete](null);
3415 }).bind(this))); 3415 }).bind(this)));
3416 } 3416 }
3417 complete() { 3417 complete() {
3418 this.addStreamFuture[_asyncComplete](null); 3418 this.addStreamFuture[_asyncComplete](null);
3419 } 3419 }
3420 } 3420 }
3421 dart.setSignature(_AddStreamState, { 3421 dart.setSignature(_AddStreamState, {
3422 methods: () => ({ 3422 methods: () => ({
3423 pause: dart.functionType(dart.void, []), 3423 pause: [dart.void, []],
3424 resume: dart.functionType(dart.void, []), 3424 resume: [dart.void, []],
3425 cancel: dart.functionType(Future, []), 3425 cancel: [Future, []],
3426 complete: dart.functionType(dart.void, []) 3426 complete: [dart.void, []]
3427 }), 3427 }),
3428 statics: () => ({makeErrorHandler: dart.functionType(dart.dynamic, [_Event Sink])}), 3428 statics: () => ({makeErrorHandler: [dart.dynamic, [_EventSink]]}),
3429 names: ['makeErrorHandler'] 3429 names: ['makeErrorHandler']
3430 }); 3430 });
3431 return _AddStreamState; 3431 return _AddStreamState;
3432 }); 3432 });
3433 let _AddStreamState = _AddStreamState$(); 3433 let _AddStreamState = _AddStreamState$();
3434 let _StreamControllerAddStreamState$ = dart.generic(function(T) { 3434 let _StreamControllerAddStreamState$ = dart.generic(function(T) {
3435 class _StreamControllerAddStreamState extends _AddStreamState$(T) { 3435 class _StreamControllerAddStreamState extends _AddStreamState$(T) {
3436 _StreamControllerAddStreamState(controller, varData, source, cancelOnError ) { 3436 _StreamControllerAddStreamState(controller, varData, source, cancelOnError ) {
3437 this.varData = varData; 3437 this.varData = varData;
3438 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance lOnError); 3438 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance lOnError);
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
3481 throw new core.StateError("Stream has already been listened to."); 3481 throw new core.StateError("Stream has already been listened to.");
3482 this[_isUsed] = true; 3482 this[_isUsed] = true;
3483 return dart.as((() => { 3483 return dart.as((() => {
3484 let _ = new _BufferingStreamSubscription(onData, onError, onDone, canc elOnError); 3484 let _ = new _BufferingStreamSubscription(onData, onError, onDone, canc elOnError);
3485 _[_setPendingEvents](this[_pending]()); 3485 _[_setPendingEvents](this[_pending]());
3486 return _; 3486 return _;
3487 }).bind(this)(), StreamSubscription$(T)); 3487 }).bind(this)(), StreamSubscription$(T));
3488 } 3488 }
3489 } 3489 }
3490 dart.setSignature(_GeneratedStreamImpl, { 3490 dart.setSignature(_GeneratedStreamImpl, {
3491 methods: () => ({[_createSubscription]: dart.functionType(StreamSubscripti on$(T), [dart.functionType(dart.void, [T]), core.Function, dart.functionType(dar t.void, []), core.bool])}) 3491 methods: () => ({[_createSubscription]: [StreamSubscription$(T), [dart.fun ctionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), core .bool]]})
3492 }); 3492 });
3493 return _GeneratedStreamImpl; 3493 return _GeneratedStreamImpl;
3494 }); 3494 });
3495 let _GeneratedStreamImpl = _GeneratedStreamImpl$(); 3495 let _GeneratedStreamImpl = _GeneratedStreamImpl$();
3496 let _eventScheduled = Symbol('_eventScheduled'); 3496 let _eventScheduled = Symbol('_eventScheduled');
3497 class _PendingEvents extends core.Object { 3497 class _PendingEvents extends core.Object {
3498 _PendingEvents() { 3498 _PendingEvents() {
3499 this[_state] = _PendingEvents._STATE_UNSCHEDULED; 3499 this[_state] = _PendingEvents._STATE_UNSCHEDULED;
3500 } 3500 }
3501 get isScheduled() { 3501 get isScheduled() {
(...skipping 20 matching lines...) Expand all
3522 }).bind(this))); 3522 }).bind(this)));
3523 this[_state] = _PendingEvents._STATE_SCHEDULED; 3523 this[_state] = _PendingEvents._STATE_SCHEDULED;
3524 } 3524 }
3525 cancelSchedule() { 3525 cancelSchedule() {
3526 if (this.isScheduled) 3526 if (this.isScheduled)
3527 this[_state] = _PendingEvents._STATE_CANCELED; 3527 this[_state] = _PendingEvents._STATE_CANCELED;
3528 } 3528 }
3529 } 3529 }
3530 dart.setSignature(_PendingEvents, { 3530 dart.setSignature(_PendingEvents, {
3531 methods: () => ({ 3531 methods: () => ({
3532 schedule: dart.functionType(dart.void, [_EventDispatch]), 3532 schedule: [dart.void, [_EventDispatch]],
3533 cancelSchedule: dart.functionType(dart.void, []) 3533 cancelSchedule: [dart.void, []]
3534 }) 3534 })
3535 }); 3535 });
3536 let _iterator = Symbol('_iterator'); 3536 let _iterator = Symbol('_iterator');
3537 let _IterablePendingEvents$ = dart.generic(function(T) { 3537 let _IterablePendingEvents$ = dart.generic(function(T) {
3538 class _IterablePendingEvents extends _PendingEvents { 3538 class _IterablePendingEvents extends _PendingEvents {
3539 _IterablePendingEvents(data) { 3539 _IterablePendingEvents(data) {
3540 this[_iterator] = data[core.$iterator]; 3540 this[_iterator] = data[core.$iterator];
3541 super._PendingEvents(); 3541 super._PendingEvents();
3542 } 3542 }
3543 get isEmpty() { 3543 get isEmpty() {
(...skipping 21 matching lines...) Expand all
3565 } 3565 }
3566 } 3566 }
3567 clear() { 3567 clear() {
3568 if (this.isScheduled) 3568 if (this.isScheduled)
3569 this.cancelSchedule(); 3569 this.cancelSchedule();
3570 this[_iterator] = null; 3570 this[_iterator] = null;
3571 } 3571 }
3572 } 3572 }
3573 dart.setSignature(_IterablePendingEvents, { 3573 dart.setSignature(_IterablePendingEvents, {
3574 methods: () => ({ 3574 methods: () => ({
3575 handleNext: dart.functionType(dart.void, [_EventDispatch]), 3575 handleNext: [dart.void, [_EventDispatch]],
3576 clear: dart.functionType(dart.void, []) 3576 clear: [dart.void, []]
3577 }) 3577 })
3578 }); 3578 });
3579 return _IterablePendingEvents; 3579 return _IterablePendingEvents;
3580 }); 3580 });
3581 let _IterablePendingEvents = _IterablePendingEvents$(); 3581 let _IterablePendingEvents = _IterablePendingEvents$();
3582 let _DataHandler$ = dart.generic(function(T) { 3582 let _DataHandler$ = dart.generic(function(T) {
3583 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart .void, [T])); 3583 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart .void, [T]));
3584 return _DataHandler; 3584 return _DataHandler;
3585 }); 3585 });
3586 let _DataHandler = _DataHandler$(); 3586 let _DataHandler = _DataHandler$();
(...skipping 25 matching lines...) Expand all
3612 _DelayedData(value) { 3612 _DelayedData(value) {
3613 this.value = value; 3613 this.value = value;
3614 super._DelayedEvent(); 3614 super._DelayedEvent();
3615 } 3615 }
3616 perform(dispatch) { 3616 perform(dispatch) {
3617 dart.as(dispatch, _EventDispatch$(T)); 3617 dart.as(dispatch, _EventDispatch$(T));
3618 dispatch[_sendData](this.value); 3618 dispatch[_sendData](this.value);
3619 } 3619 }
3620 } 3620 }
3621 dart.setSignature(_DelayedData, { 3621 dart.setSignature(_DelayedData, {
3622 methods: () => ({perform: dart.functionType(dart.void, [_EventDispatch$(T) ])}) 3622 methods: () => ({perform: [dart.void, [_EventDispatch$(T)]]})
3623 }); 3623 });
3624 return _DelayedData; 3624 return _DelayedData;
3625 }); 3625 });
3626 let _DelayedData = _DelayedData$(); 3626 let _DelayedData = _DelayedData$();
3627 class _DelayedError extends _DelayedEvent { 3627 class _DelayedError extends _DelayedEvent {
3628 _DelayedError(error, stackTrace) { 3628 _DelayedError(error, stackTrace) {
3629 this.error = error; 3629 this.error = error;
3630 this.stackTrace = stackTrace; 3630 this.stackTrace = stackTrace;
3631 super._DelayedEvent(); 3631 super._DelayedEvent();
3632 } 3632 }
3633 perform(dispatch) { 3633 perform(dispatch) {
3634 dispatch[_sendError](this.error, this.stackTrace); 3634 dispatch[_sendError](this.error, this.stackTrace);
3635 } 3635 }
3636 } 3636 }
3637 dart.setSignature(_DelayedError, { 3637 dart.setSignature(_DelayedError, {
3638 methods: () => ({perform: dart.functionType(dart.void, [_EventDispatch])}) 3638 methods: () => ({perform: [dart.void, [_EventDispatch]]})
3639 }); 3639 });
3640 class _DelayedDone extends core.Object { 3640 class _DelayedDone extends core.Object {
3641 _DelayedDone() { 3641 _DelayedDone() {
3642 } 3642 }
3643 perform(dispatch) { 3643 perform(dispatch) {
3644 dispatch[_sendDone](); 3644 dispatch[_sendDone]();
3645 } 3645 }
3646 get next() { 3646 get next() {
3647 return null; 3647 return null;
3648 } 3648 }
3649 set next(_) { 3649 set next(_) {
3650 throw new core.StateError("No events after a done."); 3650 throw new core.StateError("No events after a done.");
3651 } 3651 }
3652 } 3652 }
3653 _DelayedDone[dart.implements] = () => [_DelayedEvent]; 3653 _DelayedDone[dart.implements] = () => [_DelayedEvent];
3654 dart.setSignature(_DelayedDone, { 3654 dart.setSignature(_DelayedDone, {
3655 methods: () => ({perform: dart.functionType(dart.void, [_EventDispatch])}) 3655 methods: () => ({perform: [dart.void, [_EventDispatch]]})
3656 }); 3656 });
3657 _PendingEvents._STATE_UNSCHEDULED = 0; 3657 _PendingEvents._STATE_UNSCHEDULED = 0;
3658 _PendingEvents._STATE_SCHEDULED = 1; 3658 _PendingEvents._STATE_SCHEDULED = 1;
3659 _PendingEvents._STATE_CANCELED = 3; 3659 _PendingEvents._STATE_CANCELED = 3;
3660 class _StreamImplEvents extends _PendingEvents { 3660 class _StreamImplEvents extends _PendingEvents {
3661 _StreamImplEvents() { 3661 _StreamImplEvents() {
3662 this.firstPendingEvent = null; 3662 this.firstPendingEvent = null;
3663 this.lastPendingEvent = null; 3663 this.lastPendingEvent = null;
3664 super._PendingEvents(); 3664 super._PendingEvents();
3665 } 3665 }
(...skipping 17 matching lines...) Expand all
3683 event.perform(dispatch); 3683 event.perform(dispatch);
3684 } 3684 }
3685 clear() { 3685 clear() {
3686 if (this.isScheduled) 3686 if (this.isScheduled)
3687 this.cancelSchedule(); 3687 this.cancelSchedule();
3688 this.firstPendingEvent = this.lastPendingEvent = null; 3688 this.firstPendingEvent = this.lastPendingEvent = null;
3689 } 3689 }
3690 } 3690 }
3691 dart.setSignature(_StreamImplEvents, { 3691 dart.setSignature(_StreamImplEvents, {
3692 methods: () => ({ 3692 methods: () => ({
3693 add: dart.functionType(dart.void, [_DelayedEvent]), 3693 add: [dart.void, [_DelayedEvent]],
3694 handleNext: dart.functionType(dart.void, [_EventDispatch]), 3694 handleNext: [dart.void, [_EventDispatch]],
3695 clear: dart.functionType(dart.void, []) 3695 clear: [dart.void, []]
3696 }) 3696 })
3697 }); 3697 });
3698 let _unlink = Symbol('_unlink'); 3698 let _unlink = Symbol('_unlink');
3699 let _insertBefore = Symbol('_insertBefore'); 3699 let _insertBefore = Symbol('_insertBefore');
3700 class _BroadcastLinkedList extends core.Object { 3700 class _BroadcastLinkedList extends core.Object {
3701 _BroadcastLinkedList() { 3701 _BroadcastLinkedList() {
3702 this[_next] = null; 3702 this[_next] = null;
3703 this[_previous] = null; 3703 this[_previous] = null;
3704 } 3704 }
3705 [_unlink]() { 3705 [_unlink]() {
3706 this[_previous][_next] = this[_next]; 3706 this[_previous][_next] = this[_next];
3707 this[_next][_previous] = this[_previous]; 3707 this[_next][_previous] = this[_previous];
3708 this[_next] = this[_previous] = this; 3708 this[_next] = this[_previous] = this;
3709 } 3709 }
3710 [_insertBefore](newNext) { 3710 [_insertBefore](newNext) {
3711 let newPrevious = newNext[_previous]; 3711 let newPrevious = newNext[_previous];
3712 newPrevious[_next] = this; 3712 newPrevious[_next] = this;
3713 newNext[_previous] = this[_previous]; 3713 newNext[_previous] = this[_previous];
3714 this[_previous][_next] = newNext; 3714 this[_previous][_next] = newNext;
3715 this[_previous] = newPrevious; 3715 this[_previous] = newPrevious;
3716 } 3716 }
3717 } 3717 }
3718 dart.setSignature(_BroadcastLinkedList, { 3718 dart.setSignature(_BroadcastLinkedList, {
3719 methods: () => ({ 3719 methods: () => ({
3720 [_unlink]: dart.functionType(dart.void, []), 3720 [_unlink]: [dart.void, []],
3721 [_insertBefore]: dart.functionType(dart.void, [_BroadcastLinkedList]) 3721 [_insertBefore]: [dart.void, [_BroadcastLinkedList]]
3722 }) 3722 })
3723 }); 3723 });
3724 let _broadcastCallback = dart.typedef('_broadcastCallback', () => dart.functio nType(dart.void, [StreamSubscription])); 3724 let _broadcastCallback = dart.typedef('_broadcastCallback', () => dart.functio nType(dart.void, [StreamSubscription]));
3725 let _schedule = Symbol('_schedule'); 3725 let _schedule = Symbol('_schedule');
3726 let _isSent = Symbol('_isSent'); 3726 let _isSent = Symbol('_isSent');
3727 let _isScheduled = Symbol('_isScheduled'); 3727 let _isScheduled = Symbol('_isScheduled');
3728 let _DoneStreamSubscription$ = dart.generic(function(T) { 3728 let _DoneStreamSubscription$ = dart.generic(function(T) {
3729 class _DoneStreamSubscription extends core.Object { 3729 class _DoneStreamSubscription extends core.Object {
3730 _DoneStreamSubscription(onDone) { 3730 _DoneStreamSubscription(onDone) {
3731 this[_onDone] = onDone; 3731 this[_onDone] = onDone;
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after
3788 if (this.isPaused) 3788 if (this.isPaused)
3789 return; 3789 return;
3790 this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubs cription$()._DONE_SENT); 3790 this[_state] = dart.notNull(this[_state]) | dart.notNull(_DoneStreamSubs cription$()._DONE_SENT);
3791 if (this[_onDone] != null) 3791 if (this[_onDone] != null)
3792 this[_zone].runGuarded(this[_onDone]); 3792 this[_zone].runGuarded(this[_onDone]);
3793 } 3793 }
3794 } 3794 }
3795 _DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)]; 3795 _DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)];
3796 dart.setSignature(_DoneStreamSubscription, { 3796 dart.setSignature(_DoneStreamSubscription, {
3797 methods: () => ({ 3797 methods: () => ({
3798 [_schedule]: dart.functionType(dart.void, []), 3798 [_schedule]: [dart.void, []],
3799 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])] ), 3799 onData: [dart.void, [dart.functionType(dart.void, [T])]],
3800 onError: dart.functionType(dart.void, [core.Function]), 3800 onError: [dart.void, [core.Function]],
3801 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])]) , 3801 onDone: [dart.void, [dart.functionType(dart.void, [])]],
3802 pause: dart.functionType(dart.void, [], [Future]), 3802 pause: [dart.void, [], [Future]],
3803 resume: dart.functionType(dart.void, []), 3803 resume: [dart.void, []],
3804 cancel: dart.functionType(Future, []), 3804 cancel: [Future, []],
3805 asFuture: dart.functionType(Future, [], [dart.dynamic]), 3805 asFuture: [Future, [], [dart.dynamic]],
3806 [_sendDone]: dart.functionType(dart.void, []) 3806 [_sendDone]: [dart.void, []]
3807 }) 3807 })
3808 }); 3808 });
3809 return _DoneStreamSubscription; 3809 return _DoneStreamSubscription;
3810 }); 3810 });
3811 let _DoneStreamSubscription = _DoneStreamSubscription$(); 3811 let _DoneStreamSubscription = _DoneStreamSubscription$();
3812 _DoneStreamSubscription._DONE_SENT = 1; 3812 _DoneStreamSubscription._DONE_SENT = 1;
3813 _DoneStreamSubscription._SCHEDULED = 2; 3813 _DoneStreamSubscription._SCHEDULED = 2;
3814 _DoneStreamSubscription._PAUSED = 4; 3814 _DoneStreamSubscription._PAUSED = 4;
3815 let _source = Symbol('_source'); 3815 let _source = Symbol('_source');
3816 let _onListenHandler = Symbol('_onListenHandler'); 3816 let _onListenHandler = Symbol('_onListenHandler');
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after
3885 this[_subscription].resume(); 3885 this[_subscription].resume();
3886 } 3886 }
3887 get [_isSubscriptionPaused]() { 3887 get [_isSubscriptionPaused]() {
3888 if (this[_subscription] == null) 3888 if (this[_subscription] == null)
3889 return false; 3889 return false;
3890 return this[_subscription].isPaused; 3890 return this[_subscription].isPaused;
3891 } 3891 }
3892 } 3892 }
3893 dart.setSignature(_AsBroadcastStream, { 3893 dart.setSignature(_AsBroadcastStream, {
3894 methods: () => ({ 3894 methods: () => ({
3895 listen: dart.functionType(StreamSubscription$(T), [dart.functionType(dar t.void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), an celOnErro: core.bool}), 3895 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}],
3896 [_onCancel]: dart.functionType(dart.void, []), 3896 [_onCancel]: [dart.void, []],
3897 [_onListen]: dart.functionType(dart.void, []), 3897 [_onListen]: [dart.void, []],
3898 [_cancelSubscription]: dart.functionType(dart.void, []), 3898 [_cancelSubscription]: [dart.void, []],
3899 [_pauseSubscription]: dart.functionType(dart.void, [Future]), 3899 [_pauseSubscription]: [dart.void, [Future]],
3900 [_resumeSubscription]: dart.functionType(dart.void, []) 3900 [_resumeSubscription]: [dart.void, []]
3901 }) 3901 })
3902 }); 3902 });
3903 return _AsBroadcastStream; 3903 return _AsBroadcastStream;
3904 }); 3904 });
3905 let _AsBroadcastStream = _AsBroadcastStream$(); 3905 let _AsBroadcastStream = _AsBroadcastStream$();
3906 let _BroadcastSubscriptionWrapper$ = dart.generic(function(T) { 3906 let _BroadcastSubscriptionWrapper$ = dart.generic(function(T) {
3907 class _BroadcastSubscriptionWrapper extends core.Object { 3907 class _BroadcastSubscriptionWrapper extends core.Object {
3908 _BroadcastSubscriptionWrapper(stream) { 3908 _BroadcastSubscriptionWrapper(stream) {
3909 this[_stream] = stream; 3909 this[_stream] = stream;
3910 } 3910 }
(...skipping 25 matching lines...) Expand all
3936 } 3936 }
3937 asFuture(futureValue) { 3937 asFuture(futureValue) {
3938 if (futureValue === void 0) 3938 if (futureValue === void 0)
3939 futureValue = null; 3939 futureValue = null;
3940 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt ream source subscription."); 3940 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt ream source subscription.");
3941 } 3941 }
3942 } 3942 }
3943 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$( T)]; 3943 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$( T)];
3944 dart.setSignature(_BroadcastSubscriptionWrapper, { 3944 dart.setSignature(_BroadcastSubscriptionWrapper, {
3945 methods: () => ({ 3945 methods: () => ({
3946 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])] ), 3946 onData: [dart.void, [dart.functionType(dart.void, [T])]],
3947 onError: dart.functionType(dart.void, [core.Function]), 3947 onError: [dart.void, [core.Function]],
3948 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])]) , 3948 onDone: [dart.void, [dart.functionType(dart.void, [])]],
3949 pause: dart.functionType(dart.void, [], [Future]), 3949 pause: [dart.void, [], [Future]],
3950 resume: dart.functionType(dart.void, []), 3950 resume: [dart.void, []],
3951 cancel: dart.functionType(Future, []), 3951 cancel: [Future, []],
3952 asFuture: dart.functionType(Future, [], [dart.dynamic]) 3952 asFuture: [Future, [], [dart.dynamic]]
3953 }) 3953 })
3954 }); 3954 });
3955 return _BroadcastSubscriptionWrapper; 3955 return _BroadcastSubscriptionWrapper;
3956 }); 3956 });
3957 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); 3957 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$();
3958 let _current = Symbol('_current'); 3958 let _current = Symbol('_current');
3959 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); 3959 let _futureOrPrefetch = Symbol('_futureOrPrefetch');
3960 let _clear = Symbol('_clear'); 3960 let _clear = Symbol('_clear');
3961 let _StreamIteratorImpl$ = dart.generic(function(T) { 3961 let _StreamIteratorImpl$ = dart.generic(function(T) {
3962 class _StreamIteratorImpl extends core.Object { 3962 class _StreamIteratorImpl extends core.Object {
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after
4061 return; 4061 return;
4062 } 4062 }
4063 this[_subscription].pause(); 4063 this[_subscription].pause();
4064 this[_futureOrPrefetch] = null; 4064 this[_futureOrPrefetch] = null;
4065 this[_state] = _StreamIteratorImpl$()._STATE_EXTRA_DONE; 4065 this[_state] = _StreamIteratorImpl$()._STATE_EXTRA_DONE;
4066 } 4066 }
4067 } 4067 }
4068 _StreamIteratorImpl[dart.implements] = () => [StreamIterator$(T)]; 4068 _StreamIteratorImpl[dart.implements] = () => [StreamIterator$(T)];
4069 dart.setSignature(_StreamIteratorImpl, { 4069 dart.setSignature(_StreamIteratorImpl, {
4070 methods: () => ({ 4070 methods: () => ({
4071 moveNext: dart.functionType(Future$(core.bool), []), 4071 moveNext: [Future$(core.bool), []],
4072 [_clear]: dart.functionType(dart.void, []), 4072 [_clear]: [dart.void, []],
4073 cancel: dart.functionType(Future, []), 4073 cancel: [Future, []],
4074 [_onData]: dart.functionType(dart.void, [T]), 4074 [_onData]: [dart.void, [T]],
4075 [_onError]: dart.functionType(dart.void, [core.Object], [core.StackTrace ]), 4075 [_onError]: [dart.void, [core.Object], [core.StackTrace]],
4076 [_onDone]: dart.functionType(dart.void, []) 4076 [_onDone]: [dart.void, []]
4077 }) 4077 })
4078 }); 4078 });
4079 return _StreamIteratorImpl; 4079 return _StreamIteratorImpl;
4080 }); 4080 });
4081 let _StreamIteratorImpl = _StreamIteratorImpl$(); 4081 let _StreamIteratorImpl = _StreamIteratorImpl$();
4082 _StreamIteratorImpl._STATE_FOUND = 0; 4082 _StreamIteratorImpl._STATE_FOUND = 0;
4083 _StreamIteratorImpl._STATE_DONE = 1; 4083 _StreamIteratorImpl._STATE_DONE = 1;
4084 _StreamIteratorImpl._STATE_MOVING = 2; 4084 _StreamIteratorImpl._STATE_MOVING = 2;
4085 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; 4085 _StreamIteratorImpl._STATE_EXTRA_DATA = 3;
4086 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; 4086 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
(...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after
4176 dart.as(sink, _EventSink$(T)); 4176 dart.as(sink, _EventSink$(T));
4177 sink[_addError](error, stackTrace); 4177 sink[_addError](error, stackTrace);
4178 } 4178 }
4179 [_handleDone](sink) { 4179 [_handleDone](sink) {
4180 dart.as(sink, _EventSink$(T)); 4180 dart.as(sink, _EventSink$(T));
4181 sink[_close](); 4181 sink[_close]();
4182 } 4182 }
4183 } 4183 }
4184 dart.setSignature(_ForwardingStream, { 4184 dart.setSignature(_ForwardingStream, {
4185 methods: () => ({ 4185 methods: () => ({
4186 listen: dart.functionType(StreamSubscription$(T), [dart.functionType(dar t.void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), an celOnErro: core.bool}), 4186 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {n Erro: core.Function, nDon: dart.functionType(dart.void, []), ancelOnErro: core.b ool}],
4187 [_createSubscription]: dart.functionType(StreamSubscription$(T), [dart.f unctionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), co re.bool]), 4187 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart. void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]],
4188 [_handleData]: dart.functionType(dart.void, [S, _EventSink$(T)]), 4188 [_handleData]: [dart.void, [S, _EventSink$(T)]],
4189 [_handleError]: dart.functionType(dart.void, [dart.dynamic, core.StackTr ace, _EventSink$(T)]), 4189 [_handleError]: [dart.void, [dart.dynamic, core.StackTrace, _EventSink$( T)]],
4190 [_handleDone]: dart.functionType(dart.void, [_EventSink$(T)]) 4190 [_handleDone]: [dart.void, [_EventSink$(T)]]
4191 }) 4191 })
4192 }); 4192 });
4193 return _ForwardingStream; 4193 return _ForwardingStream;
4194 }); 4194 });
4195 let _ForwardingStream = _ForwardingStream$(); 4195 let _ForwardingStream = _ForwardingStream$();
4196 let _ForwardingStreamSubscription$ = dart.generic(function(S, T) { 4196 let _ForwardingStreamSubscription$ = dart.generic(function(S, T) {
4197 class _ForwardingStreamSubscription extends _BufferingStreamSubscription$(T) { 4197 class _ForwardingStreamSubscription extends _BufferingStreamSubscription$(T) {
4198 _ForwardingStreamSubscription(stream, onData, onError, onDone, cancelOnErr or) { 4198 _ForwardingStreamSubscription(stream, onData, onError, onDone, cancelOnErr or) {
4199 this[_stream] = stream; 4199 this[_stream] = stream;
4200 this[_subscription] = null; 4200 this[_subscription] = null;
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after
4236 } 4236 }
4237 [_handleError](error, stackTrace) { 4237 [_handleError](error, stackTrace) {
4238 this[_stream][_handleError](error, stackTrace, this); 4238 this[_stream][_handleError](error, stackTrace, this);
4239 } 4239 }
4240 [_handleDone]() { 4240 [_handleDone]() {
4241 this[_stream][_handleDone](this); 4241 this[_stream][_handleDone](this);
4242 } 4242 }
4243 } 4243 }
4244 dart.setSignature(_ForwardingStreamSubscription, { 4244 dart.setSignature(_ForwardingStreamSubscription, {
4245 methods: () => ({ 4245 methods: () => ({
4246 [_add]: dart.functionType(dart.void, [T]), 4246 [_add]: [dart.void, [T]],
4247 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace] ), 4247 [_addError]: [dart.void, [core.Object, core.StackTrace]],
4248 [_onPause]: dart.functionType(dart.void, []), 4248 [_onPause]: [dart.void, []],
4249 [_onResume]: dart.functionType(dart.void, []), 4249 [_onResume]: [dart.void, []],
4250 [_onCancel]: dart.functionType(Future, []), 4250 [_onCancel]: [Future, []],
4251 [_handleData]: dart.functionType(dart.void, [S]), 4251 [_handleData]: [dart.void, [S]],
4252 [_handleError]: dart.functionType(dart.void, [dart.dynamic, core.StackTr ace]), 4252 [_handleError]: [dart.void, [dart.dynamic, core.StackTrace]],
4253 [_handleDone]: dart.functionType(dart.void, []) 4253 [_handleDone]: [dart.void, []]
4254 }) 4254 })
4255 }); 4255 });
4256 return _ForwardingStreamSubscription; 4256 return _ForwardingStreamSubscription;
4257 }); 4257 });
4258 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); 4258 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$();
4259 let _Predicate$ = dart.generic(function(T) { 4259 let _Predicate$ = dart.generic(function(T) {
4260 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo l, [T])); 4260 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo l, [T]));
4261 return _Predicate; 4261 return _Predicate;
4262 }); 4262 });
4263 let _Predicate = _Predicate$(); 4263 let _Predicate = _Predicate$();
(...skipping 24 matching lines...) Expand all
4288 _addErrorWithReplacement(sink, e, s); 4288 _addErrorWithReplacement(sink, e, s);
4289 return; 4289 return;
4290 } 4290 }
4291 4291
4292 if (satisfies) { 4292 if (satisfies) {
4293 sink[_add](inputEvent); 4293 sink[_add](inputEvent);
4294 } 4294 }
4295 } 4295 }
4296 } 4296 }
4297 dart.setSignature(_WhereStream, { 4297 dart.setSignature(_WhereStream, {
4298 methods: () => ({[_handleData]: dart.functionType(dart.void, [T, _EventSin k$(T)])}) 4298 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4299 }); 4299 });
4300 return _WhereStream; 4300 return _WhereStream;
4301 }); 4301 });
4302 let _WhereStream = _WhereStream$(); 4302 let _WhereStream = _WhereStream$();
4303 let _Transformation$ = dart.generic(function(S, T) { 4303 let _Transformation$ = dart.generic(function(S, T) {
4304 let _Transformation = dart.typedef('_Transformation', () => dart.functionTyp e(T, [S])); 4304 let _Transformation = dart.typedef('_Transformation', () => dart.functionTyp e(T, [S]));
4305 return _Transformation; 4305 return _Transformation;
4306 }); 4306 });
4307 let _Transformation = _Transformation$(); 4307 let _Transformation = _Transformation$();
4308 let _transform = Symbol('_transform'); 4308 let _transform = Symbol('_transform');
(...skipping 12 matching lines...) Expand all
4321 } catch (e) { 4321 } catch (e) {
4322 let s = dart.stackTrace(e); 4322 let s = dart.stackTrace(e);
4323 _addErrorWithReplacement(sink, e, s); 4323 _addErrorWithReplacement(sink, e, s);
4324 return; 4324 return;
4325 } 4325 }
4326 4326
4327 sink[_add](outputEvent); 4327 sink[_add](outputEvent);
4328 } 4328 }
4329 } 4329 }
4330 dart.setSignature(_MapStream, { 4330 dart.setSignature(_MapStream, {
4331 methods: () => ({[_handleData]: dart.functionType(dart.void, [S, _EventSin k$(T)])}) 4331 methods: () => ({[_handleData]: [dart.void, [S, _EventSink$(T)]]})
4332 }); 4332 });
4333 return _MapStream; 4333 return _MapStream;
4334 }); 4334 });
4335 let _MapStream = _MapStream$(); 4335 let _MapStream = _MapStream$();
4336 let _expand = Symbol('_expand'); 4336 let _expand = Symbol('_expand');
4337 let _ExpandStream$ = dart.generic(function(S, T) { 4337 let _ExpandStream$ = dart.generic(function(S, T) {
4338 class _ExpandStream extends _ForwardingStream$(S, T) { 4338 class _ExpandStream extends _ForwardingStream$(S, T) {
4339 _ExpandStream(source, expand) { 4339 _ExpandStream(source, expand) {
4340 this[_expand] = expand; 4340 this[_expand] = expand;
4341 super._ForwardingStream(source); 4341 super._ForwardingStream(source);
4342 } 4342 }
4343 [_handleData](inputEvent, sink) { 4343 [_handleData](inputEvent, sink) {
4344 dart.as(inputEvent, S); 4344 dart.as(inputEvent, S);
4345 dart.as(sink, _EventSink$(T)); 4345 dart.as(sink, _EventSink$(T));
4346 try { 4346 try {
4347 for (let value of this[_expand](inputEvent)) { 4347 for (let value of this[_expand](inputEvent)) {
4348 sink[_add](value); 4348 sink[_add](value);
4349 } 4349 }
4350 } catch (e) { 4350 } catch (e) {
4351 let s = dart.stackTrace(e); 4351 let s = dart.stackTrace(e);
4352 _addErrorWithReplacement(sink, e, s); 4352 _addErrorWithReplacement(sink, e, s);
4353 } 4353 }
4354 4354
4355 } 4355 }
4356 } 4356 }
4357 dart.setSignature(_ExpandStream, { 4357 dart.setSignature(_ExpandStream, {
4358 methods: () => ({[_handleData]: dart.functionType(dart.void, [S, _EventSin k$(T)])}) 4358 methods: () => ({[_handleData]: [dart.void, [S, _EventSink$(T)]]})
4359 }); 4359 });
4360 return _ExpandStream; 4360 return _ExpandStream;
4361 }); 4361 });
4362 let _ExpandStream = _ExpandStream$(); 4362 let _ExpandStream = _ExpandStream$();
4363 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool, [dart.dynamic])); 4363 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool, [dart.dynamic]));
4364 let _HandleErrorStream$ = dart.generic(function(T) { 4364 let _HandleErrorStream$ = dart.generic(function(T) {
4365 class _HandleErrorStream extends _ForwardingStream$(T, T) { 4365 class _HandleErrorStream extends _ForwardingStream$(T, T) {
4366 _HandleErrorStream(source, onError, test) { 4366 _HandleErrorStream(source, onError, test) {
4367 this[_transform] = onError; 4367 this[_transform] = onError;
4368 this[_test] = test; 4368 this[_test] = test;
(...skipping 24 matching lines...) Expand all
4393 } 4393 }
4394 return; 4394 return;
4395 } 4395 }
4396 4396
4397 } else { 4397 } else {
4398 sink[_addError](error, stackTrace); 4398 sink[_addError](error, stackTrace);
4399 } 4399 }
4400 } 4400 }
4401 } 4401 }
4402 dart.setSignature(_HandleErrorStream, { 4402 dart.setSignature(_HandleErrorStream, {
4403 methods: () => ({[_handleError]: dart.functionType(dart.void, [core.Object , core.StackTrace, _EventSink$(T)])}) 4403 methods: () => ({[_handleError]: [dart.void, [core.Object, core.StackTrace , _EventSink$(T)]]})
4404 }); 4404 });
4405 return _HandleErrorStream; 4405 return _HandleErrorStream;
4406 }); 4406 });
4407 let _HandleErrorStream = _HandleErrorStream$(); 4407 let _HandleErrorStream = _HandleErrorStream$();
4408 let _remaining = Symbol('_remaining'); 4408 let _remaining = Symbol('_remaining');
4409 let _TakeStream$ = dart.generic(function(T) { 4409 let _TakeStream$ = dart.generic(function(T) {
4410 class _TakeStream extends _ForwardingStream$(T, T) { 4410 class _TakeStream extends _ForwardingStream$(T, T) {
4411 _TakeStream(source, count) { 4411 _TakeStream(source, count) {
4412 this[_remaining] = count; 4412 this[_remaining] = count;
4413 super._ForwardingStream(source); 4413 super._ForwardingStream(source);
4414 if (!(typeof count == 'number')) 4414 if (!(typeof count == 'number'))
4415 throw new core.ArgumentError(count); 4415 throw new core.ArgumentError(count);
4416 } 4416 }
4417 [_handleData](inputEvent, sink) { 4417 [_handleData](inputEvent, sink) {
4418 dart.as(inputEvent, T); 4418 dart.as(inputEvent, T);
4419 dart.as(sink, _EventSink$(T)); 4419 dart.as(sink, _EventSink$(T));
4420 if (dart.notNull(this[_remaining]) > 0) { 4420 if (dart.notNull(this[_remaining]) > 0) {
4421 sink[_add](inputEvent); 4421 sink[_add](inputEvent);
4422 this[_remaining] = dart.notNull(this[_remaining]) - 1; 4422 this[_remaining] = dart.notNull(this[_remaining]) - 1;
4423 if (this[_remaining] == 0) { 4423 if (this[_remaining] == 0) {
4424 sink[_close](); 4424 sink[_close]();
4425 } 4425 }
4426 } 4426 }
4427 } 4427 }
4428 } 4428 }
4429 dart.setSignature(_TakeStream, { 4429 dart.setSignature(_TakeStream, {
4430 methods: () => ({[_handleData]: dart.functionType(dart.void, [T, _EventSin k$(T)])}) 4430 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4431 }); 4431 });
4432 return _TakeStream; 4432 return _TakeStream;
4433 }); 4433 });
4434 let _TakeStream = _TakeStream$(); 4434 let _TakeStream = _TakeStream$();
4435 let _TakeWhileStream$ = dart.generic(function(T) { 4435 let _TakeWhileStream$ = dart.generic(function(T) {
4436 class _TakeWhileStream extends _ForwardingStream$(T, T) { 4436 class _TakeWhileStream extends _ForwardingStream$(T, T) {
4437 _TakeWhileStream(source, test) { 4437 _TakeWhileStream(source, test) {
4438 this[_test] = test; 4438 this[_test] = test;
4439 super._ForwardingStream(source); 4439 super._ForwardingStream(source);
4440 } 4440 }
(...skipping 11 matching lines...) Expand all
4452 } 4452 }
4453 4453
4454 if (satisfies) { 4454 if (satisfies) {
4455 sink[_add](inputEvent); 4455 sink[_add](inputEvent);
4456 } else { 4456 } else {
4457 sink[_close](); 4457 sink[_close]();
4458 } 4458 }
4459 } 4459 }
4460 } 4460 }
4461 dart.setSignature(_TakeWhileStream, { 4461 dart.setSignature(_TakeWhileStream, {
4462 methods: () => ({[_handleData]: dart.functionType(dart.void, [T, _EventSin k$(T)])}) 4462 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4463 }); 4463 });
4464 return _TakeWhileStream; 4464 return _TakeWhileStream;
4465 }); 4465 });
4466 let _TakeWhileStream = _TakeWhileStream$(); 4466 let _TakeWhileStream = _TakeWhileStream$();
4467 let _SkipStream$ = dart.generic(function(T) { 4467 let _SkipStream$ = dart.generic(function(T) {
4468 class _SkipStream extends _ForwardingStream$(T, T) { 4468 class _SkipStream extends _ForwardingStream$(T, T) {
4469 _SkipStream(source, count) { 4469 _SkipStream(source, count) {
4470 this[_remaining] = count; 4470 this[_remaining] = count;
4471 super._ForwardingStream(source); 4471 super._ForwardingStream(source);
4472 if (!(typeof count == 'number') || dart.notNull(count) < 0) 4472 if (!(typeof count == 'number') || dart.notNull(count) < 0)
4473 throw new core.ArgumentError(count); 4473 throw new core.ArgumentError(count);
4474 } 4474 }
4475 [_handleData](inputEvent, sink) { 4475 [_handleData](inputEvent, sink) {
4476 dart.as(inputEvent, T); 4476 dart.as(inputEvent, T);
4477 dart.as(sink, _EventSink$(T)); 4477 dart.as(sink, _EventSink$(T));
4478 if (dart.notNull(this[_remaining]) > 0) { 4478 if (dart.notNull(this[_remaining]) > 0) {
4479 this[_remaining] = dart.notNull(this[_remaining]) - 1; 4479 this[_remaining] = dart.notNull(this[_remaining]) - 1;
4480 return; 4480 return;
4481 } 4481 }
4482 sink[_add](inputEvent); 4482 sink[_add](inputEvent);
4483 } 4483 }
4484 } 4484 }
4485 dart.setSignature(_SkipStream, { 4485 dart.setSignature(_SkipStream, {
4486 methods: () => ({[_handleData]: dart.functionType(dart.void, [T, _EventSin k$(T)])}) 4486 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4487 }); 4487 });
4488 return _SkipStream; 4488 return _SkipStream;
4489 }); 4489 });
4490 let _SkipStream = _SkipStream$(); 4490 let _SkipStream = _SkipStream$();
4491 let _hasFailed = Symbol('_hasFailed'); 4491 let _hasFailed = Symbol('_hasFailed');
4492 let _SkipWhileStream$ = dart.generic(function(T) { 4492 let _SkipWhileStream$ = dart.generic(function(T) {
4493 class _SkipWhileStream extends _ForwardingStream$(T, T) { 4493 class _SkipWhileStream extends _ForwardingStream$(T, T) {
4494 _SkipWhileStream(source, test) { 4494 _SkipWhileStream(source, test) {
4495 this[_test] = test; 4495 this[_test] = test;
4496 this[_hasFailed] = false; 4496 this[_hasFailed] = false;
(...skipping 16 matching lines...) Expand all
4513 return; 4513 return;
4514 } 4514 }
4515 4515
4516 if (!dart.notNull(satisfies)) { 4516 if (!dart.notNull(satisfies)) {
4517 this[_hasFailed] = true; 4517 this[_hasFailed] = true;
4518 sink[_add](inputEvent); 4518 sink[_add](inputEvent);
4519 } 4519 }
4520 } 4520 }
4521 } 4521 }
4522 dart.setSignature(_SkipWhileStream, { 4522 dart.setSignature(_SkipWhileStream, {
4523 methods: () => ({[_handleData]: dart.functionType(dart.void, [T, _EventSin k$(T)])}) 4523 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4524 }); 4524 });
4525 return _SkipWhileStream; 4525 return _SkipWhileStream;
4526 }); 4526 });
4527 let _SkipWhileStream = _SkipWhileStream$(); 4527 let _SkipWhileStream = _SkipWhileStream$();
4528 let _Equality$ = dart.generic(function(T) { 4528 let _Equality$ = dart.generic(function(T) {
4529 let _Equality = dart.typedef('_Equality', () => dart.functionType(core.bool, [T, T])); 4529 let _Equality = dart.typedef('_Equality', () => dart.functionType(core.bool, [T, T]));
4530 return _Equality; 4530 return _Equality;
4531 }); 4531 });
4532 let _Equality = _Equality$(); 4532 let _Equality = _Equality$();
4533 let _equals = Symbol('_equals'); 4533 let _equals = Symbol('_equals');
(...skipping 25 matching lines...) Expand all
4559 } 4559 }
4560 4560
4561 if (!dart.notNull(isEqual)) { 4561 if (!dart.notNull(isEqual)) {
4562 sink[_add](inputEvent); 4562 sink[_add](inputEvent);
4563 this[_previous] = inputEvent; 4563 this[_previous] = inputEvent;
4564 } 4564 }
4565 } 4565 }
4566 } 4566 }
4567 } 4567 }
4568 dart.setSignature(_DistinctStream, { 4568 dart.setSignature(_DistinctStream, {
4569 methods: () => ({[_handleData]: dart.functionType(dart.void, [T, _EventSin k$(T)])}) 4569 methods: () => ({[_handleData]: [dart.void, [T, _EventSink$(T)]]})
4570 }); 4570 });
4571 return _DistinctStream; 4571 return _DistinctStream;
4572 }); 4572 });
4573 let _DistinctStream = _DistinctStream$(); 4573 let _DistinctStream = _DistinctStream$();
4574 dart.defineLazyProperties(_DistinctStream, { 4574 dart.defineLazyProperties(_DistinctStream, {
4575 get _SENTINEL() { 4575 get _SENTINEL() {
4576 return new core.Object(); 4576 return new core.Object();
4577 }, 4577 },
4578 set _SENTINEL(_) {} 4578 set _SENTINEL(_) {}
4579 }); 4579 });
(...skipping 11 matching lines...) Expand all
4591 stackTrace = null; 4591 stackTrace = null;
4592 this[_sink][_addError](error, stackTrace); 4592 this[_sink][_addError](error, stackTrace);
4593 } 4593 }
4594 close() { 4594 close() {
4595 this[_sink][_close](); 4595 this[_sink][_close]();
4596 } 4596 }
4597 } 4597 }
4598 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)]; 4598 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)];
4599 dart.setSignature(_EventSinkWrapper, { 4599 dart.setSignature(_EventSinkWrapper, {
4600 methods: () => ({ 4600 methods: () => ({
4601 add: dart.functionType(dart.void, [T]), 4601 add: [dart.void, [T]],
4602 addError: dart.functionType(dart.void, [dart.dynamic], [core.StackTrace] ), 4602 addError: [dart.void, [dart.dynamic], [core.StackTrace]],
4603 close: dart.functionType(dart.void, []) 4603 close: [dart.void, []]
4604 }) 4604 })
4605 }); 4605 });
4606 return _EventSinkWrapper; 4606 return _EventSinkWrapper;
4607 }); 4607 });
4608 let _EventSinkWrapper = _EventSinkWrapper$(); 4608 let _EventSinkWrapper = _EventSinkWrapper$();
4609 let _transformerSink = Symbol('_transformerSink'); 4609 let _transformerSink = Symbol('_transformerSink');
4610 let _isSubscribed = Symbol('_isSubscribed'); 4610 let _isSubscribed = Symbol('_isSubscribed');
4611 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { 4611 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) {
4612 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio n$(T) { 4612 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio n$(T) {
4613 _SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone , cancelOnError) { 4613 _SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone , cancelOnError) {
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after
4687 this[_transformerSink].close(); 4687 this[_transformerSink].close();
4688 } catch (e) { 4688 } catch (e) {
4689 let s = dart.stackTrace(e); 4689 let s = dart.stackTrace(e);
4690 this[_addError](e, s); 4690 this[_addError](e, s);
4691 } 4691 }
4692 4692
4693 } 4693 }
4694 } 4694 }
4695 dart.setSignature(_SinkTransformerStreamSubscription, { 4695 dart.setSignature(_SinkTransformerStreamSubscription, {
4696 methods: () => ({ 4696 methods: () => ({
4697 [_add]: dart.functionType(dart.void, [T]), 4697 [_add]: [dart.void, [T]],
4698 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace] ), 4698 [_addError]: [dart.void, [core.Object, core.StackTrace]],
4699 [_close]: dart.functionType(dart.void, []), 4699 [_close]: [dart.void, []],
4700 [_onPause]: dart.functionType(dart.void, []), 4700 [_onPause]: [dart.void, []],
4701 [_onResume]: dart.functionType(dart.void, []), 4701 [_onResume]: [dart.void, []],
4702 [_onCancel]: dart.functionType(Future, []), 4702 [_onCancel]: [Future, []],
4703 [_handleData]: dart.functionType(dart.void, [S]), 4703 [_handleData]: [dart.void, [S]],
4704 [_handleError]: dart.functionType(dart.void, [dart.dynamic], [dart.dynam ic]), 4704 [_handleError]: [dart.void, [dart.dynamic], [dart.dynamic]],
4705 [_handleDone]: dart.functionType(dart.void, []) 4705 [_handleDone]: [dart.void, []]
4706 }) 4706 })
4707 }); 4707 });
4708 return _SinkTransformerStreamSubscription; 4708 return _SinkTransformerStreamSubscription;
4709 }); 4709 });
4710 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$() ; 4710 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$() ;
4711 let _SinkMapper$ = dart.generic(function(S, T) { 4711 let _SinkMapper$ = dart.generic(function(S, T) {
4712 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS ink$(S), [EventSink$(T)])); 4712 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS ink$(S), [EventSink$(T)]));
4713 return _SinkMapper; 4713 return _SinkMapper;
4714 }); 4714 });
4715 let _SinkMapper = _SinkMapper$(); 4715 let _SinkMapper = _SinkMapper$();
4716 let _sinkMapper = Symbol('_sinkMapper'); 4716 let _sinkMapper = Symbol('_sinkMapper');
4717 let _StreamSinkTransformer$ = dart.generic(function(S, T) { 4717 let _StreamSinkTransformer$ = dart.generic(function(S, T) {
4718 class _StreamSinkTransformer extends core.Object { 4718 class _StreamSinkTransformer extends core.Object {
4719 _StreamSinkTransformer(sinkMapper) { 4719 _StreamSinkTransformer(sinkMapper) {
4720 this[_sinkMapper] = sinkMapper; 4720 this[_sinkMapper] = sinkMapper;
4721 } 4721 }
4722 bind(stream) { 4722 bind(stream) {
4723 dart.as(stream, Stream$(S)); 4723 dart.as(stream, Stream$(S));
4724 return new (_BoundSinkStream$(S, T))(stream, this[_sinkMapper]); 4724 return new (_BoundSinkStream$(S, T))(stream, this[_sinkMapper]);
4725 } 4725 }
4726 } 4726 }
4727 _StreamSinkTransformer[dart.implements] = () => [StreamTransformer$(S, T)]; 4727 _StreamSinkTransformer[dart.implements] = () => [StreamTransformer$(S, T)];
4728 dart.setSignature(_StreamSinkTransformer, { 4728 dart.setSignature(_StreamSinkTransformer, {
4729 methods: () => ({bind: dart.functionType(Stream$(T), [Stream$(S)])}) 4729 methods: () => ({bind: [Stream$(T), [Stream$(S)]]})
4730 }); 4730 });
4731 return _StreamSinkTransformer; 4731 return _StreamSinkTransformer;
4732 }); 4732 });
4733 let _StreamSinkTransformer = _StreamSinkTransformer$(); 4733 let _StreamSinkTransformer = _StreamSinkTransformer$();
4734 let _BoundSinkStream$ = dart.generic(function(S, T) { 4734 let _BoundSinkStream$ = dart.generic(function(S, T) {
4735 class _BoundSinkStream extends Stream$(T) { 4735 class _BoundSinkStream extends Stream$(T) {
4736 get isBroadcast() { 4736 get isBroadcast() {
4737 return this[_stream].isBroadcast; 4737 return this[_stream].isBroadcast;
4738 } 4738 }
4739 _BoundSinkStream(stream, sinkMapper) { 4739 _BoundSinkStream(stream, sinkMapper) {
4740 this[_stream] = stream; 4740 this[_stream] = stream;
4741 this[_sinkMapper] = sinkMapper; 4741 this[_sinkMapper] = sinkMapper;
4742 super.Stream(); 4742 super.Stream();
4743 } 4743 }
4744 listen(onData, opts) { 4744 listen(onData, opts) {
4745 dart.as(onData, dart.functionType(dart.void, [T])); 4745 dart.as(onData, dart.functionType(dart.void, [T]));
4746 let onError = opts && 'onError' in opts ? opts.onError : null; 4746 let onError = opts && 'onError' in opts ? opts.onError : null;
4747 let onDone = opts && 'onDone' in opts ? opts.onDone : null; 4747 let onDone = opts && 'onDone' in opts ? opts.onDone : null;
4748 dart.as(onDone, dart.functionType(dart.void, [])); 4748 dart.as(onDone, dart.functionType(dart.void, []));
4749 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null; 4749 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
4750 cancelOnError = core.identical(true, cancelOnError); 4750 cancelOnError = core.identical(true, cancelOnError);
4751 let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic , T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, o nDone, cancelOnError); 4751 let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic , T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, o nDone, cancelOnError);
4752 return subscription; 4752 return subscription;
4753 } 4753 }
4754 } 4754 }
4755 dart.setSignature(_BoundSinkStream, { 4755 dart.setSignature(_BoundSinkStream, {
4756 methods: () => ({listen: dart.functionType(StreamSubscription$(T), [dart.f unctionType(dart.void, [T])], {nErro: core.Function, nDon: dart.functionType(dar t.void, []), ancelOnErro: core.bool})}) 4756 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart. void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ance lOnErro: core.bool}]})
4757 }); 4757 });
4758 return _BoundSinkStream; 4758 return _BoundSinkStream;
4759 }); 4759 });
4760 let _BoundSinkStream = _BoundSinkStream$(); 4760 let _BoundSinkStream = _BoundSinkStream$();
4761 let _TransformDataHandler$ = dart.generic(function(S, T) { 4761 let _TransformDataHandler$ = dart.generic(function(S, T) {
4762 let _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart .functionType(dart.void, [S, EventSink$(T)])); 4762 let _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart .functionType(dart.void, [S, EventSink$(T)]));
4763 return _TransformDataHandler; 4763 return _TransformDataHandler;
4764 }); 4764 });
4765 let _TransformDataHandler = _TransformDataHandler$(); 4765 let _TransformDataHandler = _TransformDataHandler$();
4766 let _TransformErrorHandler$ = dart.generic(function(T) { 4766 let _TransformErrorHandler$ = dart.generic(function(T) {
(...skipping 23 matching lines...) Expand all
4790 stackTrace = null; 4790 stackTrace = null;
4791 return this[_handleError](error, stackTrace, this[_sink]); 4791 return this[_handleError](error, stackTrace, this[_sink]);
4792 } 4792 }
4793 close() { 4793 close() {
4794 return this[_handleDone](this[_sink]); 4794 return this[_handleDone](this[_sink]);
4795 } 4795 }
4796 } 4796 }
4797 _HandlerEventSink[dart.implements] = () => [EventSink$(S)]; 4797 _HandlerEventSink[dart.implements] = () => [EventSink$(S)];
4798 dart.setSignature(_HandlerEventSink, { 4798 dart.setSignature(_HandlerEventSink, {
4799 methods: () => ({ 4799 methods: () => ({
4800 add: dart.functionType(dart.void, [S]), 4800 add: [dart.void, [S]],
4801 addError: dart.functionType(dart.void, [core.Object], [core.StackTrace]) , 4801 addError: [dart.void, [core.Object], [core.StackTrace]],
4802 close: dart.functionType(dart.void, []) 4802 close: [dart.void, []]
4803 }) 4803 })
4804 }); 4804 });
4805 return _HandlerEventSink; 4805 return _HandlerEventSink;
4806 }); 4806 });
4807 let _HandlerEventSink = _HandlerEventSink$(); 4807 let _HandlerEventSink = _HandlerEventSink$();
4808 let _StreamHandlerTransformer$ = dart.generic(function(S, T) { 4808 let _StreamHandlerTransformer$ = dart.generic(function(S, T) {
4809 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { 4809 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) {
4810 _StreamHandlerTransformer(opts) { 4810 _StreamHandlerTransformer(opts) {
4811 let handleData = opts && 'handleData' in opts ? opts.handleData : null; 4811 let handleData = opts && 'handleData' in opts ? opts.handleData : null;
4812 let handleError = opts && 'handleError' in opts ? opts.handleError : nul l; 4812 let handleError = opts && 'handleError' in opts ? opts.handleError : nul l;
(...skipping 17 matching lines...) Expand all
4830 sink.add(data); 4830 sink.add(data);
4831 } 4831 }
4832 static _defaultHandleError(error, stackTrace, sink) { 4832 static _defaultHandleError(error, stackTrace, sink) {
4833 sink.addError(error); 4833 sink.addError(error);
4834 } 4834 }
4835 static _defaultHandleDone(sink) { 4835 static _defaultHandleDone(sink) {
4836 sink.close(); 4836 sink.close();
4837 } 4837 }
4838 } 4838 }
4839 dart.setSignature(_StreamHandlerTransformer, { 4839 dart.setSignature(_StreamHandlerTransformer, {
4840 methods: () => ({bind: dart.functionType(Stream$(T), [Stream$(S)])}), 4840 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}),
4841 statics: () => ({ 4841 statics: () => ({
4842 _defaultHandleData: dart.functionType(dart.void, [dart.dynamic, EventSin k]), 4842 _defaultHandleData: [dart.void, [dart.dynamic, EventSink]],
4843 _defaultHandleError: dart.functionType(dart.void, [dart.dynamic, core.St ackTrace, EventSink]), 4843 _defaultHandleError: [dart.void, [dart.dynamic, core.StackTrace, EventSi nk]],
4844 _defaultHandleDone: dart.functionType(dart.void, [EventSink]) 4844 _defaultHandleDone: [dart.void, [EventSink]]
4845 }), 4845 }),
4846 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone'] 4846 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone']
4847 }); 4847 });
4848 return _StreamHandlerTransformer; 4848 return _StreamHandlerTransformer;
4849 }); 4849 });
4850 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); 4850 let _StreamHandlerTransformer = _StreamHandlerTransformer$();
4851 let _SubscriptionTransformer$ = dart.generic(function(S, T) { 4851 let _SubscriptionTransformer$ = dart.generic(function(S, T) {
4852 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () = > dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool])); 4852 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () = > dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool]));
4853 return _SubscriptionTransformer; 4853 return _SubscriptionTransformer;
4854 }); 4854 });
4855 let _SubscriptionTransformer = _SubscriptionTransformer$(); 4855 let _SubscriptionTransformer = _SubscriptionTransformer$();
4856 let _transformer = Symbol('_transformer'); 4856 let _transformer = Symbol('_transformer');
4857 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { 4857 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) {
4858 class _StreamSubscriptionTransformer extends core.Object { 4858 class _StreamSubscriptionTransformer extends core.Object {
4859 _StreamSubscriptionTransformer(transformer) { 4859 _StreamSubscriptionTransformer(transformer) {
4860 this[_transformer] = transformer; 4860 this[_transformer] = transformer;
4861 } 4861 }
4862 bind(stream) { 4862 bind(stream) {
4863 dart.as(stream, Stream$(S)); 4863 dart.as(stream, Stream$(S));
4864 return new (_BoundSubscriptionStream$(S, T))(stream, this[_transformer]) ; 4864 return new (_BoundSubscriptionStream$(S, T))(stream, this[_transformer]) ;
4865 } 4865 }
4866 } 4866 }
4867 _StreamSubscriptionTransformer[dart.implements] = () => [StreamTransformer$( S, T)]; 4867 _StreamSubscriptionTransformer[dart.implements] = () => [StreamTransformer$( S, T)];
4868 dart.setSignature(_StreamSubscriptionTransformer, { 4868 dart.setSignature(_StreamSubscriptionTransformer, {
4869 methods: () => ({bind: dart.functionType(Stream$(T), [Stream$(S)])}) 4869 methods: () => ({bind: [Stream$(T), [Stream$(S)]]})
4870 }); 4870 });
4871 return _StreamSubscriptionTransformer; 4871 return _StreamSubscriptionTransformer;
4872 }); 4872 });
4873 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(); 4873 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$();
4874 let _BoundSubscriptionStream$ = dart.generic(function(S, T) { 4874 let _BoundSubscriptionStream$ = dart.generic(function(S, T) {
4875 class _BoundSubscriptionStream extends Stream$(T) { 4875 class _BoundSubscriptionStream extends Stream$(T) {
4876 _BoundSubscriptionStream(stream, transformer) { 4876 _BoundSubscriptionStream(stream, transformer) {
4877 this[_stream] = stream; 4877 this[_stream] = stream;
4878 this[_transformer] = transformer; 4878 this[_transformer] = transformer;
4879 super.Stream(); 4879 super.Stream();
4880 } 4880 }
4881 listen(onData, opts) { 4881 listen(onData, opts) {
4882 dart.as(onData, dart.functionType(dart.void, [T])); 4882 dart.as(onData, dart.functionType(dart.void, [T]));
4883 let onError = opts && 'onError' in opts ? opts.onError : null; 4883 let onError = opts && 'onError' in opts ? opts.onError : null;
4884 let onDone = opts && 'onDone' in opts ? opts.onDone : null; 4884 let onDone = opts && 'onDone' in opts ? opts.onDone : null;
4885 dart.as(onDone, dart.functionType(dart.void, [])); 4885 dart.as(onDone, dart.functionType(dart.void, []));
4886 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null; 4886 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
4887 cancelOnError = core.identical(true, cancelOnError); 4887 cancelOnError = core.identical(true, cancelOnError);
4888 let result = this[_transformer](this[_stream], cancelOnError); 4888 let result = this[_transformer](this[_stream], cancelOnError);
4889 result.onData(onData); 4889 result.onData(onData);
4890 result.onError(onError); 4890 result.onError(onError);
4891 result.onDone(onDone); 4891 result.onDone(onDone);
4892 return result; 4892 return result;
4893 } 4893 }
4894 } 4894 }
4895 dart.setSignature(_BoundSubscriptionStream, { 4895 dart.setSignature(_BoundSubscriptionStream, {
4896 methods: () => ({listen: dart.functionType(StreamSubscription$(T), [dart.f unctionType(dart.void, [T])], {nErro: core.Function, nDon: dart.functionType(dar t.void, []), ancelOnErro: core.bool})}) 4896 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart. void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), ance lOnErro: core.bool}]})
4897 }); 4897 });
4898 return _BoundSubscriptionStream; 4898 return _BoundSubscriptionStream;
4899 }); 4899 });
4900 let _BoundSubscriptionStream = _BoundSubscriptionStream$(); 4900 let _BoundSubscriptionStream = _BoundSubscriptionStream$();
4901 let __CastType27$ = dart.generic(function(S, T) { 4901 let __CastType27$ = dart.generic(function(S, T) {
4902 let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart .void, [S, EventSink$(T)])); 4902 let __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart .void, [S, EventSink$(T)]));
4903 return __CastType27; 4903 return __CastType27;
4904 }); 4904 });
4905 let __CastType27 = __CastType27$(); 4905 let __CastType27 = __CastType27$();
4906 let __CastType30$ = dart.generic(function(T) { 4906 let __CastType30$ = dart.generic(function(T) {
(...skipping 26 matching lines...) Expand all
4933 static _createPeriodicTimer(duration, callback) { 4933 static _createPeriodicTimer(duration, callback) {
4934 let milliseconds = duration.inMilliseconds; 4934 let milliseconds = duration.inMilliseconds;
4935 if (dart.notNull(milliseconds) < 0) 4935 if (dart.notNull(milliseconds) < 0)
4936 milliseconds = 0; 4936 milliseconds = 0;
4937 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback); 4937 return new _isolate_helper.TimerImpl.periodic(milliseconds, callback);
4938 } 4938 }
4939 } 4939 }
4940 dart.defineNamedConstructor(Timer, 'periodic'); 4940 dart.defineNamedConstructor(Timer, 'periodic');
4941 dart.setSignature(Timer, { 4941 dart.setSignature(Timer, {
4942 statics: () => ({ 4942 statics: () => ({
4943 run: dart.functionType(dart.void, [dart.functionType(dart.void, [])]), 4943 run: [dart.void, [dart.functionType(dart.void, [])]],
4944 _createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(d art.void, [])]), 4944 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
4945 _createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functi onType(dart.void, [Timer])]) 4945 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]]
4946 }), 4946 }),
4947 names: ['run', '_createTimer', '_createPeriodicTimer'] 4947 names: ['run', '_createTimer', '_createPeriodicTimer']
4948 }); 4948 });
4949 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v oid, [Timer])); 4949 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v oid, [Timer]));
4950 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart.d ynamic, [])); 4950 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart.d ynamic, []));
4951 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT ype(dart.dynamic, [dart.dynamic])); 4951 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT ype(dart.dynamic, [dart.dynamic]));
4952 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functio nType(dart.dynamic, [dart.dynamic, dart.dynamic])); 4952 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functio nType(dart.dynamic, [dart.dynamic, dart.dynamic]));
4953 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', () => dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, cor e.StackTrace])); 4953 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', () => dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, cor e.StackTrace]));
4954 let RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dynam ic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); 4954 let RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dynam ic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])]));
4955 let RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionType( dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.d ynamic]), dart.dynamic])); 4955 let RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionType( dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.d ynamic]), dart.dynamic]));
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after
5041 return previous; 5041 return previous;
5042 } 5042 }
5043 static _leave(previous) { 5043 static _leave(previous) {
5044 dart.assert(previous != null); 5044 dart.assert(previous != null);
5045 Zone._current = previous; 5045 Zone._current = previous;
5046 } 5046 }
5047 } 5047 }
5048 dart.defineNamedConstructor(Zone, '_'); 5048 dart.defineNamedConstructor(Zone, '_');
5049 dart.setSignature(Zone, { 5049 dart.setSignature(Zone, {
5050 statics: () => ({ 5050 statics: () => ({
5051 _enter: dart.functionType(Zone, [Zone]), 5051 _enter: [Zone, [Zone]],
5052 _leave: dart.functionType(dart.void, [Zone]) 5052 _leave: [dart.void, [Zone]]
5053 }), 5053 }),
5054 names: ['_enter', '_leave'] 5054 names: ['_enter', '_leave']
5055 }); 5055 });
5056 class _Zone extends core.Object { 5056 class _Zone extends core.Object {
5057 _Zone() { 5057 _Zone() {
5058 } 5058 }
5059 inSameErrorZone(otherZone) { 5059 inSameErrorZone(otherZone) {
5060 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone)); 5060 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone));
5061 } 5061 }
5062 } 5062 }
5063 _Zone[dart.implements] = () => [Zone]; 5063 _Zone[dart.implements] = () => [Zone];
5064 dart.setSignature(_Zone, { 5064 dart.setSignature(_Zone, {
5065 methods: () => ({inSameErrorZone: dart.functionType(core.bool, [Zone])}) 5065 methods: () => ({inSameErrorZone: [core.bool, [Zone]]})
5066 }); 5066 });
5067 let _run = Symbol('_run'); 5067 let _run = Symbol('_run');
5068 let _runUnary = Symbol('_runUnary'); 5068 let _runUnary = Symbol('_runUnary');
5069 let _runBinary = Symbol('_runBinary'); 5069 let _runBinary = Symbol('_runBinary');
5070 let _registerCallback = Symbol('_registerCallback'); 5070 let _registerCallback = Symbol('_registerCallback');
5071 let _registerUnaryCallback = Symbol('_registerUnaryCallback'); 5071 let _registerUnaryCallback = Symbol('_registerUnaryCallback');
5072 let _registerBinaryCallback = Symbol('_registerBinaryCallback'); 5072 let _registerBinaryCallback = Symbol('_registerBinaryCallback');
5073 let _errorCallback = Symbol('_errorCallback'); 5073 let _errorCallback = Symbol('_errorCallback');
5074 let _scheduleMicrotask = Symbol('_scheduleMicrotask'); 5074 let _scheduleMicrotask = Symbol('_scheduleMicrotask');
5075 let _createTimer = Symbol('_createTimer'); 5075 let _createTimer = Symbol('_createTimer');
(...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after
5242 } 5242 }
5243 createPeriodicTimer(duration, f) { 5243 createPeriodicTimer(duration, f) {
5244 return Timer._createPeriodicTimer(duration, f); 5244 return Timer._createPeriodicTimer(duration, f);
5245 } 5245 }
5246 print(line) { 5246 print(line) {
5247 _internal.printToConsole(line); 5247 _internal.printToConsole(line);
5248 } 5248 }
5249 } 5249 }
5250 dart.setSignature(_RootZone, { 5250 dart.setSignature(_RootZone, {
5251 methods: () => ({ 5251 methods: () => ({
5252 runGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.dynami c, [])]), 5252 runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
5253 runUnaryGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.d ynamic, [dart.dynamic]), dart.dynamic]), 5253 runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dyn amic]), dart.dynamic]],
5254 runBinaryGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart. dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), 5254 runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dy namic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5255 bindCallback: dart.functionType(ZoneCallback, [dart.functionType(dart.dyna mic, [])], {unGuarde: core.bool}), 5255 bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {unGua rde: core.bool}],
5256 bindUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.functionType (dart.dynamic, [dart.dynamic])], {unGuarde: core.bool}), 5256 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [d art.dynamic])], {unGuarde: core.bool}],
5257 bindBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functionTy pe(dart.dynamic, [dart.dynamic, dart.dynamic])], {unGuarde: core.bool}), 5257 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])], {unGuarde: core.bool}],
5258 get: dart.functionType(dart.dynamic, [core.Object]), 5258 get: [dart.dynamic, [core.Object]],
5259 handleUncaughtError: dart.functionType(dart.dynamic, [dart.dynamic, core.S tackTrace]), 5259 handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]],
5260 fork: dart.functionType(Zone, [], {pecificatio: ZoneSpecification, oneValu e: core.Map}), 5260 fork: [Zone, [], {pecificatio: ZoneSpecification, oneValue: core.Map}],
5261 run: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic, [])] ), 5261 run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
5262 runUnary: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]), 5262 runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]],
5263 runBinary: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic , [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), 5263 runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5264 registerCallback: dart.functionType(ZoneCallback, [dart.functionType(dart. dynamic, [])]), 5264 registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]],
5265 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.function Type(dart.dynamic, [dart.dynamic])]), 5265 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic , [dart.dynamic])]],
5266 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functi onType(dart.dynamic, [dart.dynamic, dart.dynamic])]), 5266 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynam ic, [dart.dynamic, dart.dynamic])]],
5267 errorCallback: dart.functionType(AsyncError, [core.Object, core.StackTrace ]), 5267 errorCallback: [AsyncError, [core.Object, core.StackTrace]],
5268 scheduleMicrotask: dart.functionType(dart.void, [dart.functionType(dart.vo id, [])]), 5268 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]],
5269 createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(da rt.void, [])]), 5269 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
5270 createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functio nType(dart.void, [Timer])]), 5270 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]],
5271 print: dart.functionType(dart.void, [core.String]) 5271 print: [dart.void, [core.String]]
5272 }) 5272 })
5273 }); 5273 });
5274 let _ROOT_ZONE = dart.const(new _RootZone()); 5274 let _ROOT_ZONE = dart.const(new _RootZone());
5275 Zone.ROOT = _ROOT_ZONE; 5275 Zone.ROOT = _ROOT_ZONE;
5276 Zone._current = _ROOT_ZONE; 5276 Zone._current = _ROOT_ZONE;
5277 function _parentDelegate(zone) { 5277 function _parentDelegate(zone) {
5278 if (zone.parent == null) 5278 if (zone.parent == null)
5279 return null; 5279 return null;
5280 return zone.parent[_delegate]; 5280 return zone.parent[_delegate];
5281 } 5281 }
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after
5349 } 5349 }
5350 fork(zone, specification, zoneValues) { 5350 fork(zone, specification, zoneValues) {
5351 let implementation = this[_delegationTarget][_fork]; 5351 let implementation = this[_delegationTarget][_fork];
5352 let implZone = implementation.zone; 5352 let implZone = implementation.zone;
5353 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega te(implZone), zone, specification, zoneValues), Zone); 5353 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega te(implZone), zone, specification, zoneValues), Zone);
5354 } 5354 }
5355 } 5355 }
5356 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; 5356 _ZoneDelegate[dart.implements] = () => [ZoneDelegate];
5357 dart.setSignature(_ZoneDelegate, { 5357 dart.setSignature(_ZoneDelegate, {
5358 methods: () => ({ 5358 methods: () => ({
5359 handleUncaughtError: dart.functionType(dart.dynamic, [Zone, dart.dynamic, core.StackTrace]), 5359 handleUncaughtError: [dart.dynamic, [Zone, dart.dynamic, core.StackTrace]] ,
5360 run: dart.functionType(dart.dynamic, [Zone, dart.functionType(dart.dynamic , [])]), 5360 run: [dart.dynamic, [Zone, dart.functionType(dart.dynamic, [])]],
5361 runUnary: dart.functionType(dart.dynamic, [Zone, dart.functionType(dart.dy namic, [dart.dynamic]), dart.dynamic]), 5361 runUnary: [dart.dynamic, [Zone, dart.functionType(dart.dynamic, [dart.dyna mic]), dart.dynamic]],
5362 runBinary: dart.functionType(dart.dynamic, [Zone, dart.functionType(dart.d ynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), 5362 runBinary: [dart.dynamic, [Zone, dart.functionType(dart.dynamic, [dart.dyn amic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5363 registerCallback: dart.functionType(ZoneCallback, [Zone, dart.functionType (dart.dynamic, [])]), 5363 registerCallback: [ZoneCallback, [Zone, dart.functionType(dart.dynamic, [] )]],
5364 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [Zone, dart.fu nctionType(dart.dynamic, [dart.dynamic])]), 5364 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(dart.d ynamic, [dart.dynamic])]],
5365 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, dart. functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]), 5365 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(dart .dynamic, [dart.dynamic, dart.dynamic])]],
5366 errorCallback: dart.functionType(AsyncError, [Zone, core.Object, core.Stac kTrace]), 5366 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]],
5367 scheduleMicrotask: dart.functionType(dart.void, [Zone, dart.functionType(d art.dynamic, [])]), 5367 scheduleMicrotask: [dart.void, [Zone, dart.functionType(dart.dynamic, [])] ],
5368 createTimer: dart.functionType(Timer, [Zone, core.Duration, dart.functionT ype(dart.void, [])]), 5368 createTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.void, [] )]],
5369 createPeriodicTimer: dart.functionType(Timer, [Zone, core.Duration, dart.f unctionType(dart.void, [Timer])]), 5369 createPeriodicTimer: [Timer, [Zone, core.Duration, dart.functionType(dart. void, [Timer])]],
5370 print: dart.functionType(dart.void, [Zone, core.String]), 5370 print: [dart.void, [Zone, core.String]],
5371 fork: dart.functionType(Zone, [Zone, ZoneSpecification, core.Map]) 5371 fork: [Zone, [Zone, ZoneSpecification, core.Map]]
5372 }) 5372 })
5373 }); 5373 });
5374 let _delegateCache = Symbol('_delegateCache'); 5374 let _delegateCache = Symbol('_delegateCache');
5375 class _CustomZone extends _Zone { 5375 class _CustomZone extends _Zone {
5376 get [_delegate]() { 5376 get [_delegate]() {
5377 if (this[_delegateCache] != null) 5377 if (this[_delegateCache] != null)
5378 return this[_delegateCache]; 5378 return this[_delegateCache];
5379 this[_delegateCache] = new _ZoneDelegate(this); 5379 this[_delegateCache] = new _ZoneDelegate(this);
5380 return this[_delegateCache]; 5380 return this[_delegateCache];
5381 } 5381 }
(...skipping 179 matching lines...) Expand 10 before | Expand all | Expand 10 after
5561 } 5561 }
5562 print(line) { 5562 print(line) {
5563 let implementation = this[_print]; 5563 let implementation = this[_print];
5564 dart.assert(implementation != null); 5564 dart.assert(implementation != null);
5565 let parentDelegate = _parentDelegate(implementation.zone); 5565 let parentDelegate = _parentDelegate(implementation.zone);
5566 return dart.dcall(implementation.function, implementation.zone, parentDele gate, this, line); 5566 return dart.dcall(implementation.function, implementation.zone, parentDele gate, this, line);
5567 } 5567 }
5568 } 5568 }
5569 dart.setSignature(_CustomZone, { 5569 dart.setSignature(_CustomZone, {
5570 methods: () => ({ 5570 methods: () => ({
5571 runGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.dynami c, [])]), 5571 runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
5572 runUnaryGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.d ynamic, [dart.dynamic]), dart.dynamic]), 5572 runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dyn amic]), dart.dynamic]],
5573 runBinaryGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart. dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), 5573 runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dy namic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5574 bindCallback: dart.functionType(ZoneCallback, [dart.functionType(dart.dyna mic, [])], {unGuarde: core.bool}), 5574 bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {unGua rde: core.bool}],
5575 bindUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.functionType (dart.dynamic, [dart.dynamic])], {unGuarde: core.bool}), 5575 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [d art.dynamic])], {unGuarde: core.bool}],
5576 bindBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functionTy pe(dart.dynamic, [dart.dynamic, dart.dynamic])], {unGuarde: core.bool}), 5576 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])], {unGuarde: core.bool}],
5577 get: dart.functionType(dart.dynamic, [core.Object]), 5577 get: [dart.dynamic, [core.Object]],
5578 handleUncaughtError: dart.functionType(dart.dynamic, [dart.dynamic, core.S tackTrace]), 5578 handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]],
5579 fork: dart.functionType(Zone, [], {pecificatio: ZoneSpecification, oneValu e: core.Map}), 5579 fork: [Zone, [], {pecificatio: ZoneSpecification, oneValue: core.Map}],
5580 run: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic, [])] ), 5580 run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]],
5581 runUnary: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]), 5581 runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]],
5582 runBinary: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic , [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), 5582 runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]],
5583 registerCallback: dart.functionType(ZoneCallback, [dart.functionType(dart. dynamic, [])]), 5583 registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]],
5584 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.function Type(dart.dynamic, [dart.dynamic])]), 5584 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic , [dart.dynamic])]],
5585 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functi onType(dart.dynamic, [dart.dynamic, dart.dynamic])]), 5585 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynam ic, [dart.dynamic, dart.dynamic])]],
5586 errorCallback: dart.functionType(AsyncError, [core.Object, core.StackTrace ]), 5586 errorCallback: [AsyncError, [core.Object, core.StackTrace]],
5587 scheduleMicrotask: dart.functionType(dart.void, [dart.functionType(dart.vo id, [])]), 5587 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]],
5588 createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(da rt.void, [])]), 5588 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]],
5589 createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functio nType(dart.void, [Timer])]), 5589 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]],
5590 print: dart.functionType(dart.void, [core.String]) 5590 print: [dart.void, [core.String]]
5591 }) 5591 })
5592 }); 5592 });
5593 function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) { 5593 function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) {
5594 _schedulePriorityAsyncCallback(dart.fn(() => { 5594 _schedulePriorityAsyncCallback(dart.fn(() => {
5595 throw new _UncaughtAsyncError(error, stackTrace); 5595 throw new _UncaughtAsyncError(error, stackTrace);
5596 })); 5596 }));
5597 } 5597 }
5598 dart.fn(_rootHandleUncaughtError, dart.void, [Zone, ZoneDelegate, Zone, dart.d ynamic, core.StackTrace]); 5598 dart.fn(_rootHandleUncaughtError, dart.void, [Zone, ZoneDelegate, Zone, dart.d ynamic, core.StackTrace]);
5599 function _rootRun(self, parent, zone, f) { 5599 function _rootRun(self, parent, zone, f) {
5600 if (dart.equals(Zone._current, zone)) 5600 if (dart.equals(Zone._current, zone))
(...skipping 230 matching lines...) Expand 10 before | Expand all | Expand 10 after
5831 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; 5831 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler;
5832 exports.CreateTimerHandler = CreateTimerHandler; 5832 exports.CreateTimerHandler = CreateTimerHandler;
5833 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; 5833 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler;
5834 exports.PrintHandler = PrintHandler; 5834 exports.PrintHandler = PrintHandler;
5835 exports.ForkHandler = ForkHandler; 5835 exports.ForkHandler = ForkHandler;
5836 exports.ZoneSpecification = ZoneSpecification; 5836 exports.ZoneSpecification = ZoneSpecification;
5837 exports.ZoneDelegate = ZoneDelegate; 5837 exports.ZoneDelegate = ZoneDelegate;
5838 exports.Zone = Zone; 5838 exports.Zone = Zone;
5839 exports.runZoned = runZoned; 5839 exports.runZoned = runZoned;
5840 })(async, core, _internal, _js_helper, _isolate_helper, collection); 5840 })(async, core, _internal, _js_helper, _isolate_helper, collection);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698