| OLD | NEW |
| 1 var async = dart.defineLibrary(async, {}); | 1 var async = dart.defineLibrary(async, {}); |
| 2 var core = dart.import(core); | 2 var core = dart.import(core); |
| 3 var _internal = dart.import(_internal); | 3 var _internal = dart.import(_internal); |
| 4 var _js_helper = dart.lazyImport(_js_helper); | 4 var _js_helper = dart.lazyImport(_js_helper); |
| 5 var _isolate_helper = dart.lazyImport(_isolate_helper); | 5 var _isolate_helper = dart.lazyImport(_isolate_helper); |
| 6 var collection = dart.import(collection); | 6 var collection = dart.import(collection); |
| 7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { | 7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { |
| 8 'use strict'; | 8 'use strict'; |
| 9 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 9 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
| 10 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 10 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
| (...skipping 15 matching lines...) Expand all Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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); |
| OLD | NEW |