| 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)) { |
| 11 return dart.dcall(errorHandler, error, stackTrace); | 11 return dart.dcall(errorHandler, error, stackTrace); |
| 12 } else { | 12 } else { |
| 13 return dart.dcall(errorHandler, error); | 13 return dart.dcall(errorHandler, error); |
| 14 } | 14 } |
| 15 } | 15 } |
| 16 dart.fn(_invokeErrorHandler, dart.dynamic, [core.Function, core.Object, core.S
tackTrace]); | 16 dart.fn(_invokeErrorHandler, core.Object, [core.Function, core.Object, core.St
ackTrace]); |
| 17 function _registerErrorHandler(errorHandler, zone) { | 17 function _registerErrorHandler(errorHandler, zone) { |
| 18 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 18 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
| 19 return zone.registerBinaryCallback(errorHandler); | 19 return zone.registerBinaryCallback(errorHandler); |
| 20 } else { | 20 } else { |
| 21 return zone.registerUnaryCallback(dart.as(errorHandler, __CastType0)); | 21 return zone.registerUnaryCallback(dart.as(errorHandler, __CastType0)); |
| 22 } | 22 } |
| 23 } | 23 } |
| 24 dart.fn(_registerErrorHandler, () => dart.functionType(core.Function, [core.Fu
nction, Zone])); | 24 dart.fn(_registerErrorHandler, () => dart.functionType(core.Function, [core.Fu
nction, Zone])); |
| 25 class AsyncError extends core.Object { | 25 class AsyncError extends core.Object { |
| 26 AsyncError(error, stackTrace) { | 26 AsyncError(error, stackTrace) { |
| (...skipping 19 matching lines...) Expand all Loading... |
| 46 } | 46 } |
| 47 toString() { | 47 toString() { |
| 48 let result = `Uncaught Error: ${this.error}`; | 48 let result = `Uncaught Error: ${this.error}`; |
| 49 if (this.stackTrace != null) { | 49 if (this.stackTrace != null) { |
| 50 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; | 50 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; |
| 51 } | 51 } |
| 52 return result; | 52 return result; |
| 53 } | 53 } |
| 54 } | 54 } |
| 55 dart.setSignature(_UncaughtAsyncError, { | 55 dart.setSignature(_UncaughtAsyncError, { |
| 56 statics: () => ({_getBestStackTrace: dart.functionType(core.StackTrace, [dar
t.dynamic, core.StackTrace])}), | 56 statics: () => ({_getBestStackTrace: dart.functionType(core.StackTrace, [cor
e.Object, core.StackTrace])}), |
| 57 names: ['_getBestStackTrace'] | 57 names: ['_getBestStackTrace'] |
| 58 }); | 58 }); |
| 59 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn
amic, [dart.dynamic])); | 59 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(core.Obj
ect, [dart.bottom])); |
| 60 let _add = Symbol('_add'); | 60 let _add = Symbol('_add'); |
| 61 let _closeUnchecked = Symbol('_closeUnchecked'); | 61 let _closeUnchecked = Symbol('_closeUnchecked'); |
| 62 let _addError = Symbol('_addError'); | 62 let _addError = Symbol('_addError'); |
| 63 let _completeError = Symbol('_completeError'); | 63 let _completeError = Symbol('_completeError'); |
| 64 let _complete = Symbol('_complete'); | 64 let _complete = Symbol('_complete'); |
| 65 let _sink = Symbol('_sink'); | 65 let _sink = Symbol('_sink'); |
| 66 let Stream$ = dart.generic(function(T) { | 66 let Stream$ = dart.generic(function(T) { |
| 67 class Stream extends core.Object { | 67 class Stream extends core.Object { |
| 68 Stream() { | 68 Stream() { |
| 69 } | 69 } |
| 70 fromFuture(future) { | 70 fromFuture(future) { |
| 71 let controller = dart.as(new (StreamController$(T))({sync: true}), _Stre
amController$(T)); | 71 let controller = dart.as(new (StreamController$(T))({sync: true}), _Stre
amController$(T)); |
| 72 future.then(dart.fn(value => { | 72 future.then(dart.fn(value => { |
| 73 controller[_add](dart.as(value, T)); | 73 controller[_add](dart.as(value, T)); |
| 74 controller[_closeUnchecked](); | 74 controller[_closeUnchecked](); |
| 75 }), {onError: dart.fn((error, stackTrace) => { | 75 }), {onError: dart.fn((error, stackTrace) => { |
| 76 controller[_addError](error, dart.as(stackTrace, core.StackTrace)); | 76 controller[_addError](error, dart.as(stackTrace, core.StackTrace)); |
| 77 controller[_closeUnchecked](); | 77 controller[_closeUnchecked](); |
| 78 })}); | 78 })}); |
| 79 return controller.stream; | 79 return controller.stream; |
| 80 } | 80 } |
| 81 fromIterable(data) { | 81 fromIterable(data) { |
| 82 return new (_GeneratedStreamImpl$(T))(dart.fn(() => new (_IterablePendin
gEvents$(T))(data), _IterablePendingEvents$(T), [])); | 82 return new (_GeneratedStreamImpl$(T))(dart.fn(() => new (_IterablePendin
gEvents$(T))(data), _IterablePendingEvents$(T), [])); |
| 83 } | 83 } |
| 84 periodic(period, computation) { | 84 periodic(period, computation) { |
| 85 if (computation === void 0) | 85 if (computation === void 0) |
| 86 computation = null; | 86 computation = null; |
| 87 if (computation == null) | 87 if (computation == null) |
| 88 computation = dart.fn(i => null, dart.bottom, [dart.dynamic]); | 88 computation = dart.fn(i => null, dart.bottom, [core.Object]); |
| 89 let timer = null; | 89 let timer = null; |
| 90 let computationCount = 0; | 90 let computationCount = 0; |
| 91 let controller = null; | 91 let controller = null; |
| 92 let watch = new core.Stopwatch(); | 92 let watch = new core.Stopwatch(); |
| 93 let sendEvent = () => { | 93 let sendEvent = () => { |
| 94 watch.reset(); | 94 watch.reset(); |
| 95 let data = computation((() => { | 95 let data = computation((() => { |
| 96 let x = computationCount; | 96 let x = computationCount; |
| 97 computationCount = dart.notNull(x) + 1; | 97 computationCount = dart.notNull(x) + 1; |
| 98 return x; | 98 return x; |
| 99 })()); | 99 })()); |
| 100 controller.add(data); | 100 controller.add(data); |
| 101 }; | 101 }; |
| 102 dart.fn(sendEvent, dart.void, []); | 102 dart.fn(sendEvent, dart.void, []); |
| 103 let startPeriodicTimer = () => { | 103 let startPeriodicTimer = () => { |
| 104 dart.assert(timer == null); | 104 dart.assert(timer == null); |
| 105 timer = new Timer.periodic(period, dart.fn(timer => { | 105 timer = new Timer.periodic(period, dart.fn(timer => { |
| 106 sendEvent(); | 106 sendEvent(); |
| 107 }, dart.dynamic, [Timer])); | 107 }, core.Object, [Timer])); |
| 108 }; | 108 }; |
| 109 dart.fn(startPeriodicTimer, dart.void, []); | 109 dart.fn(startPeriodicTimer, dart.void, []); |
| 110 controller = new (StreamController$(T))({sync: true, onListen: dart.fn((
) => { | 110 controller = new (StreamController$(T))({sync: true, onListen: dart.fn((
) => { |
| 111 watch.start(); | 111 watch.start(); |
| 112 startPeriodicTimer(); | 112 startPeriodicTimer(); |
| 113 }), onPause: dart.fn(() => { | 113 }), onPause: dart.fn(() => { |
| 114 timer.cancel(); | 114 timer.cancel(); |
| 115 timer = null; | 115 timer = null; |
| 116 watch.stop(); | 116 watch.stop(); |
| 117 }), onResume: dart.fn(() => { | 117 }), onResume: dart.fn(() => { |
| 118 dart.assert(timer == null); | 118 dart.assert(timer == null); |
| 119 let elapsed = watch.elapsed; | 119 let elapsed = watch.elapsed; |
| 120 watch.start(); | 120 watch.start(); |
| 121 timer = new Timer(period['-'](elapsed), dart.fn(() => { | 121 timer = new Timer(period['-'](elapsed), dart.fn(() => { |
| 122 timer = null; | 122 timer = null; |
| 123 startPeriodicTimer(); | 123 startPeriodicTimer(); |
| 124 sendEvent(); | 124 sendEvent(); |
| 125 })); | 125 })); |
| 126 }), onCancel: dart.fn(() => { | 126 }), onCancel: dart.fn(() => { |
| 127 if (timer != null) | 127 if (timer != null) |
| 128 timer.cancel(); | 128 timer.cancel(); |
| 129 timer = null; | 129 timer = null; |
| 130 })}); | 130 })}); |
| 131 return controller.stream; | 131 return controller.stream; |
| 132 } | 132 } |
| 133 eventTransformed(source, mapSink) { | 133 eventTransformed(source, mapSink) { |
| 134 return new (_BoundSinkStream$(dart.dynamic, T))(source, dart.as(mapSink,
_SinkMapper)); | 134 return new (_BoundSinkStream$(core.Object, T))(source, dart.as(mapSink,
_SinkMapper)); |
| 135 } | 135 } |
| 136 get isBroadcast() { | 136 get isBroadcast() { |
| 137 return false; | 137 return false; |
| 138 } | 138 } |
| 139 asBroadcastStream(opts) { | 139 asBroadcastStream(opts) { |
| 140 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 140 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 141 dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)])
); | 141 dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)])
); |
| 142 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 142 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 143 dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)])
); | 143 dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)])
); |
| 144 return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType12
), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription]))); | 144 return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType12
), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription]))); |
| 145 } | 145 } |
| 146 where(test) { | 146 where(test) { |
| 147 dart.as(test, dart.functionType(core.bool, [T])); | 147 dart.as(test, dart.functionType(core.bool, [T])); |
| 148 return new (_WhereStream$(T))(this, test); | 148 return new (_WhereStream$(T))(this, test); |
| 149 } | 149 } |
| 150 map(convert) { | 150 map(convert) { |
| 151 dart.as(convert, dart.functionType(dart.dynamic, [T])); | 151 dart.as(convert, dart.functionType(core.Object, [T])); |
| 152 return new (_MapStream$(T, dart.dynamic))(this, convert); | 152 return new (_MapStream$(T, core.Object))(this, convert); |
| 153 } | 153 } |
| 154 asyncMap(convert) { | 154 asyncMap(convert) { |
| 155 dart.as(convert, dart.functionType(dart.dynamic, [T])); | 155 dart.as(convert, dart.functionType(core.Object, [T])); |
| 156 let controller = null; | 156 let controller = null; |
| 157 let subscription = null; | 157 let subscription = null; |
| 158 let onListen = (() => { | 158 let onListen = (() => { |
| 159 let add = dart.bind(controller, 'add'); | 159 let add = dart.bind(controller, 'add'); |
| 160 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); | 160 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); |
| 161 let eventSink = controller; | 161 let eventSink = controller; |
| 162 let addError = eventSink[_addError]; | 162 let addError = eventSink[_addError]; |
| 163 subscription = this.listen(dart.fn(event => { | 163 subscription = this.listen(dart.fn(event => { |
| 164 dart.as(event, T); | 164 dart.as(event, T); |
| 165 let newValue = null; | 165 let newValue = null; |
| 166 try { | 166 try { |
| 167 newValue = convert(event); | 167 newValue = convert(event); |
| 168 } catch (e) { | 168 } catch (e) { |
| 169 let s = dart.stackTrace(e); | 169 let s = dart.stackTrace(e); |
| 170 controller.addError(e, s); | 170 controller.addError(e, s); |
| 171 return; | 171 return; |
| 172 } | 172 } |
| 173 | 173 |
| 174 if (dart.is(newValue, Future)) { | 174 if (dart.is(newValue, Future)) { |
| 175 subscription.pause(); | 175 subscription.pause(); |
| 176 dart.dsend(dart.dsend(newValue, 'then', add, {onError: addError}),
'whenComplete', dart.bind(subscription, 'resume')); | 176 dart.dsend(dart.dsend(newValue, 'then', add, {onError: addError}),
'whenComplete', dart.bind(subscription, 'resume')); |
| 177 } else { | 177 } else { |
| 178 controller.add(newValue); | 178 controller.add(newValue); |
| 179 } | 179 } |
| 180 }, dart.dynamic, [T]), {onError: dart.as(addError, core.Function), onD
one: dart.bind(controller, 'close')}); | 180 }, core.Object, [T]), {onError: dart.as(addError, core.Function), onDo
ne: dart.bind(controller, 'close')}); |
| 181 }).bind(this); | 181 }).bind(this); |
| 182 dart.fn(onListen, dart.void, []); | 182 dart.fn(onListen, dart.void, []); |
| 183 if (this.isBroadcast) { | 183 if (this.isBroadcast) { |
| 184 controller = new StreamController.broadcast({onListen: onListen, onCan
cel: dart.fn(() => { | 184 controller = new StreamController.broadcast({onListen: onListen, onCan
cel: dart.fn(() => { |
| 185 subscription.cancel(); | 185 subscription.cancel(); |
| 186 }), sync: true}); | 186 }), sync: true}); |
| 187 } else { | 187 } else { |
| 188 controller = new StreamController({onListen: onListen, onPause: dart.f
n(() => { | 188 controller = new StreamController({onListen: onListen, onPause: dart.f
n(() => { |
| 189 subscription.pause(); | 189 subscription.pause(); |
| 190 }), onResume: dart.fn(() => { | 190 }), onResume: dart.fn(() => { |
| (...skipping 19 matching lines...) Expand all Loading... |
| 210 } catch (e) { | 210 } catch (e) { |
| 211 let s = dart.stackTrace(e); | 211 let s = dart.stackTrace(e); |
| 212 controller.addError(e, s); | 212 controller.addError(e, s); |
| 213 return; | 213 return; |
| 214 } | 214 } |
| 215 | 215 |
| 216 if (newStream != null) { | 216 if (newStream != null) { |
| 217 subscription.pause(); | 217 subscription.pause(); |
| 218 controller.addStream(newStream).whenComplete(dart.bind(subscriptio
n, 'resume')); | 218 controller.addStream(newStream).whenComplete(dart.bind(subscriptio
n, 'resume')); |
| 219 } | 219 } |
| 220 }, dart.dynamic, [T]), {onError: dart.as(eventSink[_addError], core.Fu
nction), onDone: dart.bind(controller, 'close')}); | 220 }, core.Object, [T]), {onError: dart.as(eventSink[_addError], core.Fun
ction), onDone: dart.bind(controller, 'close')}); |
| 221 }).bind(this); | 221 }).bind(this); |
| 222 dart.fn(onListen, dart.void, []); | 222 dart.fn(onListen, dart.void, []); |
| 223 if (this.isBroadcast) { | 223 if (this.isBroadcast) { |
| 224 controller = new StreamController.broadcast({onListen: onListen, onCan
cel: dart.fn(() => { | 224 controller = new StreamController.broadcast({onListen: onListen, onCan
cel: dart.fn(() => { |
| 225 subscription.cancel(); | 225 subscription.cancel(); |
| 226 }), sync: true}); | 226 }), sync: true}); |
| 227 } else { | 227 } else { |
| 228 controller = new StreamController({onListen: onListen, onPause: dart.f
n(() => { | 228 controller = new StreamController({onListen: onListen, onPause: dart.f
n(() => { |
| 229 subscription.pause(); | 229 subscription.pause(); |
| 230 }), onResume: dart.fn(() => { | 230 }), onResume: dart.fn(() => { |
| 231 subscription.resume(); | 231 subscription.resume(); |
| 232 }), onCancel: dart.fn(() => { | 232 }), onCancel: dart.fn(() => { |
| 233 subscription.cancel(); | 233 subscription.cancel(); |
| 234 }), sync: true}); | 234 }), sync: true}); |
| 235 } | 235 } |
| 236 return controller.stream; | 236 return controller.stream; |
| 237 } | 237 } |
| 238 handleError(onError, opts) { | 238 handleError(onError, opts) { |
| 239 let test = opts && 'test' in opts ? opts.test : null; | 239 let test = opts && 'test' in opts ? opts.test : null; |
| 240 dart.as(test, dart.functionType(core.bool, [dart.dynamic])); | 240 dart.as(test, dart.functionType(core.bool, [dart.bottom])); |
| 241 return new (_HandleErrorStream$(T))(this, onError, test); | 241 return new (_HandleErrorStream$(T))(this, onError, test); |
| 242 } | 242 } |
| 243 expand(convert) { | 243 expand(convert) { |
| 244 dart.as(convert, dart.functionType(core.Iterable, [T])); | 244 dart.as(convert, dart.functionType(core.Iterable, [T])); |
| 245 return new (_ExpandStream$(T, dart.dynamic))(this, convert); | 245 return new (_ExpandStream$(T, core.Object))(this, convert); |
| 246 } | 246 } |
| 247 pipe(streamConsumer) { | 247 pipe(streamConsumer) { |
| 248 dart.as(streamConsumer, StreamConsumer$(T)); | 248 dart.as(streamConsumer, StreamConsumer$(T)); |
| 249 return streamConsumer.addStream(this).then(dart.fn(_ => streamConsumer.c
lose(), Future, [dart.dynamic])); | 249 return streamConsumer.addStream(this).then(dart.fn(_ => streamConsumer.c
lose(), Future, [core.Object])); |
| 250 } | 250 } |
| 251 transform(streamTransformer) { | 251 transform(streamTransformer) { |
| 252 dart.as(streamTransformer, StreamTransformer$(T, dart.dynamic)); | 252 dart.as(streamTransformer, StreamTransformer$(T, core.Object)); |
| 253 return streamTransformer.bind(this); | 253 return streamTransformer.bind(this); |
| 254 } | 254 } |
| 255 reduce(combine) { | 255 reduce(combine) { |
| 256 dart.as(combine, dart.functionType(T, [T, T])); | 256 dart.as(combine, dart.functionType(T, [T, T])); |
| 257 let result = new (_Future$(T))(); | 257 let result = new (_Future$(T))(); |
| 258 let seenFirst = false; | 258 let seenFirst = false; |
| 259 let value = null; | 259 let value = null; |
| 260 let subscription = null; | 260 let subscription = null; |
| 261 subscription = this.listen(dart.fn(element => { | 261 subscription = this.listen(dart.fn(element => { |
| 262 dart.as(element, T); | 262 dart.as(element, T); |
| 263 if (seenFirst) { | 263 if (seenFirst) { |
| 264 _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(
newValue => { | 264 _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(
newValue => { |
| 265 dart.as(newValue, T); | 265 dart.as(newValue, T); |
| 266 value = newValue; | 266 value = newValue; |
| 267 }, dart.dynamic, [T]), dart.as(_cancelAndErrorClosure(subscription,
result), __CastType14)); | 267 }, core.Object, [T]), dart.as(_cancelAndErrorClosure(subscription, r
esult), __CastType14)); |
| 268 } else { | 268 } else { |
| 269 value = element; | 269 value = element; |
| 270 seenFirst = true; | 270 seenFirst = true; |
| 271 } | 271 } |
| 272 }, dart.dynamic, [T]), {onError: dart.bind(result, _completeError), onDo
ne: dart.fn(() => { | 272 }, core.Object, [T]), {onError: dart.bind(result, _completeError), onDon
e: dart.fn(() => { |
| 273 if (!dart.notNull(seenFirst)) { | 273 if (!dart.notNull(seenFirst)) { |
| 274 try { | 274 try { |
| 275 throw _internal.IterableElementError.noElement(); | 275 throw _internal.IterableElementError.noElement(); |
| 276 } catch (e) { | 276 } catch (e) { |
| 277 let s = dart.stackTrace(e); | 277 let s = dart.stackTrace(e); |
| 278 _completeWithErrorCallback(result, e, s); | 278 _completeWithErrorCallback(result, e, s); |
| 279 } | 279 } |
| 280 | 280 |
| 281 } else { | 281 } else { |
| 282 result[_complete](value); | 282 result[_complete](value); |
| 283 } | 283 } |
| 284 }), cancelOnError: true}); | 284 }), cancelOnError: true}); |
| 285 return result; | 285 return result; |
| 286 } | 286 } |
| 287 fold(initialValue, combine) { | 287 fold(initialValue, combine) { |
| 288 dart.as(combine, dart.functionType(dart.dynamic, [dart.dynamic, T])); | 288 dart.as(combine, dart.functionType(core.Object, [dart.bottom, T])); |
| 289 let result = new _Future(); | 289 let result = new _Future(); |
| 290 let value = initialValue; | 290 let value = initialValue; |
| 291 let subscription = null; | 291 let subscription = null; |
| 292 subscription = this.listen(dart.fn(element => { | 292 subscription = this.listen(dart.fn(element => { |
| 293 dart.as(element, T); | 293 dart.as(element, T); |
| 294 _runUserCode(dart.fn(() => dart.dcall(combine, value, element)), dart.
fn(newValue => { | 294 _runUserCode(dart.fn(() => dart.dcall(combine, value, element)), dart.
fn(newValue => { |
| 295 value = newValue; | 295 value = newValue; |
| 296 }), dart.as(_cancelAndErrorClosure(subscription, result), dart.functio
nType(dart.dynamic, [dart.dynamic, core.StackTrace]))); | 296 }), dart.as(_cancelAndErrorClosure(subscription, result), dart.functio
nType(core.Object, [dart.bottom, core.StackTrace]))); |
| 297 }, dart.dynamic, [T]), {onError: dart.fn((e, st) => { | 297 }, core.Object, [T]), {onError: dart.fn((e, st) => { |
| 298 result[_completeError](e, dart.as(st, core.StackTrace)); | 298 result[_completeError](e, dart.as(st, core.StackTrace)); |
| 299 }), onDone: dart.fn(() => { | 299 }), onDone: dart.fn(() => { |
| 300 result[_complete](value); | 300 result[_complete](value); |
| 301 }), cancelOnError: true}); | 301 }), cancelOnError: true}); |
| 302 return result; | 302 return result; |
| 303 } | 303 } |
| 304 join(separator) { | 304 join(separator) { |
| 305 if (separator === void 0) | 305 if (separator === void 0) |
| 306 separator = ""; | 306 separator = ""; |
| 307 let result = new (_Future$(core.String))(); | 307 let result = new (_Future$(core.String))(); |
| 308 let buffer = new core.StringBuffer(); | 308 let buffer = new core.StringBuffer(); |
| 309 let subscription = null; | 309 let subscription = null; |
| 310 let first = true; | 310 let first = true; |
| 311 subscription = this.listen(dart.fn(element => { | 311 subscription = this.listen(dart.fn(element => { |
| 312 dart.as(element, T); | 312 dart.as(element, T); |
| 313 if (!dart.notNull(first)) { | 313 if (!dart.notNull(first)) { |
| 314 buffer.write(separator); | 314 buffer.write(separator); |
| 315 } | 315 } |
| 316 first = false; | 316 first = false; |
| 317 try { | 317 try { |
| 318 buffer.write(element); | 318 buffer.write(element); |
| 319 } catch (e) { | 319 } catch (e) { |
| 320 let s = dart.stackTrace(e); | 320 let s = dart.stackTrace(e); |
| 321 _cancelAndErrorWithReplacement(subscription, result, e, s); | 321 _cancelAndErrorWithReplacement(subscription, result, e, s); |
| 322 } | 322 } |
| 323 | 323 |
| 324 }, dart.dynamic, [T]), {onError: dart.fn(e => { | 324 }, core.Object, [T]), {onError: dart.fn(e => { |
| 325 result[_completeError](e); | 325 result[_completeError](e); |
| 326 }), onDone: dart.fn(() => { | 326 }), onDone: dart.fn(() => { |
| 327 result[_complete](dart.toString(buffer)); | 327 result[_complete](dart.toString(buffer)); |
| 328 }), cancelOnError: true}); | 328 }), cancelOnError: true}); |
| 329 return result; | 329 return result; |
| 330 } | 330 } |
| 331 contains(needle) { | 331 contains(needle) { |
| 332 let future = new (_Future$(core.bool))(); | 332 let future = new (_Future$(core.bool))(); |
| 333 let subscription = null; | 333 let subscription = null; |
| 334 subscription = this.listen(dart.fn(element => { | 334 subscription = this.listen(dart.fn(element => { |
| 335 dart.as(element, T); | 335 dart.as(element, T); |
| 336 _runUserCode(dart.fn(() => dart.equals(element, needle), core.bool, []
), dart.fn(isMatch => { | 336 _runUserCode(dart.fn(() => dart.equals(element, needle), core.bool, []
), dart.fn(isMatch => { |
| 337 if (isMatch) { | 337 if (isMatch) { |
| 338 _cancelAndValue(subscription, future, true); | 338 _cancelAndValue(subscription, future, true); |
| 339 } | 339 } |
| 340 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); | 340 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); |
| 341 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 341 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 342 future[_complete](false); | 342 future[_complete](false); |
| 343 }), cancelOnError: true}); | 343 }), cancelOnError: true}); |
| 344 return future; | 344 return future; |
| 345 } | 345 } |
| 346 forEach(action) { | 346 forEach(action) { |
| 347 dart.as(action, dart.functionType(dart.void, [T])); | 347 dart.as(action, dart.functionType(dart.void, [T])); |
| 348 let future = new _Future(); | 348 let future = new _Future(); |
| 349 let subscription = null; | 349 let subscription = null; |
| 350 subscription = this.listen(dart.fn(element => { | 350 subscription = this.listen(dart.fn(element => { |
| 351 dart.as(element, T); | 351 dart.as(element, T); |
| 352 _runUserCode(dart.fn(() => action(element), dart.void, []), dart.fn(_
=> { | 352 _runUserCode(dart.fn(() => action(element), dart.void, []), dart.fn(_
=> { |
| 353 }), dart.as(_cancelAndErrorClosure(subscription, future), dart.functio
nType(dart.dynamic, [dart.dynamic, core.StackTrace]))); | 353 }), dart.as(_cancelAndErrorClosure(subscription, future), dart.functio
nType(core.Object, [dart.bottom, core.StackTrace]))); |
| 354 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 354 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 355 future[_complete](null); | 355 future[_complete](null); |
| 356 }), cancelOnError: true}); | 356 }), cancelOnError: true}); |
| 357 return future; | 357 return future; |
| 358 } | 358 } |
| 359 every(test) { | 359 every(test) { |
| 360 dart.as(test, dart.functionType(core.bool, [T])); | 360 dart.as(test, dart.functionType(core.bool, [T])); |
| 361 let future = new (_Future$(core.bool))(); | 361 let future = new (_Future$(core.bool))(); |
| 362 let subscription = null; | 362 let subscription = null; |
| 363 subscription = this.listen(dart.fn(element => { | 363 subscription = this.listen(dart.fn(element => { |
| 364 dart.as(element, T); | 364 dart.as(element, T); |
| 365 _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMa
tch => { | 365 _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMa
tch => { |
| 366 if (!dart.notNull(isMatch)) { | 366 if (!dart.notNull(isMatch)) { |
| 367 _cancelAndValue(subscription, future, false); | 367 _cancelAndValue(subscription, future, false); |
| 368 } | 368 } |
| 369 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); | 369 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); |
| 370 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 370 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 371 future[_complete](true); | 371 future[_complete](true); |
| 372 }), cancelOnError: true}); | 372 }), cancelOnError: true}); |
| 373 return future; | 373 return future; |
| 374 } | 374 } |
| 375 any(test) { | 375 any(test) { |
| 376 dart.as(test, dart.functionType(core.bool, [T])); | 376 dart.as(test, dart.functionType(core.bool, [T])); |
| 377 let future = new (_Future$(core.bool))(); | 377 let future = new (_Future$(core.bool))(); |
| 378 let subscription = null; | 378 let subscription = null; |
| 379 subscription = this.listen(dart.fn(element => { | 379 subscription = this.listen(dart.fn(element => { |
| 380 dart.as(element, T); | 380 dart.as(element, T); |
| 381 _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMa
tch => { | 381 _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMa
tch => { |
| 382 if (isMatch) { | 382 if (isMatch) { |
| 383 _cancelAndValue(subscription, future, true); | 383 _cancelAndValue(subscription, future, true); |
| 384 } | 384 } |
| 385 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); | 385 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); |
| 386 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 386 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 387 future[_complete](false); | 387 future[_complete](false); |
| 388 }), cancelOnError: true}); | 388 }), cancelOnError: true}); |
| 389 return future; | 389 return future; |
| 390 } | 390 } |
| 391 get length() { | 391 get length() { |
| 392 let future = new (_Future$(core.int))(); | 392 let future = new (_Future$(core.int))(); |
| 393 let count = 0; | 393 let count = 0; |
| 394 this.listen(dart.fn(_ => { | 394 this.listen(dart.fn(_ => { |
| 395 count = dart.notNull(count) + 1; | 395 count = dart.notNull(count) + 1; |
| 396 }), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => { | 396 }), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => { |
| (...skipping 10 matching lines...) Expand all Loading... |
| 407 future[_complete](true); | 407 future[_complete](true); |
| 408 }), cancelOnError: true}); | 408 }), cancelOnError: true}); |
| 409 return future; | 409 return future; |
| 410 } | 410 } |
| 411 toList() { | 411 toList() { |
| 412 let result = dart.setType([], core.List$(T)); | 412 let result = dart.setType([], core.List$(T)); |
| 413 let future = new (_Future$(core.List$(T)))(); | 413 let future = new (_Future$(core.List$(T)))(); |
| 414 this.listen(dart.fn(data => { | 414 this.listen(dart.fn(data => { |
| 415 dart.as(data, T); | 415 dart.as(data, T); |
| 416 result[core.$add](data); | 416 result[core.$add](data); |
| 417 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 417 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 418 future[_complete](result); | 418 future[_complete](result); |
| 419 }), cancelOnError: true}); | 419 }), cancelOnError: true}); |
| 420 return future; | 420 return future; |
| 421 } | 421 } |
| 422 toSet() { | 422 toSet() { |
| 423 let result = new (core.Set$(T))(); | 423 let result = new (core.Set$(T))(); |
| 424 let future = new (_Future$(core.Set$(T)))(); | 424 let future = new (_Future$(core.Set$(T)))(); |
| 425 this.listen(dart.fn(data => { | 425 this.listen(dart.fn(data => { |
| 426 dart.as(data, T); | 426 dart.as(data, T); |
| 427 result.add(data); | 427 result.add(data); |
| 428 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 428 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 429 future[_complete](result); | 429 future[_complete](result); |
| 430 }), cancelOnError: true}); | 430 }), cancelOnError: true}); |
| 431 return future; | 431 return future; |
| 432 } | 432 } |
| 433 drain(futureValue) { | 433 drain(futureValue) { |
| 434 if (futureValue === void 0) | 434 if (futureValue === void 0) |
| 435 futureValue = null; | 435 futureValue = null; |
| 436 return this.listen(null, {cancelOnError: true}).asFuture(futureValue); | 436 return this.listen(null, {cancelOnError: true}).asFuture(futureValue); |
| 437 } | 437 } |
| 438 take(count) { | 438 take(count) { |
| (...skipping 15 matching lines...) Expand all Loading... |
| 454 equals = null; | 454 equals = null; |
| 455 dart.as(equals, dart.functionType(core.bool, [T, T])); | 455 dart.as(equals, dart.functionType(core.bool, [T, T])); |
| 456 return new (_DistinctStream$(T))(this, equals); | 456 return new (_DistinctStream$(T))(this, equals); |
| 457 } | 457 } |
| 458 get first() { | 458 get first() { |
| 459 let future = new (_Future$(T))(); | 459 let future = new (_Future$(T))(); |
| 460 let subscription = null; | 460 let subscription = null; |
| 461 subscription = this.listen(dart.fn(value => { | 461 subscription = this.listen(dart.fn(value => { |
| 462 dart.as(value, T); | 462 dart.as(value, T); |
| 463 _cancelAndValue(subscription, future, value); | 463 _cancelAndValue(subscription, future, value); |
| 464 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 464 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 465 try { | 465 try { |
| 466 throw _internal.IterableElementError.noElement(); | 466 throw _internal.IterableElementError.noElement(); |
| 467 } catch (e) { | 467 } catch (e) { |
| 468 let s = dart.stackTrace(e); | 468 let s = dart.stackTrace(e); |
| 469 _completeWithErrorCallback(future, e, s); | 469 _completeWithErrorCallback(future, e, s); |
| 470 } | 470 } |
| 471 | 471 |
| 472 }), cancelOnError: true}); | 472 }), cancelOnError: true}); |
| 473 return future; | 473 return future; |
| 474 } | 474 } |
| 475 get last() { | 475 get last() { |
| 476 let future = new (_Future$(T))(); | 476 let future = new (_Future$(T))(); |
| 477 let result = null; | 477 let result = null; |
| 478 let foundResult = false; | 478 let foundResult = false; |
| 479 let subscription = null; | 479 let subscription = null; |
| 480 subscription = this.listen(dart.fn(value => { | 480 subscription = this.listen(dart.fn(value => { |
| 481 dart.as(value, T); | 481 dart.as(value, T); |
| 482 foundResult = true; | 482 foundResult = true; |
| 483 result = value; | 483 result = value; |
| 484 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 484 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 485 if (foundResult) { | 485 if (foundResult) { |
| 486 future[_complete](result); | 486 future[_complete](result); |
| 487 return; | 487 return; |
| 488 } | 488 } |
| 489 try { | 489 try { |
| 490 throw _internal.IterableElementError.noElement(); | 490 throw _internal.IterableElementError.noElement(); |
| 491 } catch (e) { | 491 } catch (e) { |
| 492 let s = dart.stackTrace(e); | 492 let s = dart.stackTrace(e); |
| 493 _completeWithErrorCallback(future, e, s); | 493 _completeWithErrorCallback(future, e, s); |
| 494 } | 494 } |
| (...skipping 13 matching lines...) Expand all Loading... |
| 508 throw _internal.IterableElementError.tooMany(); | 508 throw _internal.IterableElementError.tooMany(); |
| 509 } catch (e) { | 509 } catch (e) { |
| 510 let s = dart.stackTrace(e); | 510 let s = dart.stackTrace(e); |
| 511 _cancelAndErrorWithReplacement(subscription, future, e, s); | 511 _cancelAndErrorWithReplacement(subscription, future, e, s); |
| 512 } | 512 } |
| 513 | 513 |
| 514 return; | 514 return; |
| 515 } | 515 } |
| 516 foundResult = true; | 516 foundResult = true; |
| 517 result = value; | 517 result = value; |
| 518 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 518 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 519 if (foundResult) { | 519 if (foundResult) { |
| 520 future[_complete](result); | 520 future[_complete](result); |
| 521 return; | 521 return; |
| 522 } | 522 } |
| 523 try { | 523 try { |
| 524 throw _internal.IterableElementError.noElement(); | 524 throw _internal.IterableElementError.noElement(); |
| 525 } catch (e) { | 525 } catch (e) { |
| 526 let s = dart.stackTrace(e); | 526 let s = dart.stackTrace(e); |
| 527 _completeWithErrorCallback(future, e, s); | 527 _completeWithErrorCallback(future, e, s); |
| 528 } | 528 } |
| 529 | 529 |
| 530 }), cancelOnError: true}); | 530 }), cancelOnError: true}); |
| 531 return future; | 531 return future; |
| 532 } | 532 } |
| 533 firstWhere(test, opts) { | 533 firstWhere(test, opts) { |
| 534 dart.as(test, dart.functionType(core.bool, [T])); | 534 dart.as(test, dart.functionType(core.bool, [T])); |
| 535 let defaultValue = opts && 'defaultValue' in opts ? opts.defaultValue :
null; | 535 let defaultValue = opts && 'defaultValue' in opts ? opts.defaultValue :
null; |
| 536 dart.as(defaultValue, dart.functionType(core.Object, [])); | 536 dart.as(defaultValue, dart.functionType(core.Object, [])); |
| 537 let future = new _Future(); | 537 let future = new _Future(); |
| 538 let subscription = null; | 538 let subscription = null; |
| 539 subscription = this.listen(dart.fn(value => { | 539 subscription = this.listen(dart.fn(value => { |
| 540 dart.as(value, T); | 540 dart.as(value, T); |
| 541 _runUserCode(dart.fn(() => test(value), core.bool, []), dart.fn(isMatc
h => { | 541 _runUserCode(dart.fn(() => test(value), core.bool, []), dart.fn(isMatc
h => { |
| 542 if (isMatch) { | 542 if (isMatch) { |
| 543 _cancelAndValue(subscription, future, value); | 543 _cancelAndValue(subscription, future, value); |
| 544 } | 544 } |
| 545 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); | 545 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); |
| 546 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 546 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 547 if (defaultValue != null) { | 547 if (defaultValue != null) { |
| 548 _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind
(future, _completeError)); | 548 _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind
(future, _completeError)); |
| 549 return; | 549 return; |
| 550 } | 550 } |
| 551 try { | 551 try { |
| 552 throw _internal.IterableElementError.noElement(); | 552 throw _internal.IterableElementError.noElement(); |
| 553 } catch (e) { | 553 } catch (e) { |
| 554 let s = dart.stackTrace(e); | 554 let s = dart.stackTrace(e); |
| 555 _completeWithErrorCallback(future, e, s); | 555 _completeWithErrorCallback(future, e, s); |
| 556 } | 556 } |
| 557 | 557 |
| 558 }), cancelOnError: true}); | 558 }), cancelOnError: true}); |
| 559 return future; | 559 return future; |
| 560 } | 560 } |
| 561 lastWhere(test, opts) { | 561 lastWhere(test, opts) { |
| 562 dart.as(test, dart.functionType(core.bool, [T])); | 562 dart.as(test, dart.functionType(core.bool, [T])); |
| 563 let defaultValue = opts && 'defaultValue' in opts ? opts.defaultValue :
null; | 563 let defaultValue = opts && 'defaultValue' in opts ? opts.defaultValue :
null; |
| 564 dart.as(defaultValue, dart.functionType(core.Object, [])); | 564 dart.as(defaultValue, dart.functionType(core.Object, [])); |
| 565 let future = new _Future(); | 565 let future = new _Future(); |
| 566 let result = null; | 566 let result = null; |
| 567 let foundResult = false; | 567 let foundResult = false; |
| 568 let subscription = null; | 568 let subscription = null; |
| 569 subscription = this.listen(dart.fn(value => { | 569 subscription = this.listen(dart.fn(value => { |
| 570 dart.as(value, T); | 570 dart.as(value, T); |
| 571 _runUserCode(dart.fn(() => true == test(value), core.bool, []), dart.f
n(isMatch => { | 571 _runUserCode(dart.fn(() => true == test(value), core.bool, []), dart.f
n(isMatch => { |
| 572 if (isMatch) { | 572 if (isMatch) { |
| 573 foundResult = true; | 573 foundResult = true; |
| 574 result = value; | 574 result = value; |
| 575 } | 575 } |
| 576 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); | 576 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); |
| 577 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 577 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 578 if (foundResult) { | 578 if (foundResult) { |
| 579 future[_complete](result); | 579 future[_complete](result); |
| 580 return; | 580 return; |
| 581 } | 581 } |
| 582 if (defaultValue != null) { | 582 if (defaultValue != null) { |
| 583 _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind
(future, _completeError)); | 583 _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind
(future, _completeError)); |
| 584 return; | 584 return; |
| 585 } | 585 } |
| 586 try { | 586 try { |
| 587 throw _internal.IterableElementError.noElement(); | 587 throw _internal.IterableElementError.noElement(); |
| (...skipping 21 matching lines...) Expand all Loading... |
| 609 } catch (e) { | 609 } catch (e) { |
| 610 let s = dart.stackTrace(e); | 610 let s = dart.stackTrace(e); |
| 611 _cancelAndErrorWithReplacement(subscription, future, e, s); | 611 _cancelAndErrorWithReplacement(subscription, future, e, s); |
| 612 } | 612 } |
| 613 | 613 |
| 614 return; | 614 return; |
| 615 } | 615 } |
| 616 foundResult = true; | 616 foundResult = true; |
| 617 result = value; | 617 result = value; |
| 618 } | 618 } |
| 619 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); | 619 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); |
| 620 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { | 620 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { |
| 621 if (foundResult) { | 621 if (foundResult) { |
| 622 future[_complete](result); | 622 future[_complete](result); |
| 623 return; | 623 return; |
| 624 } | 624 } |
| 625 try { | 625 try { |
| 626 throw _internal.IterableElementError.noElement(); | 626 throw _internal.IterableElementError.noElement(); |
| 627 } catch (e) { | 627 } catch (e) { |
| 628 let s = dart.stackTrace(e); | 628 let s = dart.stackTrace(e); |
| 629 _completeWithErrorCallback(future, e, s); | 629 _completeWithErrorCallback(future, e, s); |
| 630 } | 630 } |
| 631 | 631 |
| 632 }), cancelOnError: true}); | 632 }), cancelOnError: true}); |
| 633 return future; | 633 return future; |
| 634 } | 634 } |
| 635 elementAt(index) { | 635 elementAt(index) { |
| 636 if (!(typeof index == 'number') || dart.notNull(index) < 0) | 636 if (!(typeof index == 'number') || dart.notNull(index) < 0) |
| 637 throw new core.ArgumentError(index); | 637 throw new core.ArgumentError(index); |
| 638 let future = new (_Future$(T))(); | 638 let future = new (_Future$(T))(); |
| 639 let subscription = null; | 639 let subscription = null; |
| 640 let elementIndex = 0; | 640 let elementIndex = 0; |
| 641 subscription = this.listen(dart.fn(value => { | 641 subscription = this.listen(dart.fn(value => { |
| 642 dart.as(value, T); | 642 dart.as(value, T); |
| 643 if (index == elementIndex) { | 643 if (index == elementIndex) { |
| 644 _cancelAndValue(subscription, future, value); | 644 _cancelAndValue(subscription, future, value); |
| 645 return; | 645 return; |
| 646 } | 646 } |
| 647 elementIndex = dart.notNull(elementIndex) + 1; | 647 elementIndex = dart.notNull(elementIndex) + 1; |
| 648 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn((() => { | 648 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn((() => { |
| 649 future[_completeError](new core.RangeError.index(index, this, "index
", null, elementIndex)); | 649 future[_completeError](new core.RangeError.index(index, this, "index
", null, elementIndex)); |
| 650 }).bind(this)), cancelOnError: true}); | 650 }).bind(this)), cancelOnError: true}); |
| 651 return future; | 651 return future; |
| 652 } | 652 } |
| 653 timeout(timeLimit, opts) { | 653 timeout(timeLimit, opts) { |
| 654 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; | 654 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; |
| 655 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); | 655 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); |
| 656 let controller = null; | 656 let controller = null; |
| 657 let subscription = null; | 657 let subscription = null; |
| 658 let timer = null; | 658 let timer = null; |
| 659 let zone = null; | 659 let zone = null; |
| 660 let timeout = null; | 660 let timeout = null; |
| 661 let onData = event => { | 661 let onData = event => { |
| 662 dart.as(event, T); | 662 dart.as(event, T); |
| 663 timer.cancel(); | 663 timer.cancel(); |
| 664 controller.add(event); | 664 controller.add(event); |
| 665 timer = zone.createTimer(timeLimit, dart.as(timeout, __CastType17)); | 665 timer = zone.createTimer(timeLimit, dart.as(timeout, __CastType17)); |
| 666 }; | 666 }; |
| 667 dart.fn(onData, dart.void, [T]); | 667 dart.fn(onData, dart.void, [T]); |
| 668 let onError = (error, stackTrace) => { | 668 let onError = (error, stackTrace) => { |
| 669 timer.cancel(); | 669 timer.cancel(); |
| 670 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); | 670 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); |
| 671 let eventSink = controller; | 671 let eventSink = controller; |
| 672 dart.dcall(eventSink[_addError], error, stackTrace); | 672 dart.dcall(eventSink[_addError], error, stackTrace); |
| 673 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType
(dart.void, []))); | 673 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType
(dart.void, []))); |
| 674 }; | 674 }; |
| 675 dart.fn(onError, dart.void, [dart.dynamic, core.StackTrace]); | 675 dart.fn(onError, dart.void, [core.Object, core.StackTrace]); |
| 676 let onDone = () => { | 676 let onDone = () => { |
| 677 timer.cancel(); | 677 timer.cancel(); |
| 678 controller.close(); | 678 controller.close(); |
| 679 }; | 679 }; |
| 680 dart.fn(onDone, dart.void, []); | 680 dart.fn(onDone, dart.void, []); |
| 681 let onListen = (() => { | 681 let onListen = (() => { |
| 682 zone = Zone.current; | 682 zone = Zone.current; |
| 683 if (onTimeout == null) { | 683 if (onTimeout == null) { |
| 684 timeout = dart.fn(() => { | 684 timeout = dart.fn(() => { |
| 685 controller.addError(new TimeoutException("No stream event", timeLi
mit), null); | 685 controller.addError(new TimeoutException("No stream event", timeLi
mit), null); |
| (...skipping 29 matching lines...) Expand all Loading... |
| 715 } | 715 } |
| 716 } | 716 } |
| 717 dart.defineNamedConstructor(Stream, 'fromFuture'); | 717 dart.defineNamedConstructor(Stream, 'fromFuture'); |
| 718 dart.defineNamedConstructor(Stream, 'fromIterable'); | 718 dart.defineNamedConstructor(Stream, 'fromIterable'); |
| 719 dart.defineNamedConstructor(Stream, 'periodic'); | 719 dart.defineNamedConstructor(Stream, 'periodic'); |
| 720 dart.defineNamedConstructor(Stream, 'eventTransformed'); | 720 dart.defineNamedConstructor(Stream, 'eventTransformed'); |
| 721 dart.setSignature(Stream, { | 721 dart.setSignature(Stream, { |
| 722 methods: () => ({ | 722 methods: () => ({ |
| 723 asBroadcastStream: dart.functionType(Stream$(T), [], {nListe: dart.funct
ionType(dart.void, [StreamSubscription$(T)]), nCance: dart.functionType(dart.voi
d, [StreamSubscription$(T)])}), | 723 asBroadcastStream: dart.functionType(Stream$(T), [], {nListe: dart.funct
ionType(dart.void, [StreamSubscription$(T)]), nCance: dart.functionType(dart.voi
d, [StreamSubscription$(T)])}), |
| 724 where: dart.functionType(Stream$(T), [dart.functionType(core.bool, [T])]
), | 724 where: dart.functionType(Stream$(T), [dart.functionType(core.bool, [T])]
), |
| 725 map: dart.functionType(Stream$(), [dart.functionType(dart.dynamic, [T])]
), | 725 map: dart.functionType(Stream$(), [dart.functionType(core.Object, [T])])
, |
| 726 asyncMap: dart.functionType(Stream$(), [dart.functionType(dart.dynamic,
[T])]), | 726 asyncMap: dart.functionType(Stream$(), [dart.functionType(core.Object, [
T])]), |
| 727 asyncExpand: dart.functionType(Stream$(), [dart.functionType(Stream$(),
[T])]), | 727 asyncExpand: dart.functionType(Stream$(), [dart.functionType(Stream$(),
[T])]), |
| 728 handleError: dart.functionType(Stream$(T), [core.Function], {es: dart.fu
nctionType(core.bool, [dart.dynamic])}), | 728 handleError: dart.functionType(Stream$(T), [core.Function], {es: dart.fu
nctionType(core.bool, [dart.bottom])}), |
| 729 expand: dart.functionType(Stream$(), [dart.functionType(core.Iterable, [
T])]), | 729 expand: dart.functionType(Stream$(), [dart.functionType(core.Iterable, [
T])]), |
| 730 pipe: dart.functionType(Future, [StreamConsumer$(T)]), | 730 pipe: dart.functionType(Future, [StreamConsumer$(T)]), |
| 731 transform: dart.functionType(Stream$(), [StreamTransformer$(T, dart.dyna
mic)]), | 731 transform: dart.functionType(Stream$(), [StreamTransformer$(T, core.Obje
ct)]), |
| 732 reduce: dart.functionType(Future$(T), [dart.functionType(T, [T, T])]), | 732 reduce: dart.functionType(Future$(T), [dart.functionType(T, [T, T])]), |
| 733 fold: dart.functionType(Future, [dart.dynamic, dart.functionType(dart.dy
namic, [dart.dynamic, T])]), | 733 fold: dart.functionType(Future, [core.Object, dart.functionType(core.Obj
ect, [dart.bottom, T])]), |
| 734 join: dart.functionType(Future$(core.String), [], [core.String]), | 734 join: dart.functionType(Future$(core.String), [], [core.String]), |
| 735 contains: dart.functionType(Future$(core.bool), [core.Object]), | 735 contains: dart.functionType(Future$(core.bool), [core.Object]), |
| 736 forEach: dart.functionType(Future, [dart.functionType(dart.void, [T])]), | 736 forEach: dart.functionType(Future, [dart.functionType(dart.void, [T])]), |
| 737 every: dart.functionType(Future$(core.bool), [dart.functionType(core.boo
l, [T])]), | 737 every: dart.functionType(Future$(core.bool), [dart.functionType(core.boo
l, [T])]), |
| 738 any: dart.functionType(Future$(core.bool), [dart.functionType(core.bool,
[T])]), | 738 any: dart.functionType(Future$(core.bool), [dart.functionType(core.bool,
[T])]), |
| 739 toList: dart.functionType(Future$(core.List$(T)), []), | 739 toList: dart.functionType(Future$(core.List$(T)), []), |
| 740 toSet: dart.functionType(Future$(core.Set$(T)), []), | 740 toSet: dart.functionType(Future$(core.Set$(T)), []), |
| 741 drain: dart.functionType(Future, [], [dart.dynamic]), | 741 drain: dart.functionType(Future, [], [core.Object]), |
| 742 take: dart.functionType(Stream$(T), [core.int]), | 742 take: dart.functionType(Stream$(T), [core.int]), |
| 743 takeWhile: dart.functionType(Stream$(T), [dart.functionType(core.bool, [
T])]), | 743 takeWhile: dart.functionType(Stream$(T), [dart.functionType(core.bool, [
T])]), |
| 744 skip: dart.functionType(Stream$(T), [core.int]), | 744 skip: dart.functionType(Stream$(T), [core.int]), |
| 745 skipWhile: dart.functionType(Stream$(T), [dart.functionType(core.bool, [
T])]), | 745 skipWhile: dart.functionType(Stream$(T), [dart.functionType(core.bool, [
T])]), |
| 746 distinct: dart.functionType(Stream$(T), [], [dart.functionType(core.bool
, [T, T])]), | 746 distinct: dart.functionType(Stream$(T), [], [dart.functionType(core.bool
, [T, T])]), |
| 747 firstWhere: dart.functionType(Future, [dart.functionType(core.bool, [T])
], {efaultValu: dart.functionType(core.Object, [])}), | 747 firstWhere: dart.functionType(Future, [dart.functionType(core.bool, [T])
], {efaultValu: dart.functionType(core.Object, [])}), |
| 748 lastWhere: dart.functionType(Future, [dart.functionType(core.bool, [T])]
, {efaultValu: dart.functionType(core.Object, [])}), | 748 lastWhere: dart.functionType(Future, [dart.functionType(core.bool, [T])]
, {efaultValu: dart.functionType(core.Object, [])}), |
| 749 singleWhere: dart.functionType(Future$(T), [dart.functionType(core.bool,
[T])]), | 749 singleWhere: dart.functionType(Future$(T), [dart.functionType(core.bool,
[T])]), |
| 750 elementAt: dart.functionType(Future$(T), [core.int]), | 750 elementAt: dart.functionType(Future$(T), [core.int]), |
| 751 timeout: dart.functionType(Stream$(), [core.Duration], {nTimeou: dart.fu
nctionType(dart.void, [EventSink])}) | 751 timeout: dart.functionType(Stream$(), [core.Duration], {nTimeou: dart.fu
nctionType(dart.void, [EventSink])}) |
| (...skipping 426 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1178 dart.setSignature(_BufferingStreamSubscription, { | 1178 dart.setSignature(_BufferingStreamSubscription, { |
| 1179 methods: () => ({ | 1179 methods: () => ({ |
| 1180 [_setPendingEvents]: dart.functionType(dart.void, [_PendingEvents]), | 1180 [_setPendingEvents]: dart.functionType(dart.void, [_PendingEvents]), |
| 1181 [_extractPending]: dart.functionType(_PendingEvents, []), | 1181 [_extractPending]: dart.functionType(_PendingEvents, []), |
| 1182 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])]
), | 1182 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])]
), |
| 1183 onError: dart.functionType(dart.void, [core.Function]), | 1183 onError: dart.functionType(dart.void, [core.Function]), |
| 1184 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])])
, | 1184 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])])
, |
| 1185 pause: dart.functionType(dart.void, [], [Future]), | 1185 pause: dart.functionType(dart.void, [], [Future]), |
| 1186 resume: dart.functionType(dart.void, []), | 1186 resume: dart.functionType(dart.void, []), |
| 1187 cancel: dart.functionType(Future, []), | 1187 cancel: dart.functionType(Future, []), |
| 1188 asFuture: dart.functionType(Future, [], [dart.dynamic]), | 1188 asFuture: dart.functionType(Future, [], [core.Object]), |
| 1189 [_cancel]: dart.functionType(dart.void, []), | 1189 [_cancel]: dart.functionType(dart.void, []), |
| 1190 [_incrementPauseCount]: dart.functionType(dart.void, []), | 1190 [_incrementPauseCount]: dart.functionType(dart.void, []), |
| 1191 [_decrementPauseCount]: dart.functionType(dart.void, []), | 1191 [_decrementPauseCount]: dart.functionType(dart.void, []), |
| 1192 [_add]: dart.functionType(dart.void, [T]), | 1192 [_add]: dart.functionType(dart.void, [T]), |
| 1193 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace]
), | 1193 [_addError]: dart.functionType(dart.void, [core.Object, core.StackTrace]
), |
| 1194 [_close]: dart.functionType(dart.void, []), | 1194 [_close]: dart.functionType(dart.void, []), |
| 1195 [_onPause]: dart.functionType(dart.void, []), | 1195 [_onPause]: dart.functionType(dart.void, []), |
| 1196 [_onResume]: dart.functionType(dart.void, []), | 1196 [_onResume]: dart.functionType(dart.void, []), |
| 1197 [_onCancel]: dart.functionType(Future, []), | 1197 [_onCancel]: dart.functionType(Future, []), |
| 1198 [_addPending]: dart.functionType(dart.void, [_DelayedEvent]), | 1198 [_addPending]: dart.functionType(dart.void, [_DelayedEvent]), |
| 1199 [_sendData]: dart.functionType(dart.void, [T]), | 1199 [_sendData]: dart.functionType(dart.void, [T]), |
| 1200 [_sendError]: dart.functionType(dart.void, [core.Object, core.StackTrace
]), | 1200 [_sendError]: dart.functionType(dart.void, [core.Object, core.StackTrace
]), |
| 1201 [_sendDone]: dart.functionType(dart.void, []), | 1201 [_sendDone]: dart.functionType(dart.void, []), |
| 1202 [_guardCallback]: dart.functionType(dart.void, [dart.dynamic]), | 1202 [_guardCallback]: dart.functionType(dart.void, [core.Object]), |
| 1203 [_checkState]: dart.functionType(dart.void, [core.bool]) | 1203 [_checkState]: dart.functionType(dart.void, [core.bool]) |
| 1204 }) | 1204 }) |
| 1205 }); | 1205 }); |
| 1206 return _BufferingStreamSubscription; | 1206 return _BufferingStreamSubscription; |
| 1207 }); | 1207 }); |
| 1208 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); | 1208 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); |
| 1209 let _recordCancel = Symbol('_recordCancel'); | 1209 let _recordCancel = Symbol('_recordCancel'); |
| 1210 let _recordPause = Symbol('_recordPause'); | 1210 let _recordPause = Symbol('_recordPause'); |
| 1211 let _recordResume = Symbol('_recordResume'); | 1211 let _recordResume = Symbol('_recordResume'); |
| 1212 let _ControllerSubscription$ = dart.generic(function(T) { | 1212 let _ControllerSubscription$ = dart.generic(function(T) { |
| (...skipping 331 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1544 subscription[_add](data); | 1544 subscription[_add](data); |
| 1545 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastSt
reamController._STATE_FIRING); | 1545 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastSt
reamController._STATE_FIRING); |
| 1546 if (this[_isEmpty]) { | 1546 if (this[_isEmpty]) { |
| 1547 this[_callOnCancel](); | 1547 this[_callOnCancel](); |
| 1548 } | 1548 } |
| 1549 return; | 1549 return; |
| 1550 } | 1550 } |
| 1551 this[_forEachListener](dart.fn(subscription => { | 1551 this[_forEachListener](dart.fn(subscription => { |
| 1552 dart.as(subscription, _BufferingStreamSubscription$(T)); | 1552 dart.as(subscription, _BufferingStreamSubscription$(T)); |
| 1553 subscription[_add](data); | 1553 subscription[_add](data); |
| 1554 }, dart.dynamic, [_BufferingStreamSubscription$(T)])); | 1554 }, core.Object, [_BufferingStreamSubscription$(T)])); |
| 1555 } | 1555 } |
| 1556 [_sendError](error, stackTrace) { | 1556 [_sendError](error, stackTrace) { |
| 1557 if (this[_isEmpty]) | 1557 if (this[_isEmpty]) |
| 1558 return; | 1558 return; |
| 1559 this[_forEachListener](dart.fn(subscription => { | 1559 this[_forEachListener](dart.fn(subscription => { |
| 1560 dart.as(subscription, _BufferingStreamSubscription$(T)); | 1560 dart.as(subscription, _BufferingStreamSubscription$(T)); |
| 1561 subscription[_addError](error, stackTrace); | 1561 subscription[_addError](error, stackTrace); |
| 1562 }, dart.dynamic, [_BufferingStreamSubscription$(T)])); | 1562 }, core.Object, [_BufferingStreamSubscription$(T)])); |
| 1563 } | 1563 } |
| 1564 [_sendDone]() { | 1564 [_sendDone]() { |
| 1565 if (!dart.notNull(this[_isEmpty])) { | 1565 if (!dart.notNull(this[_isEmpty])) { |
| 1566 this[_forEachListener](dart.as(dart.fn(subscription => { | 1566 this[_forEachListener](dart.as(dart.fn(subscription => { |
| 1567 dart.as(subscription, _BroadcastSubscription$(T)); | 1567 dart.as(subscription, _BroadcastSubscription$(T)); |
| 1568 subscription[_close](); | 1568 subscription[_close](); |
| 1569 }, dart.dynamic, [_BroadcastSubscription$(T)]), __CastType2)); | 1569 }, core.Object, [_BroadcastSubscription$(T)]), __CastType2)); |
| 1570 } else { | 1570 } else { |
| 1571 dart.assert(this[_doneFuture] != null); | 1571 dart.assert(this[_doneFuture] != null); |
| 1572 dart.assert(this[_doneFuture][_mayComplete]); | 1572 dart.assert(this[_doneFuture][_mayComplete]); |
| 1573 this[_doneFuture][_asyncComplete](null); | 1573 this[_doneFuture][_asyncComplete](null); |
| 1574 } | 1574 } |
| 1575 } | 1575 } |
| 1576 } | 1576 } |
| 1577 dart.setSignature(_SyncBroadcastStreamController, { | 1577 dart.setSignature(_SyncBroadcastStreamController, { |
| 1578 methods: () => ({ | 1578 methods: () => ({ |
| 1579 [_sendData]: dart.functionType(dart.void, [T]), | 1579 [_sendData]: dart.functionType(dart.void, [T]), |
| (...skipping 156 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1736 } | 1736 } |
| 1737 } | 1737 } |
| 1738 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; | 1738 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; |
| 1739 dart.setSignature(_DoneSubscription, { | 1739 dart.setSignature(_DoneSubscription, { |
| 1740 methods: () => ({ | 1740 methods: () => ({ |
| 1741 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])]
), | 1741 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])]
), |
| 1742 onError: dart.functionType(dart.void, [core.Function]), | 1742 onError: dart.functionType(dart.void, [core.Function]), |
| 1743 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])])
, | 1743 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])])
, |
| 1744 pause: dart.functionType(dart.void, [], [Future]), | 1744 pause: dart.functionType(dart.void, [], [Future]), |
| 1745 resume: dart.functionType(dart.void, []), | 1745 resume: dart.functionType(dart.void, []), |
| 1746 [_resume]: dart.functionType(dart.void, [dart.dynamic]), | 1746 [_resume]: dart.functionType(dart.void, [core.Object]), |
| 1747 cancel: dart.functionType(Future, []), | 1747 cancel: dart.functionType(Future, []), |
| 1748 asFuture: dart.functionType(Future, [], [core.Object]) | 1748 asFuture: dart.functionType(Future, [], [core.Object]) |
| 1749 }) | 1749 }) |
| 1750 }); | 1750 }); |
| 1751 return _DoneSubscription; | 1751 return _DoneSubscription; |
| 1752 }); | 1752 }); |
| 1753 let _DoneSubscription = _DoneSubscription$(); | 1753 let _DoneSubscription = _DoneSubscription$(); |
| 1754 let __CastType2$ = dart.generic(function(T) { | 1754 let __CastType2$ = dart.generic(function(T) { |
| 1755 let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.v
oid, [_BufferingStreamSubscription$(T)])); | 1755 let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.v
oid, [_BufferingStreamSubscription$(T)])); |
| 1756 return __CastType2; | 1756 return __CastType2; |
| (...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1847 let s = dart.stackTrace(e); | 1847 let s = dart.stackTrace(e); |
| 1848 _completeWithErrorCallback(result, e, s); | 1848 _completeWithErrorCallback(result, e, s); |
| 1849 } | 1849 } |
| 1850 | 1850 |
| 1851 })); | 1851 })); |
| 1852 return dart.as(result, Future$(T)); | 1852 return dart.as(result, Future$(T)); |
| 1853 } | 1853 } |
| 1854 static wait(futures, opts) { | 1854 static wait(futures, opts) { |
| 1855 let eagerError = opts && 'eagerError' in opts ? opts.eagerError : false; | 1855 let eagerError = opts && 'eagerError' in opts ? opts.eagerError : false; |
| 1856 let cleanUp = opts && 'cleanUp' in opts ? opts.cleanUp : null; | 1856 let cleanUp = opts && 'cleanUp' in opts ? opts.cleanUp : null; |
| 1857 dart.as(cleanUp, dart.functionType(dart.void, [dart.dynamic])); | 1857 dart.as(cleanUp, dart.functionType(dart.void, [dart.bottom])); |
| 1858 let result = new (_Future$(core.List))(); | 1858 let result = new (_Future$(core.List))(); |
| 1859 let values = null; | 1859 let values = null; |
| 1860 let remaining = 0; | 1860 let remaining = 0; |
| 1861 let error = null; | 1861 let error = null; |
| 1862 let stackTrace = null; | 1862 let stackTrace = null; |
| 1863 let handleError = (theError, theStackTrace) => { | 1863 let handleError = (theError, theStackTrace) => { |
| 1864 remaining = dart.notNull(remaining) - 1; | 1864 remaining = dart.notNull(remaining) - 1; |
| 1865 if (values != null) { | 1865 if (values != null) { |
| 1866 if (cleanUp != null) { | 1866 if (cleanUp != null) { |
| 1867 for (let value of values) { | 1867 for (let value of values) { |
| 1868 if (value != null) { | 1868 if (value != null) { |
| 1869 new (Future$()).sync(dart.fn(() => { | 1869 new (Future$()).sync(dart.fn(() => { |
| 1870 dart.dcall(cleanUp, value); | 1870 dart.dcall(cleanUp, value); |
| 1871 })); | 1871 })); |
| 1872 } | 1872 } |
| 1873 } | 1873 } |
| 1874 } | 1874 } |
| 1875 values = null; | 1875 values = null; |
| 1876 if (remaining == 0 || dart.notNull(eagerError)) { | 1876 if (remaining == 0 || dart.notNull(eagerError)) { |
| 1877 result[_completeError](theError, dart.as(theStackTrace, core.Stack
Trace)); | 1877 result[_completeError](theError, dart.as(theStackTrace, core.Stack
Trace)); |
| 1878 } else { | 1878 } else { |
| 1879 error = theError; | 1879 error = theError; |
| 1880 stackTrace = dart.as(theStackTrace, core.StackTrace); | 1880 stackTrace = dart.as(theStackTrace, core.StackTrace); |
| 1881 } | 1881 } |
| 1882 } else if (remaining == 0 && !dart.notNull(eagerError)) { | 1882 } else if (remaining == 0 && !dart.notNull(eagerError)) { |
| 1883 result[_completeError](error, stackTrace); | 1883 result[_completeError](error, stackTrace); |
| 1884 } | 1884 } |
| 1885 }; | 1885 }; |
| 1886 dart.fn(handleError, dart.void, [dart.dynamic, dart.dynamic]); | 1886 dart.fn(handleError, dart.void, [core.Object, core.Object]); |
| 1887 for (let future of futures) { | 1887 for (let future of futures) { |
| 1888 let pos = remaining; | 1888 let pos = remaining; |
| 1889 remaining = dart.notNull(pos) + 1; | 1889 remaining = dart.notNull(pos) + 1; |
| 1890 future.then(dart.fn(value => { | 1890 future.then(dart.fn(value => { |
| 1891 remaining = dart.notNull(remaining) - 1; | 1891 remaining = dart.notNull(remaining) - 1; |
| 1892 if (values != null) { | 1892 if (values != null) { |
| 1893 values[core.$set](pos, value); | 1893 values[core.$set](pos, value); |
| 1894 if (remaining == 0) { | 1894 if (remaining == 0) { |
| 1895 result[_completeWithValue](values); | 1895 result[_completeWithValue](values); |
| 1896 } | 1896 } |
| 1897 } else { | 1897 } else { |
| 1898 if (dart.notNull(cleanUp != null) && dart.notNull(value != null))
{ | 1898 if (dart.notNull(cleanUp != null) && dart.notNull(value != null))
{ |
| 1899 new (Future$()).sync(dart.fn(() => { | 1899 new (Future$()).sync(dart.fn(() => { |
| 1900 dart.dcall(cleanUp, value); | 1900 dart.dcall(cleanUp, value); |
| 1901 })); | 1901 })); |
| 1902 } | 1902 } |
| 1903 if (remaining == 0 && !dart.notNull(eagerError)) { | 1903 if (remaining == 0 && !dart.notNull(eagerError)) { |
| 1904 result[_completeError](error, stackTrace); | 1904 result[_completeError](error, stackTrace); |
| 1905 } | 1905 } |
| 1906 } | 1906 } |
| 1907 }, dart.dynamic, [core.Object]), {onError: handleError}); | 1907 }, core.Object, [core.Object]), {onError: handleError}); |
| 1908 } | 1908 } |
| 1909 if (remaining == 0) { | 1909 if (remaining == 0) { |
| 1910 return new (Future$(core.List)).value(dart.const([])); | 1910 return new (Future$(core.List)).value(dart.const([])); |
| 1911 } | 1911 } |
| 1912 values = new core.List(remaining); | 1912 values = new core.List(remaining); |
| 1913 return result; | 1913 return result; |
| 1914 } | 1914 } |
| 1915 static forEach(input, f) { | 1915 static forEach(input, f) { |
| 1916 dart.as(f, dart.functionType(dart.dynamic, [dart.dynamic])); | 1916 dart.as(f, dart.functionType(core.Object, [dart.bottom])); |
| 1917 let iterator = input[core.$iterator]; | 1917 let iterator = input[core.$iterator]; |
| 1918 return Future$().doWhile(dart.fn(() => { | 1918 return Future$().doWhile(dart.fn(() => { |
| 1919 if (!dart.notNull(iterator.moveNext())) | 1919 if (!dart.notNull(iterator.moveNext())) |
| 1920 return false; | 1920 return false; |
| 1921 return new (Future$()).sync(dart.fn(() => dart.dcall(f, iterator.curre
nt))).then(dart.fn(_ => true, core.bool, [dart.dynamic])); | 1921 return new (Future$()).sync(dart.fn(() => dart.dcall(f, iterator.curre
nt))).then(dart.fn(_ => true, core.bool, [core.Object])); |
| 1922 })); | 1922 })); |
| 1923 } | 1923 } |
| 1924 static doWhile(f) { | 1924 static doWhile(f) { |
| 1925 dart.as(f, dart.functionType(dart.dynamic, [])); | 1925 dart.as(f, dart.functionType(core.Object, [])); |
| 1926 let doneSignal = new _Future(); | 1926 let doneSignal = new _Future(); |
| 1927 let nextIteration = null; | 1927 let nextIteration = null; |
| 1928 nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => { | 1928 nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => { |
| 1929 if (keepGoing) { | 1929 if (keepGoing) { |
| 1930 new (Future$()).sync(f).then(dart.as(nextIteration, __CastType4), {o
nError: dart.bind(doneSignal, _completeError)}); | 1930 new (Future$()).sync(f).then(dart.as(nextIteration, __CastType4), {o
nError: dart.bind(doneSignal, _completeError)}); |
| 1931 } else { | 1931 } else { |
| 1932 doneSignal[_complete](null); | 1932 doneSignal[_complete](null); |
| 1933 } | 1933 } |
| 1934 }, dart.dynamic, [core.bool]), {runGuarded: true}); | 1934 }, core.Object, [core.bool]), {runGuarded: true}); |
| 1935 dart.dcall(nextIteration, true); | 1935 dart.dcall(nextIteration, true); |
| 1936 return doneSignal; | 1936 return doneSignal; |
| 1937 } | 1937 } |
| 1938 } | 1938 } |
| 1939 dart.defineNamedConstructor(Future, 'microtask'); | 1939 dart.defineNamedConstructor(Future, 'microtask'); |
| 1940 dart.defineNamedConstructor(Future, 'sync'); | 1940 dart.defineNamedConstructor(Future, 'sync'); |
| 1941 dart.defineNamedConstructor(Future, 'value'); | 1941 dart.defineNamedConstructor(Future, 'value'); |
| 1942 dart.defineNamedConstructor(Future, 'error'); | 1942 dart.defineNamedConstructor(Future, 'error'); |
| 1943 dart.defineNamedConstructor(Future, 'delayed'); | 1943 dart.defineNamedConstructor(Future, 'delayed'); |
| 1944 dart.setSignature(Future, { | 1944 dart.setSignature(Future, { |
| 1945 statics: () => ({ | 1945 statics: () => ({ |
| 1946 wait: dart.functionType(Future$(core.List), [core.Iterable$(Future$())],
{agerErro: core.bool, leanU: dart.functionType(dart.void, [dart.dynamic])}), | 1946 wait: dart.functionType(Future$(core.List), [core.Iterable$(Future$())],
{agerErro: core.bool, leanU: dart.functionType(dart.void, [dart.bottom])}), |
| 1947 forEach: dart.functionType(Future$(), [core.Iterable, dart.functionType(
dart.dynamic, [dart.dynamic])]), | 1947 forEach: dart.functionType(Future$(), [core.Iterable, dart.functionType(
core.Object, [dart.bottom])]), |
| 1948 doWhile: dart.functionType(Future$(), [dart.functionType(dart.dynamic, [
])]) | 1948 doWhile: dart.functionType(Future$(), [dart.functionType(core.Object, []
)]) |
| 1949 }), | 1949 }), |
| 1950 names: ['wait', 'forEach', 'doWhile'] | 1950 names: ['wait', 'forEach', 'doWhile'] |
| 1951 }); | 1951 }); |
| 1952 return Future; | 1952 return Future; |
| 1953 }); | 1953 }); |
| 1954 let Future = Future$(); | 1954 let Future = Future$(); |
| 1955 dart.defineLazyProperties(Future, { | 1955 dart.defineLazyProperties(Future, { |
| 1956 get _nullFuture() { | 1956 get _nullFuture() { |
| 1957 return new _Future.immediate(null); | 1957 return new _Future.immediate(null); |
| 1958 } | 1958 } |
| (...skipping 29 matching lines...) Expand all Loading... |
| 1988 }); | 1988 }); |
| 1989 let Completer = Completer$(); | 1989 let Completer = Completer$(); |
| 1990 function _completeWithErrorCallback(result, error, stackTrace) { | 1990 function _completeWithErrorCallback(result, error, stackTrace) { |
| 1991 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); | 1991 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); |
| 1992 if (replacement != null) { | 1992 if (replacement != null) { |
| 1993 error = _nonNullError(replacement.error); | 1993 error = _nonNullError(replacement.error); |
| 1994 stackTrace = replacement.stackTrace; | 1994 stackTrace = replacement.stackTrace; |
| 1995 } | 1995 } |
| 1996 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 1996 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
| 1997 } | 1997 } |
| 1998 dart.fn(_completeWithErrorCallback, () => dart.functionType(dart.void, [_Futur
e, dart.dynamic, dart.dynamic])); | 1998 dart.fn(_completeWithErrorCallback, () => dart.functionType(dart.void, [_Futur
e, core.Object, core.Object])); |
| 1999 function _nonNullError(error) { | 1999 function _nonNullError(error) { |
| 2000 return error != null ? error : new core.NullThrownError(); | 2000 return error != null ? error : new core.NullThrownError(); |
| 2001 } | 2001 } |
| 2002 dart.fn(_nonNullError, core.Object, [core.Object]); | 2002 dart.fn(_nonNullError, core.Object, [core.Object]); |
| 2003 let __CastType4 = dart.typedef('__CastType4', () => dart.functionType(dart.dyn
amic, [dart.dynamic])); | 2003 let __CastType4 = dart.typedef('__CastType4', () => dart.functionType(core.Obj
ect, [dart.bottom])); |
| 2004 let _FutureOnValue$ = dart.generic(function(T) { | 2004 let _FutureOnValue$ = dart.generic(function(T) { |
| 2005 let _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionType(
dart.dynamic, [T])); | 2005 let _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionType(
core.Object, [T])); |
| 2006 return _FutureOnValue; | 2006 return _FutureOnValue; |
| 2007 }); | 2007 }); |
| 2008 let _FutureOnValue = _FutureOnValue$(); | 2008 let _FutureOnValue = _FutureOnValue$(); |
| 2009 let _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionTyp
e(core.bool, [dart.dynamic])); | 2009 let _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionTyp
e(core.bool, [dart.bottom])); |
| 2010 let _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(dart
.dynamic, [])); | 2010 let _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(core
.Object, [])); |
| 2011 let _Completer$ = dart.generic(function(T) { | 2011 let _Completer$ = dart.generic(function(T) { |
| 2012 class _Completer extends core.Object { | 2012 class _Completer extends core.Object { |
| 2013 _Completer() { | 2013 _Completer() { |
| 2014 this.future = new (_Future$(T))(); | 2014 this.future = new (_Future$(T))(); |
| 2015 } | 2015 } |
| 2016 completeError(error, stackTrace) { | 2016 completeError(error, stackTrace) { |
| 2017 if (stackTrace === void 0) | 2017 if (stackTrace === void 0) |
| 2018 stackTrace = null; | 2018 stackTrace = null; |
| 2019 error = _nonNullError(error); | 2019 error = _nonNullError(error); |
| 2020 if (!dart.notNull(this.future[_mayComplete])) | 2020 if (!dart.notNull(this.future[_mayComplete])) |
| (...skipping 28 matching lines...) Expand all Loading... |
| 2049 if (!dart.notNull(this.future[_mayComplete])) | 2049 if (!dart.notNull(this.future[_mayComplete])) |
| 2050 throw new core.StateError("Future already completed"); | 2050 throw new core.StateError("Future already completed"); |
| 2051 this.future[_asyncComplete](value); | 2051 this.future[_asyncComplete](value); |
| 2052 } | 2052 } |
| 2053 [_completeError](error, stackTrace) { | 2053 [_completeError](error, stackTrace) { |
| 2054 this.future[_asyncCompleteError](error, stackTrace); | 2054 this.future[_asyncCompleteError](error, stackTrace); |
| 2055 } | 2055 } |
| 2056 } | 2056 } |
| 2057 dart.setSignature(_AsyncCompleter, { | 2057 dart.setSignature(_AsyncCompleter, { |
| 2058 methods: () => ({ | 2058 methods: () => ({ |
| 2059 complete: dart.functionType(dart.void, [], [dart.dynamic]), | 2059 complete: dart.functionType(dart.void, [], [core.Object]), |
| 2060 [_completeError]: dart.functionType(dart.void, [core.Object, core.StackT
race]) | 2060 [_completeError]: dart.functionType(dart.void, [core.Object, core.StackT
race]) |
| 2061 }) | 2061 }) |
| 2062 }); | 2062 }); |
| 2063 return _AsyncCompleter; | 2063 return _AsyncCompleter; |
| 2064 }); | 2064 }); |
| 2065 let _AsyncCompleter = _AsyncCompleter$(); | 2065 let _AsyncCompleter = _AsyncCompleter$(); |
| 2066 let _SyncCompleter$ = dart.generic(function(T) { | 2066 let _SyncCompleter$ = dart.generic(function(T) { |
| 2067 class _SyncCompleter extends _Completer$(T) { | 2067 class _SyncCompleter extends _Completer$(T) { |
| 2068 _SyncCompleter() { | 2068 _SyncCompleter() { |
| 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[_complete](value); | 2076 this.future[_complete](value); |
| 2077 } | 2077 } |
| 2078 [_completeError](error, stackTrace) { | 2078 [_completeError](error, stackTrace) { |
| 2079 this.future[_completeError](error, stackTrace); | 2079 this.future[_completeError](error, stackTrace); |
| 2080 } | 2080 } |
| 2081 } | 2081 } |
| 2082 dart.setSignature(_SyncCompleter, { | 2082 dart.setSignature(_SyncCompleter, { |
| 2083 methods: () => ({ | 2083 methods: () => ({ |
| 2084 complete: dart.functionType(dart.void, [], [dart.dynamic]), | 2084 complete: dart.functionType(dart.void, [], [core.Object]), |
| 2085 [_completeError]: dart.functionType(dart.void, [core.Object, core.StackT
race]) | 2085 [_completeError]: dart.functionType(dart.void, [core.Object, core.StackT
race]) |
| 2086 }) | 2086 }) |
| 2087 }); | 2087 }); |
| 2088 return _SyncCompleter; | 2088 return _SyncCompleter; |
| 2089 }); | 2089 }); |
| 2090 let _SyncCompleter = _SyncCompleter$(); | 2090 let _SyncCompleter = _SyncCompleter$(); |
| 2091 let _nextListener = Symbol('_nextListener'); | 2091 let _nextListener = Symbol('_nextListener'); |
| 2092 let _onValue = Symbol('_onValue'); | 2092 let _onValue = Symbol('_onValue'); |
| 2093 let _errorTest = Symbol('_errorTest'); | 2093 let _errorTest = Symbol('_errorTest'); |
| 2094 let _whenCompleteAction = Symbol('_whenCompleteAction'); | 2094 let _whenCompleteAction = Symbol('_whenCompleteAction'); |
| (...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2217 set [_isChained](value) { | 2217 set [_isChained](value) { |
| 2218 if (value) { | 2218 if (value) { |
| 2219 dart.assert(!dart.notNull(this[_isComplete])); | 2219 dart.assert(!dart.notNull(this[_isComplete])); |
| 2220 this[_state] = _Future$()._CHAINED; | 2220 this[_state] = _Future$()._CHAINED; |
| 2221 } else { | 2221 } else { |
| 2222 dart.assert(this[_isChained]); | 2222 dart.assert(this[_isChained]); |
| 2223 this[_state] = _Future$()._INCOMPLETE; | 2223 this[_state] = _Future$()._INCOMPLETE; |
| 2224 } | 2224 } |
| 2225 } | 2225 } |
| 2226 then(f, opts) { | 2226 then(f, opts) { |
| 2227 dart.as(f, dart.functionType(dart.dynamic, [T])); | 2227 dart.as(f, dart.functionType(core.Object, [T])); |
| 2228 let onError = opts && 'onError' in opts ? opts.onError : null; | 2228 let onError = opts && 'onError' in opts ? opts.onError : null; |
| 2229 let result = new (_Future$())(); | 2229 let result = new (_Future$())(); |
| 2230 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2230 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
| 2231 f = dart.as(result[_zone].registerUnaryCallback(f), __CastType6); | 2231 f = dart.as(result[_zone].registerUnaryCallback(f), __CastType6); |
| 2232 if (onError != null) { | 2232 if (onError != null) { |
| 2233 onError = _registerErrorHandler(onError, result[_zone]); | 2233 onError = _registerErrorHandler(onError, result[_zone]); |
| 2234 } | 2234 } |
| 2235 } | 2235 } |
| 2236 this[_addListener](new _FutureListener.then(result, f, onError)); | 2236 this[_addListener](new _FutureListener.then(result, f, onError)); |
| 2237 return result; | 2237 return result; |
| 2238 } | 2238 } |
| 2239 catchError(onError, opts) { | 2239 catchError(onError, opts) { |
| 2240 let test = opts && 'test' in opts ? opts.test : null; | 2240 let test = opts && 'test' in opts ? opts.test : null; |
| 2241 dart.as(test, dart.functionType(core.bool, [dart.dynamic])); | 2241 dart.as(test, dart.functionType(core.bool, [dart.bottom])); |
| 2242 let result = new (_Future$())(); | 2242 let result = new (_Future$())(); |
| 2243 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2243 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
| 2244 onError = _registerErrorHandler(onError, result[_zone]); | 2244 onError = _registerErrorHandler(onError, result[_zone]); |
| 2245 if (test != null) | 2245 if (test != null) |
| 2246 test = dart.as(result[_zone].registerUnaryCallback(test), __CastType
8); | 2246 test = dart.as(result[_zone].registerUnaryCallback(test), __CastType
8); |
| 2247 } | 2247 } |
| 2248 this[_addListener](new _FutureListener.catchError(result, onError, test)
); | 2248 this[_addListener](new _FutureListener.catchError(result, onError, test)
); |
| 2249 return result; | 2249 return result; |
| 2250 } | 2250 } |
| 2251 whenComplete(action) { | 2251 whenComplete(action) { |
| 2252 dart.as(action, dart.functionType(dart.dynamic, [])); | 2252 dart.as(action, dart.functionType(core.Object, [])); |
| 2253 let result = new (_Future$(T))(); | 2253 let result = new (_Future$(T))(); |
| 2254 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2254 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
| 2255 action = result[_zone].registerCallback(action); | 2255 action = result[_zone].registerCallback(action); |
| 2256 } | 2256 } |
| 2257 this[_addListener](new _FutureListener.whenComplete(result, action)); | 2257 this[_addListener](new _FutureListener.whenComplete(result, action)); |
| 2258 return dart.as(result, Future$(T)); | 2258 return dart.as(result, Future$(T)); |
| 2259 } | 2259 } |
| 2260 asStream() { | 2260 asStream() { |
| 2261 return new (Stream$(T)).fromFuture(this); | 2261 return new (Stream$(T)).fromFuture(this); |
| 2262 } | 2262 } |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2316 dart.assert(!dart.is(source, _Future$())); | 2316 dart.assert(!dart.is(source, _Future$())); |
| 2317 target[_isChained] = true; | 2317 target[_isChained] = true; |
| 2318 source.then(dart.fn(value => { | 2318 source.then(dart.fn(value => { |
| 2319 dart.assert(target[_isChained]); | 2319 dart.assert(target[_isChained]); |
| 2320 target[_completeWithValue](value); | 2320 target[_completeWithValue](value); |
| 2321 }), {onError: dart.fn((error, stackTrace) => { | 2321 }), {onError: dart.fn((error, stackTrace) => { |
| 2322 if (stackTrace === void 0) | 2322 if (stackTrace === void 0) |
| 2323 stackTrace = null; | 2323 stackTrace = null; |
| 2324 dart.assert(target[_isChained]); | 2324 dart.assert(target[_isChained]); |
| 2325 target[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 2325 target[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
| 2326 }, dart.dynamic, [dart.dynamic], [dart.dynamic])}); | 2326 }, core.Object, [core.Object], [core.Object])}); |
| 2327 } | 2327 } |
| 2328 static _chainCoreFuture(source, target) { | 2328 static _chainCoreFuture(source, target) { |
| 2329 dart.assert(!dart.notNull(target[_isComplete])); | 2329 dart.assert(!dart.notNull(target[_isComplete])); |
| 2330 dart.assert(dart.is(source, _Future$())); | 2330 dart.assert(dart.is(source, _Future$())); |
| 2331 target[_isChained] = true; | 2331 target[_isChained] = true; |
| 2332 let listener = new _FutureListener.chain(target); | 2332 let listener = new _FutureListener.chain(target); |
| 2333 if (source[_isComplete]) { | 2333 if (source[_isComplete]) { |
| 2334 _Future$()._propagateToListeners(source, listener); | 2334 _Future$()._propagateToListeners(source, listener); |
| 2335 } else { | 2335 } else { |
| 2336 source[_addListener](listener); | 2336 source[_addListener](listener); |
| (...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2503 dart.dsend(completeResult, 'then', dart.fn(ignored => { | 2503 dart.dsend(completeResult, 'then', dart.fn(ignored => { |
| 2504 _Future$()._propagateToListeners(source, new _FutureListener.c
hain(result)); | 2504 _Future$()._propagateToListeners(source, new _FutureListener.c
hain(result)); |
| 2505 }), {onError: dart.fn((error, stackTrace) => { | 2505 }), {onError: dart.fn((error, stackTrace) => { |
| 2506 if (stackTrace === void 0) | 2506 if (stackTrace === void 0) |
| 2507 stackTrace = null; | 2507 stackTrace = null; |
| 2508 if (!dart.is(completeResult, _Future$())) { | 2508 if (!dart.is(completeResult, _Future$())) { |
| 2509 completeResult = new (_Future$())(); | 2509 completeResult = new (_Future$())(); |
| 2510 dart.dsend(completeResult, _setError, error, stackTrace); | 2510 dart.dsend(completeResult, _setError, error, stackTrace); |
| 2511 } | 2511 } |
| 2512 _Future$()._propagateToListeners(dart.as(completeResult, _Fu
ture$()), new _FutureListener.chain(result)); | 2512 _Future$()._propagateToListeners(dart.as(completeResult, _Fu
ture$()), new _FutureListener.chain(result)); |
| 2513 }, dart.dynamic, [dart.dynamic], [dart.dynamic])}); | 2513 }, core.Object, [core.Object], [core.Object])}); |
| 2514 } | 2514 } |
| 2515 }; | 2515 }; |
| 2516 dart.fn(handleWhenCompleteCallback, dart.void, []); | 2516 dart.fn(handleWhenCompleteCallback, dart.void, []); |
| 2517 if (!dart.notNull(hasError)) { | 2517 if (!dart.notNull(hasError)) { |
| 2518 if (listener.handlesValue) { | 2518 if (listener.handlesValue) { |
| 2519 listenerHasValue = handleValueCallback(); | 2519 listenerHasValue = handleValueCallback(); |
| 2520 } | 2520 } |
| 2521 } else { | 2521 } else { |
| 2522 handleError(); | 2522 handleError(); |
| 2523 } | 2523 } |
| (...skipping 28 matching lines...) Expand all Loading... |
| 2552 result[_setValue](listenerValueOrError); | 2552 result[_setValue](listenerValueOrError); |
| 2553 } else { | 2553 } else { |
| 2554 let asyncError = dart.as(listenerValueOrError, AsyncError); | 2554 let asyncError = dart.as(listenerValueOrError, AsyncError); |
| 2555 result[_setErrorObject](asyncError); | 2555 result[_setErrorObject](asyncError); |
| 2556 } | 2556 } |
| 2557 source = result; | 2557 source = result; |
| 2558 } | 2558 } |
| 2559 } | 2559 } |
| 2560 timeout(timeLimit, opts) { | 2560 timeout(timeLimit, opts) { |
| 2561 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; | 2561 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; |
| 2562 dart.as(onTimeout, dart.functionType(dart.dynamic, [])); | 2562 dart.as(onTimeout, dart.functionType(core.Object, [])); |
| 2563 if (this[_isComplete]) | 2563 if (this[_isComplete]) |
| 2564 return new (_Future$()).immediate(this); | 2564 return new (_Future$()).immediate(this); |
| 2565 let result = new (_Future$())(); | 2565 let result = new (_Future$())(); |
| 2566 let timer = null; | 2566 let timer = null; |
| 2567 if (onTimeout == null) { | 2567 if (onTimeout == null) { |
| 2568 timer = new Timer(timeLimit, dart.fn(() => { | 2568 timer = new Timer(timeLimit, dart.fn(() => { |
| 2569 result[_completeError](new TimeoutException("Future not completed",
timeLimit)); | 2569 result[_completeError](new TimeoutException("Future not completed",
timeLimit)); |
| 2570 })); | 2570 })); |
| 2571 } else { | 2571 } else { |
| 2572 let zone = Zone.current; | 2572 let zone = Zone.current; |
| 2573 onTimeout = zone.registerCallback(onTimeout); | 2573 onTimeout = zone.registerCallback(onTimeout); |
| 2574 timer = new Timer(timeLimit, dart.fn(() => { | 2574 timer = new Timer(timeLimit, dart.fn(() => { |
| 2575 try { | 2575 try { |
| 2576 result[_complete](zone.run(onTimeout)); | 2576 result[_complete](zone.run(onTimeout)); |
| 2577 } catch (e) { | 2577 } catch (e) { |
| 2578 let s = dart.stackTrace(e); | 2578 let s = dart.stackTrace(e); |
| 2579 result[_completeError](e, s); | 2579 result[_completeError](e, s); |
| 2580 } | 2580 } |
| 2581 | 2581 |
| 2582 })); | 2582 })); |
| 2583 } | 2583 } |
| 2584 this.then(dart.fn(v => { | 2584 this.then(dart.fn(v => { |
| 2585 dart.as(v, T); | 2585 dart.as(v, T); |
| 2586 if (timer.isActive) { | 2586 if (timer.isActive) { |
| 2587 timer.cancel(); | 2587 timer.cancel(); |
| 2588 result[_completeWithValue](v); | 2588 result[_completeWithValue](v); |
| 2589 } | 2589 } |
| 2590 }, dart.dynamic, [T]), {onError: dart.fn((e, s) => { | 2590 }, core.Object, [T]), {onError: dart.fn((e, s) => { |
| 2591 if (timer.isActive) { | 2591 if (timer.isActive) { |
| 2592 timer.cancel(); | 2592 timer.cancel(); |
| 2593 result[_completeError](e, dart.as(s, core.StackTrace)); | 2593 result[_completeError](e, dart.as(s, core.StackTrace)); |
| 2594 } | 2594 } |
| 2595 })}); | 2595 })}); |
| 2596 return result; | 2596 return result; |
| 2597 } | 2597 } |
| 2598 } | 2598 } |
| 2599 _Future[dart.implements] = () => [Future$(T)]; | 2599 _Future[dart.implements] = () => [Future$(T)]; |
| 2600 dart.defineNamedConstructor(_Future, 'immediate'); | 2600 dart.defineNamedConstructor(_Future, 'immediate'); |
| 2601 dart.defineNamedConstructor(_Future, 'immediateError'); | 2601 dart.defineNamedConstructor(_Future, 'immediateError'); |
| 2602 dart.setSignature(_Future, { | 2602 dart.setSignature(_Future, { |
| 2603 methods: () => ({ | 2603 methods: () => ({ |
| 2604 then: dart.functionType(Future, [dart.functionType(dart.dynamic, [T])],
{nErro: core.Function}), | 2604 then: dart.functionType(Future, [dart.functionType(core.Object, [T])], {
nErro: core.Function}), |
| 2605 catchError: dart.functionType(Future, [core.Function], {es: dart.functio
nType(core.bool, [dart.dynamic])}), | 2605 catchError: dart.functionType(Future, [core.Function], {es: dart.functio
nType(core.bool, [dart.bottom])}), |
| 2606 whenComplete: dart.functionType(Future$(T), [dart.functionType(dart.dyna
mic, [])]), | 2606 whenComplete: dart.functionType(Future$(T), [dart.functionType(core.Obje
ct, [])]), |
| 2607 asStream: dart.functionType(Stream$(T), []), | 2607 asStream: dart.functionType(Stream$(T), []), |
| 2608 [_markPendingCompletion]: dart.functionType(dart.void, []), | 2608 [_markPendingCompletion]: dart.functionType(dart.void, []), |
| 2609 [_setValue]: dart.functionType(dart.void, [T]), | 2609 [_setValue]: dart.functionType(dart.void, [T]), |
| 2610 [_setErrorObject]: dart.functionType(dart.void, [AsyncError]), | 2610 [_setErrorObject]: dart.functionType(dart.void, [AsyncError]), |
| 2611 [_setError]: dart.functionType(dart.void, [core.Object, core.StackTrace]
), | 2611 [_setError]: dart.functionType(dart.void, [core.Object, core.StackTrace]
), |
| 2612 [_addListener]: dart.functionType(dart.void, [_FutureListener]), | 2612 [_addListener]: dart.functionType(dart.void, [_FutureListener]), |
| 2613 [_removeListeners]: dart.functionType(_FutureListener, []), | 2613 [_removeListeners]: dart.functionType(_FutureListener, []), |
| 2614 [_complete]: dart.functionType(dart.void, [dart.dynamic]), | 2614 [_complete]: dart.functionType(dart.void, [core.Object]), |
| 2615 [_completeWithValue]: dart.functionType(dart.void, [dart.dynamic]), | 2615 [_completeWithValue]: dart.functionType(dart.void, [core.Object]), |
| 2616 [_completeError]: dart.functionType(dart.void, [dart.dynamic], [core.Sta
ckTrace]), | 2616 [_completeError]: dart.functionType(dart.void, [core.Object], [core.Stac
kTrace]), |
| 2617 [_asyncComplete]: dart.functionType(dart.void, [dart.dynamic]), | 2617 [_asyncComplete]: dart.functionType(dart.void, [core.Object]), |
| 2618 [_asyncCompleteError]: dart.functionType(dart.void, [dart.dynamic, core.
StackTrace]), | 2618 [_asyncCompleteError]: dart.functionType(dart.void, [core.Object, core.S
tackTrace]), |
| 2619 timeout: dart.functionType(Future, [core.Duration], {nTimeou: dart.funct
ionType(dart.dynamic, [])}) | 2619 timeout: dart.functionType(Future, [core.Duration], {nTimeou: dart.funct
ionType(core.Object, [])}) |
| 2620 }), | 2620 }), |
| 2621 statics: () => ({ | 2621 statics: () => ({ |
| 2622 _chainForeignFuture: dart.functionType(dart.void, [Future, _Future$()]), | 2622 _chainForeignFuture: dart.functionType(dart.void, [Future, _Future$()]), |
| 2623 _chainCoreFuture: dart.functionType(dart.void, [_Future$(), _Future$()])
, | 2623 _chainCoreFuture: dart.functionType(dart.void, [_Future$(), _Future$()])
, |
| 2624 _propagateToListeners: dart.functionType(dart.void, [_Future$(), _Future
Listener]) | 2624 _propagateToListeners: dart.functionType(dart.void, [_Future$(), _Future
Listener]) |
| 2625 }), | 2625 }), |
| 2626 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] | 2626 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] |
| 2627 }); | 2627 }); |
| 2628 return _Future; | 2628 return _Future; |
| 2629 }); | 2629 }); |
| 2630 let _Future = _Future$(); | 2630 let _Future = _Future$(); |
| 2631 _Future._INCOMPLETE = 0; | 2631 _Future._INCOMPLETE = 0; |
| 2632 _Future._PENDING_COMPLETE = 1; | 2632 _Future._PENDING_COMPLETE = 1; |
| 2633 _Future._CHAINED = 2; | 2633 _Future._CHAINED = 2; |
| 2634 _Future._VALUE = 4; | 2634 _Future._VALUE = 4; |
| 2635 _Future._ERROR = 8; | 2635 _Future._ERROR = 8; |
| 2636 let __CastType6$ = dart.generic(function(T) { | 2636 let __CastType6$ = dart.generic(function(T) { |
| 2637 let __CastType6 = dart.typedef('__CastType6', () => dart.functionType(dart.d
ynamic, [T])); | 2637 let __CastType6 = dart.typedef('__CastType6', () => dart.functionType(core.O
bject, [T])); |
| 2638 return __CastType6; | 2638 return __CastType6; |
| 2639 }); | 2639 }); |
| 2640 let __CastType6 = __CastType6$(); | 2640 let __CastType6 = __CastType6$(); |
| 2641 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo
l, [dart.dynamic])); | 2641 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo
l, [dart.bottom])); |
| 2642 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); | 2642 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(core.O
bject, [dart.bottom])); |
| 2643 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da
rt.void, [])); | 2643 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da
rt.void, [])); |
| 2644 class _AsyncCallbackEntry extends core.Object { | 2644 class _AsyncCallbackEntry extends core.Object { |
| 2645 _AsyncCallbackEntry(callback) { | 2645 _AsyncCallbackEntry(callback) { |
| 2646 this.callback = callback; | 2646 this.callback = callback; |
| 2647 this.next = null; | 2647 this.next = null; |
| 2648 } | 2648 } |
| 2649 } | 2649 } |
| 2650 exports._nextCallback = null; | 2650 exports._nextCallback = null; |
| 2651 exports._lastCallback = null; | 2651 exports._lastCallback = null; |
| 2652 exports._lastPriorityCallback = null; | 2652 exports._lastPriorityCallback = null; |
| (...skipping 26 matching lines...) Expand all Loading... |
| 2679 exports._nextCallback = exports._lastCallback = new _AsyncCallbackEntry(da
rt.as(callback, _AsyncCallback)); | 2679 exports._nextCallback = exports._lastCallback = new _AsyncCallbackEntry(da
rt.as(callback, _AsyncCallback)); |
| 2680 if (!dart.notNull(exports._isInCallbackLoop)) { | 2680 if (!dart.notNull(exports._isInCallbackLoop)) { |
| 2681 _AsyncRun._scheduleImmediate(_asyncRunCallback); | 2681 _AsyncRun._scheduleImmediate(_asyncRunCallback); |
| 2682 } | 2682 } |
| 2683 } else { | 2683 } else { |
| 2684 let newEntry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); | 2684 let newEntry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); |
| 2685 exports._lastCallback.next = newEntry; | 2685 exports._lastCallback.next = newEntry; |
| 2686 exports._lastCallback = newEntry; | 2686 exports._lastCallback = newEntry; |
| 2687 } | 2687 } |
| 2688 } | 2688 } |
| 2689 dart.fn(_scheduleAsyncCallback, dart.void, [dart.dynamic]); | 2689 dart.fn(_scheduleAsyncCallback, dart.void, [core.Object]); |
| 2690 function _schedulePriorityAsyncCallback(callback) { | 2690 function _schedulePriorityAsyncCallback(callback) { |
| 2691 let entry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); | 2691 let entry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); |
| 2692 if (exports._nextCallback == null) { | 2692 if (exports._nextCallback == null) { |
| 2693 _scheduleAsyncCallback(callback); | 2693 _scheduleAsyncCallback(callback); |
| 2694 exports._lastPriorityCallback = exports._lastCallback; | 2694 exports._lastPriorityCallback = exports._lastCallback; |
| 2695 } else if (exports._lastPriorityCallback == null) { | 2695 } else if (exports._lastPriorityCallback == null) { |
| 2696 entry.next = exports._nextCallback; | 2696 entry.next = exports._nextCallback; |
| 2697 exports._nextCallback = exports._lastPriorityCallback = entry; | 2697 exports._nextCallback = exports._lastPriorityCallback = entry; |
| 2698 } else { | 2698 } else { |
| 2699 entry.next = exports._lastPriorityCallback.next; | 2699 entry.next = exports._lastPriorityCallback.next; |
| 2700 exports._lastPriorityCallback.next = entry; | 2700 exports._lastPriorityCallback.next = entry; |
| 2701 exports._lastPriorityCallback = entry; | 2701 exports._lastPriorityCallback = entry; |
| 2702 if (entry.next == null) { | 2702 if (entry.next == null) { |
| 2703 exports._lastCallback = entry; | 2703 exports._lastCallback = entry; |
| 2704 } | 2704 } |
| 2705 } | 2705 } |
| 2706 } | 2706 } |
| 2707 dart.fn(_schedulePriorityAsyncCallback, dart.void, [dart.dynamic]); | 2707 dart.fn(_schedulePriorityAsyncCallback, dart.void, [core.Object]); |
| 2708 function scheduleMicrotask(callback) { | 2708 function scheduleMicrotask(callback) { |
| 2709 if (core.identical(_ROOT_ZONE, Zone.current)) { | 2709 if (core.identical(_ROOT_ZONE, Zone.current)) { |
| 2710 _rootScheduleMicrotask(null, null, _ROOT_ZONE, callback); | 2710 _rootScheduleMicrotask(null, null, _ROOT_ZONE, callback); |
| 2711 return; | 2711 return; |
| 2712 } | 2712 } |
| 2713 Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuard
ed: true})); | 2713 Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuard
ed: true})); |
| 2714 } | 2714 } |
| 2715 dart.fn(scheduleMicrotask, dart.void, [dart.functionType(dart.void, [])]); | 2715 dart.fn(scheduleMicrotask, dart.void, [dart.functionType(dart.void, [])]); |
| 2716 class _AsyncRun extends core.Object { | 2716 class _AsyncRun extends core.Object { |
| 2717 static _scheduleImmediate(callback) { | 2717 static _scheduleImmediate(callback) { |
| (...skipping 16 matching lines...) Expand all Loading... |
| 2734 }; | 2734 }; |
| 2735 dart.fn(internalCallback); | 2735 dart.fn(internalCallback); |
| 2736 ; | 2736 ; |
| 2737 let observer = new self.MutationObserver(_js_helper.convertDartClosureTo
JS(internalCallback, 1)); | 2737 let observer = new self.MutationObserver(_js_helper.convertDartClosureTo
JS(internalCallback, 1)); |
| 2738 observer.observe(div, {childList: true}); | 2738 observer.observe(div, {childList: true}); |
| 2739 return dart.fn(callback => { | 2739 return dart.fn(callback => { |
| 2740 dart.assert(storedCallback == null); | 2740 dart.assert(storedCallback == null); |
| 2741 _isolate_helper.enterJsAsync(); | 2741 _isolate_helper.enterJsAsync(); |
| 2742 storedCallback = callback; | 2742 storedCallback = callback; |
| 2743 div.firstChild ? div.removeChild(span) : div.appendChild(span); | 2743 div.firstChild ? div.removeChild(span) : div.appendChild(span); |
| 2744 }, dart.dynamic, [dart.functionType(dart.void, [])]); | 2744 }, core.Object, [dart.functionType(dart.void, [])]); |
| 2745 } else if (self.setImmediate != null) { | 2745 } else if (self.setImmediate != null) { |
| 2746 return _AsyncRun._scheduleImmediateWithSetImmediate; | 2746 return _AsyncRun._scheduleImmediateWithSetImmediate; |
| 2747 } | 2747 } |
| 2748 return _AsyncRun._scheduleImmediateWithTimer; | 2748 return _AsyncRun._scheduleImmediateWithTimer; |
| 2749 } | 2749 } |
| 2750 static _scheduleImmediateJsOverride(callback) { | 2750 static _scheduleImmediateJsOverride(callback) { |
| 2751 let internalCallback = () => { | 2751 let internalCallback = () => { |
| 2752 _isolate_helper.leaveJsAsync(); | 2752 _isolate_helper.leaveJsAsync(); |
| 2753 callback(); | 2753 callback(); |
| 2754 }; | 2754 }; |
| (...skipping 125 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2880 this[_sink].addError(error, stackTrace); | 2880 this[_sink].addError(error, stackTrace); |
| 2881 } | 2881 } |
| 2882 close() { | 2882 close() { |
| 2883 this[_sink].close(); | 2883 this[_sink].close(); |
| 2884 } | 2884 } |
| 2885 } | 2885 } |
| 2886 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; | 2886 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; |
| 2887 dart.setSignature(_ControllerEventSinkWrapper, { | 2887 dart.setSignature(_ControllerEventSinkWrapper, { |
| 2888 methods: () => ({ | 2888 methods: () => ({ |
| 2889 add: dart.functionType(dart.void, [T]), | 2889 add: dart.functionType(dart.void, [T]), |
| 2890 addError: dart.functionType(dart.void, [dart.dynamic], [core.StackTrace]
), | 2890 addError: dart.functionType(dart.void, [core.Object], [core.StackTrace])
, |
| 2891 close: dart.functionType(dart.void, []) | 2891 close: dart.functionType(dart.void, []) |
| 2892 }) | 2892 }) |
| 2893 }); | 2893 }); |
| 2894 return _ControllerEventSinkWrapper; | 2894 return _ControllerEventSinkWrapper; |
| 2895 }); | 2895 }); |
| 2896 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); | 2896 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); |
| 2897 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v
oid, [StreamSubscription])); | 2897 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v
oid, [StreamSubscription])); |
| 2898 let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart.d
ynamic, [dart.dynamic, core.StackTrace])); | 2898 let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(core.O
bject, [dart.bottom, core.StackTrace])); |
| 2899 let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.v
oid, [])); | 2899 let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.v
oid, [])); |
| 2900 let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.v
oid, [EventSink])); | 2900 let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.v
oid, [EventSink])); |
| 2901 let StreamController$ = dart.generic(function(T) { | 2901 let StreamController$ = dart.generic(function(T) { |
| 2902 class StreamController extends core.Object { | 2902 class StreamController extends core.Object { |
| 2903 StreamController(opts) { | 2903 StreamController(opts) { |
| 2904 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2904 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 2905 let onPause = opts && 'onPause' in opts ? opts.onPause : null; | 2905 let onPause = opts && 'onPause' in opts ? opts.onPause : null; |
| 2906 let onResume = opts && 'onResume' in opts ? opts.onResume : null; | 2906 let onResume = opts && 'onResume' in opts ? opts.onResume : null; |
| 2907 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2907 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 2908 let sync = opts && 'sync' in opts ? opts.sync : false; | 2908 let sync = opts && 'sync' in opts ? opts.sync : false; |
| (...skipping 378 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3287 } | 3287 } |
| 3288 get [_onResume]() { | 3288 get [_onResume]() { |
| 3289 return null; | 3289 return null; |
| 3290 } | 3290 } |
| 3291 get [_onCancel]() { | 3291 get [_onCancel]() { |
| 3292 return null; | 3292 return null; |
| 3293 } | 3293 } |
| 3294 } | 3294 } |
| 3295 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _
AsyncStreamControllerDispatch, _NoCallbacks) {} | 3295 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _
AsyncStreamControllerDispatch, _NoCallbacks) {} |
| 3296 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S
yncStreamControllerDispatch, _NoCallbacks) {} | 3296 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S
yncStreamControllerDispatch, _NoCallbacks) {} |
| 3297 let _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.fun
ctionType(dart.dynamic, [])); | 3297 let _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.fun
ctionType(core.Object, [])); |
| 3298 function _runGuarded(notificationHandler) { | 3298 function _runGuarded(notificationHandler) { |
| 3299 if (notificationHandler == null) | 3299 if (notificationHandler == null) |
| 3300 return null; | 3300 return null; |
| 3301 try { | 3301 try { |
| 3302 let result = notificationHandler(); | 3302 let result = notificationHandler(); |
| 3303 if (dart.is(result, Future)) | 3303 if (dart.is(result, Future)) |
| 3304 return dart.as(result, Future); | 3304 return dart.as(result, Future); |
| 3305 return null; | 3305 return null; |
| 3306 } catch (e) { | 3306 } catch (e) { |
| 3307 let s = dart.stackTrace(e); | 3307 let s = dart.stackTrace(e); |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3352 let _AddStreamState$ = dart.generic(function(T) { | 3352 let _AddStreamState$ = dart.generic(function(T) { |
| 3353 class _AddStreamState extends core.Object { | 3353 class _AddStreamState extends core.Object { |
| 3354 _AddStreamState(controller, source, cancelOnError) { | 3354 _AddStreamState(controller, source, cancelOnError) { |
| 3355 this.addStreamFuture = new _Future(); | 3355 this.addStreamFuture = new _Future(); |
| 3356 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}); | 3356 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}); |
| 3357 } | 3357 } |
| 3358 static makeErrorHandler(controller) { | 3358 static makeErrorHandler(controller) { |
| 3359 return dart.fn((e, s) => { | 3359 return dart.fn((e, s) => { |
| 3360 controller[_addError](e, s); | 3360 controller[_addError](e, s); |
| 3361 controller[_close](); | 3361 controller[_close](); |
| 3362 }, dart.dynamic, [dart.dynamic, core.StackTrace]); | 3362 }, core.Object, [core.Object, core.StackTrace]); |
| 3363 } | 3363 } |
| 3364 pause() { | 3364 pause() { |
| 3365 this.addSubscription.pause(); | 3365 this.addSubscription.pause(); |
| 3366 } | 3366 } |
| 3367 resume() { | 3367 resume() { |
| 3368 this.addSubscription.resume(); | 3368 this.addSubscription.resume(); |
| 3369 } | 3369 } |
| 3370 cancel() { | 3370 cancel() { |
| 3371 let cancel = this.addSubscription.cancel(); | 3371 let cancel = this.addSubscription.cancel(); |
| 3372 if (cancel == null) { | 3372 if (cancel == null) { |
| 3373 this.addStreamFuture[_asyncComplete](null); | 3373 this.addStreamFuture[_asyncComplete](null); |
| 3374 return null; | 3374 return null; |
| 3375 } | 3375 } |
| 3376 return cancel.whenComplete(dart.fn((() => { | 3376 return cancel.whenComplete(dart.fn((() => { |
| 3377 this.addStreamFuture[_asyncComplete](null); | 3377 this.addStreamFuture[_asyncComplete](null); |
| 3378 }).bind(this))); | 3378 }).bind(this))); |
| 3379 } | 3379 } |
| 3380 complete() { | 3380 complete() { |
| 3381 this.addStreamFuture[_asyncComplete](null); | 3381 this.addStreamFuture[_asyncComplete](null); |
| 3382 } | 3382 } |
| 3383 } | 3383 } |
| 3384 dart.setSignature(_AddStreamState, { | 3384 dart.setSignature(_AddStreamState, { |
| 3385 methods: () => ({ | 3385 methods: () => ({ |
| 3386 pause: dart.functionType(dart.void, []), | 3386 pause: dart.functionType(dart.void, []), |
| 3387 resume: dart.functionType(dart.void, []), | 3387 resume: dart.functionType(dart.void, []), |
| 3388 cancel: dart.functionType(Future, []), | 3388 cancel: dart.functionType(Future, []), |
| 3389 complete: dart.functionType(dart.void, []) | 3389 complete: dart.functionType(dart.void, []) |
| 3390 }), | 3390 }), |
| 3391 statics: () => ({makeErrorHandler: dart.functionType(dart.dynamic, [_Event
Sink])}), | 3391 statics: () => ({makeErrorHandler: dart.functionType(core.Object, [_EventS
ink])}), |
| 3392 names: ['makeErrorHandler'] | 3392 names: ['makeErrorHandler'] |
| 3393 }); | 3393 }); |
| 3394 return _AddStreamState; | 3394 return _AddStreamState; |
| 3395 }); | 3395 }); |
| 3396 let _AddStreamState = _AddStreamState$(); | 3396 let _AddStreamState = _AddStreamState$(); |
| 3397 let _StreamControllerAddStreamState$ = dart.generic(function(T) { | 3397 let _StreamControllerAddStreamState$ = dart.generic(function(T) { |
| 3398 class _StreamControllerAddStreamState extends _AddStreamState$(T) { | 3398 class _StreamControllerAddStreamState extends _AddStreamState$(T) { |
| 3399 _StreamControllerAddStreamState(controller, varData, source, cancelOnError
) { | 3399 _StreamControllerAddStreamState(controller, varData, source, cancelOnError
) { |
| 3400 this.varData = varData; | 3400 this.varData = varData; |
| 3401 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance
lOnError); | 3401 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance
lOnError); |
| (...skipping 138 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3540 }); | 3540 }); |
| 3541 let _IterablePendingEvents = _IterablePendingEvents$(); | 3541 let _IterablePendingEvents = _IterablePendingEvents$(); |
| 3542 let _DataHandler$ = dart.generic(function(T) { | 3542 let _DataHandler$ = dart.generic(function(T) { |
| 3543 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart
.void, [T])); | 3543 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart
.void, [T])); |
| 3544 return _DataHandler; | 3544 return _DataHandler; |
| 3545 }); | 3545 }); |
| 3546 let _DataHandler = _DataHandler$(); | 3546 let _DataHandler = _DataHandler$(); |
| 3547 let _DoneHandler = dart.typedef('_DoneHandler', () => dart.functionType(dart.v
oid, [])); | 3547 let _DoneHandler = dart.typedef('_DoneHandler', () => dart.functionType(dart.v
oid, [])); |
| 3548 function _nullDataHandler(value) { | 3548 function _nullDataHandler(value) { |
| 3549 } | 3549 } |
| 3550 dart.fn(_nullDataHandler, dart.void, [dart.dynamic]); | 3550 dart.fn(_nullDataHandler, dart.void, [core.Object]); |
| 3551 function _nullErrorHandler(error, stackTrace) { | 3551 function _nullErrorHandler(error, stackTrace) { |
| 3552 if (stackTrace === void 0) | 3552 if (stackTrace === void 0) |
| 3553 stackTrace = null; | 3553 stackTrace = null; |
| 3554 Zone.current.handleUncaughtError(error, stackTrace); | 3554 Zone.current.handleUncaughtError(error, stackTrace); |
| 3555 } | 3555 } |
| 3556 dart.fn(_nullErrorHandler, dart.void, [dart.dynamic], [core.StackTrace]); | 3556 dart.fn(_nullErrorHandler, dart.void, [core.Object], [core.StackTrace]); |
| 3557 function _nullDoneHandler() { | 3557 function _nullDoneHandler() { |
| 3558 } | 3558 } |
| 3559 dart.fn(_nullDoneHandler, dart.void, []); | 3559 dart.fn(_nullDoneHandler, dart.void, []); |
| 3560 let _DelayedEvent$ = dart.generic(function(T) { | 3560 let _DelayedEvent$ = dart.generic(function(T) { |
| 3561 class _DelayedEvent extends core.Object { | 3561 class _DelayedEvent extends core.Object { |
| 3562 _DelayedEvent() { | 3562 _DelayedEvent() { |
| 3563 this.next = null; | 3563 this.next = null; |
| 3564 } | 3564 } |
| 3565 } | 3565 } |
| 3566 return _DelayedEvent; | 3566 return _DelayedEvent; |
| (...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3754 _DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)]; | 3754 _DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)]; |
| 3755 dart.setSignature(_DoneStreamSubscription, { | 3755 dart.setSignature(_DoneStreamSubscription, { |
| 3756 methods: () => ({ | 3756 methods: () => ({ |
| 3757 [_schedule]: dart.functionType(dart.void, []), | 3757 [_schedule]: dart.functionType(dart.void, []), |
| 3758 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])]
), | 3758 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])]
), |
| 3759 onError: dart.functionType(dart.void, [core.Function]), | 3759 onError: dart.functionType(dart.void, [core.Function]), |
| 3760 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])])
, | 3760 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])])
, |
| 3761 pause: dart.functionType(dart.void, [], [Future]), | 3761 pause: dart.functionType(dart.void, [], [Future]), |
| 3762 resume: dart.functionType(dart.void, []), | 3762 resume: dart.functionType(dart.void, []), |
| 3763 cancel: dart.functionType(Future, []), | 3763 cancel: dart.functionType(Future, []), |
| 3764 asFuture: dart.functionType(Future, [], [dart.dynamic]), | 3764 asFuture: dart.functionType(Future, [], [core.Object]), |
| 3765 [_sendDone]: dart.functionType(dart.void, []) | 3765 [_sendDone]: dart.functionType(dart.void, []) |
| 3766 }) | 3766 }) |
| 3767 }); | 3767 }); |
| 3768 return _DoneStreamSubscription; | 3768 return _DoneStreamSubscription; |
| 3769 }); | 3769 }); |
| 3770 let _DoneStreamSubscription = _DoneStreamSubscription$(); | 3770 let _DoneStreamSubscription = _DoneStreamSubscription$(); |
| 3771 _DoneStreamSubscription._DONE_SENT = 1; | 3771 _DoneStreamSubscription._DONE_SENT = 1; |
| 3772 _DoneStreamSubscription._SCHEDULED = 2; | 3772 _DoneStreamSubscription._SCHEDULED = 2; |
| 3773 _DoneStreamSubscription._PAUSED = 4; | 3773 _DoneStreamSubscription._PAUSED = 4; |
| 3774 let _source = Symbol('_source'); | 3774 let _source = Symbol('_source'); |
| (...skipping 126 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3901 } | 3901 } |
| 3902 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; | 3902 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; |
| 3903 dart.setSignature(_BroadcastSubscriptionWrapper, { | 3903 dart.setSignature(_BroadcastSubscriptionWrapper, { |
| 3904 methods: () => ({ | 3904 methods: () => ({ |
| 3905 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])]
), | 3905 onData: dart.functionType(dart.void, [dart.functionType(dart.void, [T])]
), |
| 3906 onError: dart.functionType(dart.void, [core.Function]), | 3906 onError: dart.functionType(dart.void, [core.Function]), |
| 3907 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])])
, | 3907 onDone: dart.functionType(dart.void, [dart.functionType(dart.void, [])])
, |
| 3908 pause: dart.functionType(dart.void, [], [Future]), | 3908 pause: dart.functionType(dart.void, [], [Future]), |
| 3909 resume: dart.functionType(dart.void, []), | 3909 resume: dart.functionType(dart.void, []), |
| 3910 cancel: dart.functionType(Future, []), | 3910 cancel: dart.functionType(Future, []), |
| 3911 asFuture: dart.functionType(Future, [], [dart.dynamic]) | 3911 asFuture: dart.functionType(Future, [], [core.Object]) |
| 3912 }) | 3912 }) |
| 3913 }); | 3913 }); |
| 3914 return _BroadcastSubscriptionWrapper; | 3914 return _BroadcastSubscriptionWrapper; |
| 3915 }); | 3915 }); |
| 3916 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); | 3916 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); |
| 3917 let _current = Symbol('_current'); | 3917 let _current = Symbol('_current'); |
| 3918 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); | 3918 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); |
| 3919 let _clear = Symbol('_clear'); | 3919 let _clear = Symbol('_clear'); |
| 3920 let _StreamIteratorImpl$ = dart.generic(function(T) { | 3920 let _StreamIteratorImpl$ = dart.generic(function(T) { |
| 3921 class _StreamIteratorImpl extends core.Object { | 3921 class _StreamIteratorImpl extends core.Object { |
| (...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4042 _StreamIteratorImpl._STATE_DONE = 1; | 4042 _StreamIteratorImpl._STATE_DONE = 1; |
| 4043 _StreamIteratorImpl._STATE_MOVING = 2; | 4043 _StreamIteratorImpl._STATE_MOVING = 2; |
| 4044 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; | 4044 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; |
| 4045 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; | 4045 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; |
| 4046 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; | 4046 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; |
| 4047 let __CastType20$ = dart.generic(function(T) { | 4047 let __CastType20$ = dart.generic(function(T) { |
| 4048 let __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart
.void, [T])); | 4048 let __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart
.void, [T])); |
| 4049 return __CastType20; | 4049 return __CastType20; |
| 4050 }); | 4050 }); |
| 4051 let __CastType20 = __CastType20$(); | 4051 let __CastType20 = __CastType20$(); |
| 4052 let __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart.d
ynamic, [dart.dynamic, dart.dynamic])); | 4052 let __CastType22 = dart.typedef('__CastType22', () => dart.functionType(core.O
bject, [dart.bottom, dart.bottom])); |
| 4053 let __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); | 4053 let __CastType25 = dart.typedef('__CastType25', () => dart.functionType(core.O
bject, [dart.bottom])); |
| 4054 function _runUserCode(userCode, onSuccess, onError) { | 4054 function _runUserCode(userCode, onSuccess, onError) { |
| 4055 try { | 4055 try { |
| 4056 dart.dcall(onSuccess, userCode()); | 4056 dart.dcall(onSuccess, userCode()); |
| 4057 } catch (e) { | 4057 } catch (e) { |
| 4058 let s = dart.stackTrace(e); | 4058 let s = dart.stackTrace(e); |
| 4059 let replacement = Zone.current.errorCallback(e, s); | 4059 let replacement = Zone.current.errorCallback(e, s); |
| 4060 if (replacement == null) { | 4060 if (replacement == null) { |
| 4061 dart.dcall(onError, e, s); | 4061 dart.dcall(onError, e, s); |
| 4062 } else { | 4062 } else { |
| 4063 let error = _nonNullError(replacement.error); | 4063 let error = _nonNullError(replacement.error); |
| 4064 let stackTrace = replacement.stackTrace; | 4064 let stackTrace = replacement.stackTrace; |
| 4065 dart.dcall(onError, error, stackTrace); | 4065 dart.dcall(onError, error, stackTrace); |
| 4066 } | 4066 } |
| 4067 } | 4067 } |
| 4068 | 4068 |
| 4069 } | 4069 } |
| 4070 dart.fn(_runUserCode, dart.dynamic, [dart.functionType(dart.dynamic, []), dart
.functionType(dart.dynamic, [dart.dynamic]), dart.functionType(dart.dynamic, [da
rt.dynamic, core.StackTrace])]); | 4070 dart.fn(_runUserCode, core.Object, [dart.functionType(core.Object, []), dart.f
unctionType(core.Object, [dart.bottom]), dart.functionType(core.Object, [dart.bo
ttom, core.StackTrace])]); |
| 4071 function _cancelAndError(subscription, future, error, stackTrace) { | 4071 function _cancelAndError(subscription, future, error, stackTrace) { |
| 4072 let cancelFuture = subscription.cancel(); | 4072 let cancelFuture = subscription.cancel(); |
| 4073 if (dart.is(cancelFuture, Future)) { | 4073 if (dart.is(cancelFuture, Future)) { |
| 4074 cancelFuture.whenComplete(dart.fn(() => future[_completeError](error, stac
kTrace), dart.void, [])); | 4074 cancelFuture.whenComplete(dart.fn(() => future[_completeError](error, stac
kTrace), dart.void, [])); |
| 4075 } else { | 4075 } else { |
| 4076 future[_completeError](error, stackTrace); | 4076 future[_completeError](error, stackTrace); |
| 4077 } | 4077 } |
| 4078 } | 4078 } |
| 4079 dart.fn(_cancelAndError, dart.void, [StreamSubscription, _Future, dart.dynamic
, core.StackTrace]); | 4079 dart.fn(_cancelAndError, dart.void, [StreamSubscription, _Future, core.Object,
core.StackTrace]); |
| 4080 function _cancelAndErrorWithReplacement(subscription, future, error, stackTrac
e) { | 4080 function _cancelAndErrorWithReplacement(subscription, future, error, stackTrac
e) { |
| 4081 let replacement = Zone.current.errorCallback(error, stackTrace); | 4081 let replacement = Zone.current.errorCallback(error, stackTrace); |
| 4082 if (replacement != null) { | 4082 if (replacement != null) { |
| 4083 error = _nonNullError(replacement.error); | 4083 error = _nonNullError(replacement.error); |
| 4084 stackTrace = replacement.stackTrace; | 4084 stackTrace = replacement.stackTrace; |
| 4085 } | 4085 } |
| 4086 _cancelAndError(subscription, future, error, stackTrace); | 4086 _cancelAndError(subscription, future, error, stackTrace); |
| 4087 } | 4087 } |
| 4088 dart.fn(_cancelAndErrorWithReplacement, dart.void, [StreamSubscription, _Futur
e, dart.dynamic, core.StackTrace]); | 4088 dart.fn(_cancelAndErrorWithReplacement, dart.void, [StreamSubscription, _Futur
e, core.Object, core.StackTrace]); |
| 4089 function _cancelAndErrorClosure(subscription, future) { | 4089 function _cancelAndErrorClosure(subscription, future) { |
| 4090 return dart.fn((error, stackTrace) => _cancelAndError(subscription, future,
error, stackTrace), dart.void, [dart.dynamic, core.StackTrace]); | 4090 return dart.fn((error, stackTrace) => _cancelAndError(subscription, future,
error, stackTrace), dart.void, [core.Object, core.StackTrace]); |
| 4091 } | 4091 } |
| 4092 dart.fn(_cancelAndErrorClosure, dart.dynamic, [StreamSubscription, _Future]); | 4092 dart.fn(_cancelAndErrorClosure, core.Object, [StreamSubscription, _Future]); |
| 4093 function _cancelAndValue(subscription, future, value) { | 4093 function _cancelAndValue(subscription, future, value) { |
| 4094 let cancelFuture = subscription.cancel(); | 4094 let cancelFuture = subscription.cancel(); |
| 4095 if (dart.is(cancelFuture, Future)) { | 4095 if (dart.is(cancelFuture, Future)) { |
| 4096 cancelFuture.whenComplete(dart.fn(() => future[_complete](value), dart.voi
d, [])); | 4096 cancelFuture.whenComplete(dart.fn(() => future[_complete](value), dart.voi
d, [])); |
| 4097 } else { | 4097 } else { |
| 4098 future[_complete](value); | 4098 future[_complete](value); |
| 4099 } | 4099 } |
| 4100 } | 4100 } |
| 4101 dart.fn(_cancelAndValue, dart.void, [StreamSubscription, _Future, dart.dynamic
]); | 4101 dart.fn(_cancelAndValue, dart.void, [StreamSubscription, _Future, core.Object]
); |
| 4102 let _handleData = Symbol('_handleData'); | 4102 let _handleData = Symbol('_handleData'); |
| 4103 let _handleError = Symbol('_handleError'); | 4103 let _handleError = Symbol('_handleError'); |
| 4104 let _handleDone = Symbol('_handleDone'); | 4104 let _handleDone = Symbol('_handleDone'); |
| 4105 let _ForwardingStream$ = dart.generic(function(S, T) { | 4105 let _ForwardingStream$ = dart.generic(function(S, T) { |
| 4106 class _ForwardingStream extends Stream$(T) { | 4106 class _ForwardingStream extends Stream$(T) { |
| 4107 _ForwardingStream(source) { | 4107 _ForwardingStream(source) { |
| 4108 this[_source] = source; | 4108 this[_source] = source; |
| 4109 super.Stream(); | 4109 super.Stream(); |
| 4110 } | 4110 } |
| 4111 get isBroadcast() { | 4111 get isBroadcast() { |
| (...skipping 26 matching lines...) Expand all Loading... |
| 4138 [_handleDone](sink) { | 4138 [_handleDone](sink) { |
| 4139 dart.as(sink, _EventSink$(T)); | 4139 dart.as(sink, _EventSink$(T)); |
| 4140 sink[_close](); | 4140 sink[_close](); |
| 4141 } | 4141 } |
| 4142 } | 4142 } |
| 4143 dart.setSignature(_ForwardingStream, { | 4143 dart.setSignature(_ForwardingStream, { |
| 4144 methods: () => ({ | 4144 methods: () => ({ |
| 4145 listen: dart.functionType(StreamSubscription$(T), [dart.functionType(dar
t.void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), an
celOnErro: core.bool}), | 4145 listen: dart.functionType(StreamSubscription$(T), [dart.functionType(dar
t.void, [T])], {nErro: core.Function, nDon: dart.functionType(dart.void, []), an
celOnErro: core.bool}), |
| 4146 [_createSubscription]: dart.functionType(StreamSubscription$(T), [dart.f
unctionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), co
re.bool]), | 4146 [_createSubscription]: dart.functionType(StreamSubscription$(T), [dart.f
unctionType(dart.void, [T]), core.Function, dart.functionType(dart.void, []), co
re.bool]), |
| 4147 [_handleData]: dart.functionType(dart.void, [S, _EventSink$(T)]), | 4147 [_handleData]: dart.functionType(dart.void, [S, _EventSink$(T)]), |
| 4148 [_handleError]: dart.functionType(dart.void, [dart.dynamic, core.StackTr
ace, _EventSink$(T)]), | 4148 [_handleError]: dart.functionType(dart.void, [core.Object, core.StackTra
ce, _EventSink$(T)]), |
| 4149 [_handleDone]: dart.functionType(dart.void, [_EventSink$(T)]) | 4149 [_handleDone]: dart.functionType(dart.void, [_EventSink$(T)]) |
| 4150 }) | 4150 }) |
| 4151 }); | 4151 }); |
| 4152 return _ForwardingStream; | 4152 return _ForwardingStream; |
| 4153 }); | 4153 }); |
| 4154 let _ForwardingStream = _ForwardingStream$(); | 4154 let _ForwardingStream = _ForwardingStream$(); |
| 4155 let _ForwardingStreamSubscription$ = dart.generic(function(S, T) { | 4155 let _ForwardingStreamSubscription$ = dart.generic(function(S, T) { |
| 4156 class _ForwardingStreamSubscription extends _BufferingStreamSubscription$(T)
{ | 4156 class _ForwardingStreamSubscription extends _BufferingStreamSubscription$(T)
{ |
| 4157 _ForwardingStreamSubscription(stream, onData, onError, onDone, cancelOnErr
or) { | 4157 _ForwardingStreamSubscription(stream, onData, onError, onDone, cancelOnErr
or) { |
| 4158 this[_stream] = stream; | 4158 this[_stream] = stream; |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4197 this[_stream][_handleError](error, stackTrace, this); | 4197 this[_stream][_handleError](error, stackTrace, this); |
| 4198 } | 4198 } |
| 4199 [_handleDone]() { | 4199 [_handleDone]() { |
| 4200 this[_stream][_handleDone](this); | 4200 this[_stream][_handleDone](this); |
| 4201 } | 4201 } |
| 4202 } | 4202 } |
| 4203 dart.setSignature(_ForwardingStreamSubscription, { | 4203 dart.setSignature(_ForwardingStreamSubscription, { |
| 4204 methods: () => ({ | 4204 methods: () => ({ |
| 4205 [_add]: dart.functionType(dart.void, [T]), | 4205 [_add]: dart.functionType(dart.void, [T]), |
| 4206 [_handleData]: dart.functionType(dart.void, [S]), | 4206 [_handleData]: dart.functionType(dart.void, [S]), |
| 4207 [_handleError]: dart.functionType(dart.void, [dart.dynamic, core.StackTr
ace]), | 4207 [_handleError]: dart.functionType(dart.void, [core.Object, core.StackTra
ce]), |
| 4208 [_handleDone]: dart.functionType(dart.void, []) | 4208 [_handleDone]: dart.functionType(dart.void, []) |
| 4209 }) | 4209 }) |
| 4210 }); | 4210 }); |
| 4211 return _ForwardingStreamSubscription; | 4211 return _ForwardingStreamSubscription; |
| 4212 }); | 4212 }); |
| 4213 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); | 4213 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); |
| 4214 let _Predicate$ = dart.generic(function(T) { | 4214 let _Predicate$ = dart.generic(function(T) { |
| 4215 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo
l, [T])); | 4215 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo
l, [T])); |
| 4216 return _Predicate; | 4216 return _Predicate; |
| 4217 }); | 4217 }); |
| 4218 let _Predicate = _Predicate$(); | 4218 let _Predicate = _Predicate$(); |
| 4219 function _addErrorWithReplacement(sink, error, stackTrace) { | 4219 function _addErrorWithReplacement(sink, error, stackTrace) { |
| 4220 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); | 4220 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); |
| 4221 if (replacement != null) { | 4221 if (replacement != null) { |
| 4222 error = _nonNullError(replacement.error); | 4222 error = _nonNullError(replacement.error); |
| 4223 stackTrace = replacement.stackTrace; | 4223 stackTrace = replacement.stackTrace; |
| 4224 } | 4224 } |
| 4225 sink[_addError](error, dart.as(stackTrace, core.StackTrace)); | 4225 sink[_addError](error, dart.as(stackTrace, core.StackTrace)); |
| 4226 } | 4226 } |
| 4227 dart.fn(_addErrorWithReplacement, dart.void, [_EventSink, dart.dynamic, dart.d
ynamic]); | 4227 dart.fn(_addErrorWithReplacement, dart.void, [_EventSink, core.Object, core.Ob
ject]); |
| 4228 let _test = Symbol('_test'); | 4228 let _test = Symbol('_test'); |
| 4229 let _WhereStream$ = dart.generic(function(T) { | 4229 let _WhereStream$ = dart.generic(function(T) { |
| 4230 class _WhereStream extends _ForwardingStream$(T, T) { | 4230 class _WhereStream extends _ForwardingStream$(T, T) { |
| 4231 _WhereStream(source, test) { | 4231 _WhereStream(source, test) { |
| 4232 this[_test] = test; | 4232 this[_test] = test; |
| 4233 super._ForwardingStream(source); | 4233 super._ForwardingStream(source); |
| 4234 } | 4234 } |
| 4235 [_handleData](inputEvent, sink) { | 4235 [_handleData](inputEvent, sink) { |
| 4236 dart.as(inputEvent, T); | 4236 dart.as(inputEvent, T); |
| 4237 dart.as(sink, _EventSink$(T)); | 4237 dart.as(sink, _EventSink$(T)); |
| (...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4308 } | 4308 } |
| 4309 | 4309 |
| 4310 } | 4310 } |
| 4311 } | 4311 } |
| 4312 dart.setSignature(_ExpandStream, { | 4312 dart.setSignature(_ExpandStream, { |
| 4313 methods: () => ({[_handleData]: dart.functionType(dart.void, [S, _EventSin
k$(T)])}) | 4313 methods: () => ({[_handleData]: dart.functionType(dart.void, [S, _EventSin
k$(T)])}) |
| 4314 }); | 4314 }); |
| 4315 return _ExpandStream; | 4315 return _ExpandStream; |
| 4316 }); | 4316 }); |
| 4317 let _ExpandStream = _ExpandStream$(); | 4317 let _ExpandStream = _ExpandStream$(); |
| 4318 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool,
[dart.dynamic])); | 4318 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool,
[dart.bottom])); |
| 4319 let _HandleErrorStream$ = dart.generic(function(T) { | 4319 let _HandleErrorStream$ = dart.generic(function(T) { |
| 4320 class _HandleErrorStream extends _ForwardingStream$(T, T) { | 4320 class _HandleErrorStream extends _ForwardingStream$(T, T) { |
| 4321 _HandleErrorStream(source, onError, test) { | 4321 _HandleErrorStream(source, onError, test) { |
| 4322 this[_transform] = onError; | 4322 this[_transform] = onError; |
| 4323 this[_test] = test; | 4323 this[_test] = test; |
| 4324 super._ForwardingStream(source); | 4324 super._ForwardingStream(source); |
| 4325 } | 4325 } |
| 4326 [_handleError](error, stackTrace, sink) { | 4326 [_handleError](error, stackTrace, sink) { |
| 4327 dart.as(sink, _EventSink$(T)); | 4327 dart.as(sink, _EventSink$(T)); |
| 4328 let matches = true; | 4328 let matches = true; |
| (...skipping 218 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4547 this[_sink][_addError](error, stackTrace); | 4547 this[_sink][_addError](error, stackTrace); |
| 4548 } | 4548 } |
| 4549 close() { | 4549 close() { |
| 4550 this[_sink][_close](); | 4550 this[_sink][_close](); |
| 4551 } | 4551 } |
| 4552 } | 4552 } |
| 4553 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)]; | 4553 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)]; |
| 4554 dart.setSignature(_EventSinkWrapper, { | 4554 dart.setSignature(_EventSinkWrapper, { |
| 4555 methods: () => ({ | 4555 methods: () => ({ |
| 4556 add: dart.functionType(dart.void, [T]), | 4556 add: dart.functionType(dart.void, [T]), |
| 4557 addError: dart.functionType(dart.void, [dart.dynamic], [core.StackTrace]
), | 4557 addError: dart.functionType(dart.void, [core.Object], [core.StackTrace])
, |
| 4558 close: dart.functionType(dart.void, []) | 4558 close: dart.functionType(dart.void, []) |
| 4559 }) | 4559 }) |
| 4560 }); | 4560 }); |
| 4561 return _EventSinkWrapper; | 4561 return _EventSinkWrapper; |
| 4562 }); | 4562 }); |
| 4563 let _EventSinkWrapper = _EventSinkWrapper$(); | 4563 let _EventSinkWrapper = _EventSinkWrapper$(); |
| 4564 let _transformerSink = Symbol('_transformerSink'); | 4564 let _transformerSink = Symbol('_transformerSink'); |
| 4565 let _isSubscribed = Symbol('_isSubscribed'); | 4565 let _isSubscribed = Symbol('_isSubscribed'); |
| 4566 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { | 4566 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { |
| 4567 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio
n$(T) { | 4567 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio
n$(T) { |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4644 let s = dart.stackTrace(e); | 4644 let s = dart.stackTrace(e); |
| 4645 this[_addError](e, s); | 4645 this[_addError](e, s); |
| 4646 } | 4646 } |
| 4647 | 4647 |
| 4648 } | 4648 } |
| 4649 } | 4649 } |
| 4650 dart.setSignature(_SinkTransformerStreamSubscription, { | 4650 dart.setSignature(_SinkTransformerStreamSubscription, { |
| 4651 methods: () => ({ | 4651 methods: () => ({ |
| 4652 [_add]: dart.functionType(dart.void, [T]), | 4652 [_add]: dart.functionType(dart.void, [T]), |
| 4653 [_handleData]: dart.functionType(dart.void, [S]), | 4653 [_handleData]: dart.functionType(dart.void, [S]), |
| 4654 [_handleError]: dart.functionType(dart.void, [dart.dynamic], [dart.dynam
ic]), | 4654 [_handleError]: dart.functionType(dart.void, [core.Object], [core.Object
]), |
| 4655 [_handleDone]: dart.functionType(dart.void, []) | 4655 [_handleDone]: dart.functionType(dart.void, []) |
| 4656 }) | 4656 }) |
| 4657 }); | 4657 }); |
| 4658 return _SinkTransformerStreamSubscription; | 4658 return _SinkTransformerStreamSubscription; |
| 4659 }); | 4659 }); |
| 4660 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$()
; | 4660 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$()
; |
| 4661 let _SinkMapper$ = dart.generic(function(S, T) { | 4661 let _SinkMapper$ = dart.generic(function(S, T) { |
| 4662 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS
ink$(S), [EventSink$(T)])); | 4662 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS
ink$(S), [EventSink$(T)])); |
| 4663 return _SinkMapper; | 4663 return _SinkMapper; |
| 4664 }); | 4664 }); |
| (...skipping 26 matching lines...) Expand all Loading... |
| 4691 this[_sinkMapper] = sinkMapper; | 4691 this[_sinkMapper] = sinkMapper; |
| 4692 super.Stream(); | 4692 super.Stream(); |
| 4693 } | 4693 } |
| 4694 listen(onData, opts) { | 4694 listen(onData, opts) { |
| 4695 dart.as(onData, dart.functionType(dart.void, [T])); | 4695 dart.as(onData, dart.functionType(dart.void, [T])); |
| 4696 let onError = opts && 'onError' in opts ? opts.onError : null; | 4696 let onError = opts && 'onError' in opts ? opts.onError : null; |
| 4697 let onDone = opts && 'onDone' in opts ? opts.onDone : null; | 4697 let onDone = opts && 'onDone' in opts ? opts.onDone : null; |
| 4698 dart.as(onDone, dart.functionType(dart.void, [])); | 4698 dart.as(onDone, dart.functionType(dart.void, [])); |
| 4699 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 4699 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
| 4700 cancelOnError = core.identical(true, cancelOnError); | 4700 cancelOnError = core.identical(true, cancelOnError); |
| 4701 let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic
, T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, o
nDone, cancelOnError); | 4701 let subscription = new (_SinkTransformerStreamSubscription$(core.Object,
T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, on
Done, cancelOnError); |
| 4702 return subscription; | 4702 return subscription; |
| 4703 } | 4703 } |
| 4704 } | 4704 } |
| 4705 dart.setSignature(_BoundSinkStream, { | 4705 dart.setSignature(_BoundSinkStream, { |
| 4706 methods: () => ({listen: dart.functionType(StreamSubscription$(T), [dart.f
unctionType(dart.void, [T])], {nErro: core.Function, nDon: dart.functionType(dar
t.void, []), ancelOnErro: core.bool})}) | 4706 methods: () => ({listen: dart.functionType(StreamSubscription$(T), [dart.f
unctionType(dart.void, [T])], {nErro: core.Function, nDon: dart.functionType(dar
t.void, []), ancelOnErro: core.bool})}) |
| 4707 }); | 4707 }); |
| 4708 return _BoundSinkStream; | 4708 return _BoundSinkStream; |
| 4709 }); | 4709 }); |
| 4710 let _BoundSinkStream = _BoundSinkStream$(); | 4710 let _BoundSinkStream = _BoundSinkStream$(); |
| 4711 let _TransformDataHandler$ = dart.generic(function(S, T) { | 4711 let _TransformDataHandler$ = dart.generic(function(S, T) { |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4763 let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null; | 4763 let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null; |
| 4764 super._StreamSinkTransformer(dart.as(dart.fn(outputSink => { | 4764 super._StreamSinkTransformer(dart.as(dart.fn(outputSink => { |
| 4765 dart.as(outputSink, EventSink$(T)); | 4765 dart.as(outputSink, EventSink$(T)); |
| 4766 if (handleData == null) | 4766 if (handleData == null) |
| 4767 handleData = dart.as(_StreamHandlerTransformer$()._defaultHandleData
, __CastType27); | 4767 handleData = dart.as(_StreamHandlerTransformer$()._defaultHandleData
, __CastType27); |
| 4768 if (handleError == null) | 4768 if (handleError == null) |
| 4769 handleError = dart.as(_StreamHandlerTransformer$()._defaultHandleErr
or, __CastType30); | 4769 handleError = dart.as(_StreamHandlerTransformer$()._defaultHandleErr
or, __CastType30); |
| 4770 if (handleDone == null) | 4770 if (handleDone == null) |
| 4771 handleDone = _StreamHandlerTransformer$()._defaultHandleDone; | 4771 handleDone = _StreamHandlerTransformer$()._defaultHandleDone; |
| 4772 return new (_HandlerEventSink$(S, T))(handleData, handleError, handleD
one, outputSink); | 4772 return new (_HandlerEventSink$(S, T))(handleData, handleError, handleD
one, outputSink); |
| 4773 }, dart.dynamic, [EventSink$(T)]), _SinkMapper$(S, T))); | 4773 }, core.Object, [EventSink$(T)]), _SinkMapper$(S, T))); |
| 4774 } | 4774 } |
| 4775 bind(stream) { | 4775 bind(stream) { |
| 4776 dart.as(stream, Stream$(S)); | 4776 dart.as(stream, Stream$(S)); |
| 4777 return super.bind(stream); | 4777 return super.bind(stream); |
| 4778 } | 4778 } |
| 4779 static _defaultHandleData(data, sink) { | 4779 static _defaultHandleData(data, sink) { |
| 4780 sink.add(data); | 4780 sink.add(data); |
| 4781 } | 4781 } |
| 4782 static _defaultHandleError(error, stackTrace, sink) { | 4782 static _defaultHandleError(error, stackTrace, sink) { |
| 4783 sink.addError(error); | 4783 sink.addError(error); |
| 4784 } | 4784 } |
| 4785 static _defaultHandleDone(sink) { | 4785 static _defaultHandleDone(sink) { |
| 4786 sink.close(); | 4786 sink.close(); |
| 4787 } | 4787 } |
| 4788 } | 4788 } |
| 4789 dart.setSignature(_StreamHandlerTransformer, { | 4789 dart.setSignature(_StreamHandlerTransformer, { |
| 4790 methods: () => ({bind: dart.functionType(Stream$(T), [Stream$(S)])}), | 4790 methods: () => ({bind: dart.functionType(Stream$(T), [Stream$(S)])}), |
| 4791 statics: () => ({ | 4791 statics: () => ({ |
| 4792 _defaultHandleData: dart.functionType(dart.void, [dart.dynamic, EventSin
k]), | 4792 _defaultHandleData: dart.functionType(dart.void, [core.Object, EventSink
]), |
| 4793 _defaultHandleError: dart.functionType(dart.void, [dart.dynamic, core.St
ackTrace, EventSink]), | 4793 _defaultHandleError: dart.functionType(dart.void, [core.Object, core.Sta
ckTrace, EventSink]), |
| 4794 _defaultHandleDone: dart.functionType(dart.void, [EventSink]) | 4794 _defaultHandleDone: dart.functionType(dart.void, [EventSink]) |
| 4795 }), | 4795 }), |
| 4796 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone'] | 4796 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone'] |
| 4797 }); | 4797 }); |
| 4798 return _StreamHandlerTransformer; | 4798 return _StreamHandlerTransformer; |
| 4799 }); | 4799 }); |
| 4800 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); | 4800 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); |
| 4801 let _SubscriptionTransformer$ = dart.generic(function(S, T) { | 4801 let _SubscriptionTransformer$ = dart.generic(function(S, T) { |
| 4802 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () =
> dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool])); | 4802 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () =
> dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool])); |
| 4803 return _SubscriptionTransformer; | 4803 return _SubscriptionTransformer; |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4890 dart.defineNamedConstructor(Timer, 'periodic'); | 4890 dart.defineNamedConstructor(Timer, 'periodic'); |
| 4891 dart.setSignature(Timer, { | 4891 dart.setSignature(Timer, { |
| 4892 statics: () => ({ | 4892 statics: () => ({ |
| 4893 run: dart.functionType(dart.void, [dart.functionType(dart.void, [])]), | 4893 run: dart.functionType(dart.void, [dart.functionType(dart.void, [])]), |
| 4894 _createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(d
art.void, [])]), | 4894 _createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(d
art.void, [])]), |
| 4895 _createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functi
onType(dart.void, [Timer])]) | 4895 _createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functi
onType(dart.void, [Timer])]) |
| 4896 }), | 4896 }), |
| 4897 names: ['run', '_createTimer', '_createPeriodicTimer'] | 4897 names: ['run', '_createTimer', '_createPeriodicTimer'] |
| 4898 }); | 4898 }); |
| 4899 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v
oid, [Timer])); | 4899 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v
oid, [Timer])); |
| 4900 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart.d
ynamic, [])); | 4900 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(core.O
bject, [])); |
| 4901 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT
ype(dart.dynamic, [dart.dynamic])); | 4901 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT
ype(core.Object, [dart.bottom])); |
| 4902 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functio
nType(dart.dynamic, [dart.dynamic, dart.dynamic])); | 4902 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functio
nType(core.Object, [dart.bottom, dart.bottom])); |
| 4903 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', ()
=> dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, cor
e.StackTrace])); | 4903 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', ()
=> dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.
StackTrace])); |
| 4904 let RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dynam
ic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); | 4904 let RunHandler = dart.typedef('RunHandler', () => dart.functionType(core.Objec
t, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [])])); |
| 4905 let RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionType(
dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.d
ynamic]), dart.dynamic])); | 4905 let RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionType(
core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [dart.bot
tom]), dart.bottom])); |
| 4906 let RunBinaryHandler = dart.typedef('RunBinaryHandler', () => dart.functionTyp
e(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart
.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic])); | 4906 let RunBinaryHandler = dart.typedef('RunBinaryHandler', () => dart.functionTyp
e(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [dart.b
ottom, dart.bottom]), dart.bottom, dart.bottom])); |
| 4907 let RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () => da
rt.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.
dynamic, [])])); | 4907 let RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () => da
rt.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(core.
Object, [])])); |
| 4908 let RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandler'
, () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [dart.dynamic])])); | 4908 let RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandler'
, () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(core.Object, [dart.bottom])])); |
| 4909 let RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHandle
r', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.
functionType(dart.dynamic, [dart.dynamic, dart.dynamic])])); | 4909 let RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHandle
r', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.
functionType(core.Object, [dart.bottom, dart.bottom])])); |
| 4910 let ErrorCallbackHandler = dart.typedef('ErrorCallbackHandler', () => dart.fun
ctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]))
; | 4910 let ErrorCallbackHandler = dart.typedef('ErrorCallbackHandler', () => dart.fun
ctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]))
; |
| 4911 let ScheduleMicrotaskHandler = dart.typedef('ScheduleMicrotaskHandler', () =>
dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.d
ynamic, [])])); | 4911 let ScheduleMicrotaskHandler = dart.typedef('ScheduleMicrotaskHandler', () =>
dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(core.O
bject, [])])); |
| 4912 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])])); | 4912 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])])); |
| 4913 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', ()
=> dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func
tionType(dart.void, [Timer])])); | 4913 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', ()
=> dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func
tionType(dart.void, [Timer])])); |
| 4914 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v
oid, [Zone, ZoneDelegate, Zone, core.String])); | 4914 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v
oid, [Zone, ZoneDelegate, Zone, core.String])); |
| 4915 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z
one, ZoneDelegate, Zone, ZoneSpecification, core.Map])); | 4915 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z
one, ZoneDelegate, Zone, ZoneSpecification, core.Map])); |
| 4916 class _ZoneFunction extends core.Object { | 4916 class _ZoneFunction extends core.Object { |
| 4917 _ZoneFunction(zone, func) { | 4917 _ZoneFunction(zone, func) { |
| 4918 this.zone = zone; | 4918 this.zone = zone; |
| 4919 this.function = func; | 4919 this.function = func; |
| 4920 } | 4920 } |
| 4921 } | 4921 } |
| (...skipping 266 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5188 } | 5188 } |
| 5189 createPeriodicTimer(duration, f) { | 5189 createPeriodicTimer(duration, f) { |
| 5190 return Timer._createPeriodicTimer(duration, f); | 5190 return Timer._createPeriodicTimer(duration, f); |
| 5191 } | 5191 } |
| 5192 print(line) { | 5192 print(line) { |
| 5193 _internal.printToConsole(line); | 5193 _internal.printToConsole(line); |
| 5194 } | 5194 } |
| 5195 } | 5195 } |
| 5196 dart.setSignature(_RootZone, { | 5196 dart.setSignature(_RootZone, { |
| 5197 methods: () => ({ | 5197 methods: () => ({ |
| 5198 runGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.dynami
c, [])]), | 5198 runGuarded: dart.functionType(core.Object, [dart.functionType(core.Object,
[])]), |
| 5199 runUnaryGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.d
ynamic, [dart.dynamic]), dart.dynamic]), | 5199 runUnaryGuarded: dart.functionType(core.Object, [dart.functionType(core.Ob
ject, [dart.bottom]), core.Object]), |
| 5200 runBinaryGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.
dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), | 5200 runBinaryGuarded: dart.functionType(core.Object, [dart.functionType(core.O
bject, [dart.bottom, dart.bottom]), core.Object, core.Object]), |
| 5201 bindCallback: dart.functionType(ZoneCallback, [dart.functionType(dart.dyna
mic, [])], {unGuarde: core.bool}), | 5201 bindCallback: dart.functionType(ZoneCallback, [dart.functionType(core.Obje
ct, [])], {unGuarde: core.bool}), |
| 5202 bindUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.functionType
(dart.dynamic, [dart.dynamic])], {unGuarde: core.bool}), | 5202 bindUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.functionType
(core.Object, [dart.bottom])], {unGuarde: core.bool}), |
| 5203 bindBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functionTy
pe(dart.dynamic, [dart.dynamic, dart.dynamic])], {unGuarde: core.bool}), | 5203 bindBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functionTy
pe(core.Object, [dart.bottom, dart.bottom])], {unGuarde: core.bool}), |
| 5204 get: dart.functionType(dart.dynamic, [core.Object]), | 5204 get: dart.functionType(core.Object, [core.Object]), |
| 5205 handleUncaughtError: dart.functionType(dart.dynamic, [dart.dynamic, core.S
tackTrace]), | 5205 handleUncaughtError: dart.functionType(core.Object, [core.Object, core.Sta
ckTrace]), |
| 5206 fork: dart.functionType(Zone, [], {pecificatio: ZoneSpecification, oneValu
e: core.Map}), | 5206 fork: dart.functionType(Zone, [], {pecificatio: ZoneSpecification, oneValu
e: core.Map}), |
| 5207 run: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic, [])]
), | 5207 run: dart.functionType(core.Object, [dart.functionType(core.Object, [])]), |
| 5208 runUnary: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic,
[dart.dynamic]), dart.dynamic]), | 5208 runUnary: dart.functionType(core.Object, [dart.functionType(core.Object, [
dart.bottom]), core.Object]), |
| 5209 runBinary: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic
, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), | 5209 runBinary: dart.functionType(core.Object, [dart.functionType(core.Object,
[dart.bottom, dart.bottom]), core.Object, core.Object]), |
| 5210 registerCallback: dart.functionType(ZoneCallback, [dart.functionType(dart.
dynamic, [])]), | 5210 registerCallback: dart.functionType(ZoneCallback, [dart.functionType(core.
Object, [])]), |
| 5211 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.function
Type(dart.dynamic, [dart.dynamic])]), | 5211 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.function
Type(core.Object, [dart.bottom])]), |
| 5212 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functi
onType(dart.dynamic, [dart.dynamic, dart.dynamic])]), | 5212 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functi
onType(core.Object, [dart.bottom, dart.bottom])]), |
| 5213 errorCallback: dart.functionType(AsyncError, [core.Object, core.StackTrace
]), | 5213 errorCallback: dart.functionType(AsyncError, [core.Object, core.StackTrace
]), |
| 5214 scheduleMicrotask: dart.functionType(dart.void, [dart.functionType(dart.vo
id, [])]), | 5214 scheduleMicrotask: dart.functionType(dart.void, [dart.functionType(dart.vo
id, [])]), |
| 5215 createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(da
rt.void, [])]), | 5215 createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(da
rt.void, [])]), |
| 5216 createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functio
nType(dart.void, [Timer])]), | 5216 createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functio
nType(dart.void, [Timer])]), |
| 5217 print: dart.functionType(dart.void, [core.String]) | 5217 print: dart.functionType(dart.void, [core.String]) |
| 5218 }) | 5218 }) |
| 5219 }); | 5219 }); |
| 5220 let _ROOT_ZONE = dart.const(new _RootZone()); | 5220 let _ROOT_ZONE = dart.const(new _RootZone()); |
| 5221 Zone.ROOT = _ROOT_ZONE; | 5221 Zone.ROOT = _ROOT_ZONE; |
| 5222 Zone._current = _ROOT_ZONE; | 5222 Zone._current = _ROOT_ZONE; |
| (...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5295 } | 5295 } |
| 5296 fork(zone, specification, zoneValues) { | 5296 fork(zone, specification, zoneValues) { |
| 5297 let implementation = this[_delegationTarget][_fork]; | 5297 let implementation = this[_delegationTarget][_fork]; |
| 5298 let implZone = implementation.zone; | 5298 let implZone = implementation.zone; |
| 5299 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, specification, zoneValues), Zone); | 5299 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, specification, zoneValues), Zone); |
| 5300 } | 5300 } |
| 5301 } | 5301 } |
| 5302 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; | 5302 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; |
| 5303 dart.setSignature(_ZoneDelegate, { | 5303 dart.setSignature(_ZoneDelegate, { |
| 5304 methods: () => ({ | 5304 methods: () => ({ |
| 5305 handleUncaughtError: dart.functionType(dart.dynamic, [Zone, dart.dynamic,
core.StackTrace]), | 5305 handleUncaughtError: dart.functionType(core.Object, [Zone, core.Object, co
re.StackTrace]), |
| 5306 run: dart.functionType(dart.dynamic, [Zone, dart.functionType(dart.dynamic
, [])]), | 5306 run: dart.functionType(core.Object, [Zone, dart.functionType(core.Object,
[])]), |
| 5307 runUnary: dart.functionType(dart.dynamic, [Zone, dart.functionType(dart.dy
namic, [dart.dynamic]), dart.dynamic]), | 5307 runUnary: dart.functionType(core.Object, [Zone, dart.functionType(core.Obj
ect, [dart.bottom]), core.Object]), |
| 5308 runBinary: dart.functionType(dart.dynamic, [Zone, dart.functionType(dart.d
ynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), | 5308 runBinary: dart.functionType(core.Object, [Zone, dart.functionType(core.Ob
ject, [dart.bottom, dart.bottom]), core.Object, core.Object]), |
| 5309 registerCallback: dart.functionType(ZoneCallback, [Zone, dart.functionType
(dart.dynamic, [])]), | 5309 registerCallback: dart.functionType(ZoneCallback, [Zone, dart.functionType
(core.Object, [])]), |
| 5310 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [Zone, dart.fu
nctionType(dart.dynamic, [dart.dynamic])]), | 5310 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [Zone, dart.fu
nctionType(core.Object, [dart.bottom])]), |
| 5311 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, dart.
functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]), | 5311 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, dart.
functionType(core.Object, [dart.bottom, dart.bottom])]), |
| 5312 errorCallback: dart.functionType(AsyncError, [Zone, core.Object, core.Stac
kTrace]), | 5312 errorCallback: dart.functionType(AsyncError, [Zone, core.Object, core.Stac
kTrace]), |
| 5313 scheduleMicrotask: dart.functionType(dart.void, [Zone, dart.functionType(d
art.dynamic, [])]), | 5313 scheduleMicrotask: dart.functionType(dart.void, [Zone, dart.functionType(c
ore.Object, [])]), |
| 5314 createTimer: dart.functionType(Timer, [Zone, core.Duration, dart.functionT
ype(dart.void, [])]), | 5314 createTimer: dart.functionType(Timer, [Zone, core.Duration, dart.functionT
ype(dart.void, [])]), |
| 5315 createPeriodicTimer: dart.functionType(Timer, [Zone, core.Duration, dart.f
unctionType(dart.void, [Timer])]), | 5315 createPeriodicTimer: dart.functionType(Timer, [Zone, core.Duration, dart.f
unctionType(dart.void, [Timer])]), |
| 5316 print: dart.functionType(dart.void, [Zone, core.String]), | 5316 print: dart.functionType(dart.void, [Zone, core.String]), |
| 5317 fork: dart.functionType(Zone, [Zone, ZoneSpecification, core.Map]) | 5317 fork: dart.functionType(Zone, [Zone, ZoneSpecification, core.Map]) |
| 5318 }) | 5318 }) |
| 5319 }); | 5319 }); |
| 5320 let _delegateCache = Symbol('_delegateCache'); | 5320 let _delegateCache = Symbol('_delegateCache'); |
| 5321 class _CustomZone extends _Zone { | 5321 class _CustomZone extends _Zone { |
| 5322 get [_delegate]() { | 5322 get [_delegate]() { |
| 5323 if (this[_delegateCache] != null) | 5323 if (this[_delegateCache] != null) |
| (...skipping 183 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5507 } | 5507 } |
| 5508 print(line) { | 5508 print(line) { |
| 5509 let implementation = this[_print]; | 5509 let implementation = this[_print]; |
| 5510 dart.assert(implementation != null); | 5510 dart.assert(implementation != null); |
| 5511 let parentDelegate = _parentDelegate(implementation.zone); | 5511 let parentDelegate = _parentDelegate(implementation.zone); |
| 5512 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, line); | 5512 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, line); |
| 5513 } | 5513 } |
| 5514 } | 5514 } |
| 5515 dart.setSignature(_CustomZone, { | 5515 dart.setSignature(_CustomZone, { |
| 5516 methods: () => ({ | 5516 methods: () => ({ |
| 5517 runGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.dynami
c, [])]), | 5517 runGuarded: dart.functionType(core.Object, [dart.functionType(core.Object,
[])]), |
| 5518 runUnaryGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.d
ynamic, [dart.dynamic]), dart.dynamic]), | 5518 runUnaryGuarded: dart.functionType(core.Object, [dart.functionType(core.Ob
ject, [dart.bottom]), core.Object]), |
| 5519 runBinaryGuarded: dart.functionType(dart.dynamic, [dart.functionType(dart.
dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), | 5519 runBinaryGuarded: dart.functionType(core.Object, [dart.functionType(core.O
bject, [dart.bottom, dart.bottom]), core.Object, core.Object]), |
| 5520 bindCallback: dart.functionType(ZoneCallback, [dart.functionType(dart.dyna
mic, [])], {unGuarde: core.bool}), | 5520 bindCallback: dart.functionType(ZoneCallback, [dart.functionType(core.Obje
ct, [])], {unGuarde: core.bool}), |
| 5521 bindUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.functionType
(dart.dynamic, [dart.dynamic])], {unGuarde: core.bool}), | 5521 bindUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.functionType
(core.Object, [dart.bottom])], {unGuarde: core.bool}), |
| 5522 bindBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functionTy
pe(dart.dynamic, [dart.dynamic, dart.dynamic])], {unGuarde: core.bool}), | 5522 bindBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functionTy
pe(core.Object, [dart.bottom, dart.bottom])], {unGuarde: core.bool}), |
| 5523 get: dart.functionType(dart.dynamic, [core.Object]), | 5523 get: dart.functionType(core.Object, [core.Object]), |
| 5524 handleUncaughtError: dart.functionType(dart.dynamic, [dart.dynamic, core.S
tackTrace]), | 5524 handleUncaughtError: dart.functionType(core.Object, [core.Object, core.Sta
ckTrace]), |
| 5525 fork: dart.functionType(Zone, [], {pecificatio: ZoneSpecification, oneValu
e: core.Map}), | 5525 fork: dart.functionType(Zone, [], {pecificatio: ZoneSpecification, oneValu
e: core.Map}), |
| 5526 run: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic, [])]
), | 5526 run: dart.functionType(core.Object, [dart.functionType(core.Object, [])]), |
| 5527 runUnary: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic,
[dart.dynamic]), dart.dynamic]), | 5527 runUnary: dart.functionType(core.Object, [dart.functionType(core.Object, [
dart.bottom]), core.Object]), |
| 5528 runBinary: dart.functionType(dart.dynamic, [dart.functionType(dart.dynamic
, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), | 5528 runBinary: dart.functionType(core.Object, [dart.functionType(core.Object,
[dart.bottom, dart.bottom]), core.Object, core.Object]), |
| 5529 registerCallback: dart.functionType(ZoneCallback, [dart.functionType(dart.
dynamic, [])]), | 5529 registerCallback: dart.functionType(ZoneCallback, [dart.functionType(core.
Object, [])]), |
| 5530 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.function
Type(dart.dynamic, [dart.dynamic])]), | 5530 registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [dart.function
Type(core.Object, [dart.bottom])]), |
| 5531 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functi
onType(dart.dynamic, [dart.dynamic, dart.dynamic])]), | 5531 registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [dart.functi
onType(core.Object, [dart.bottom, dart.bottom])]), |
| 5532 errorCallback: dart.functionType(AsyncError, [core.Object, core.StackTrace
]), | 5532 errorCallback: dart.functionType(AsyncError, [core.Object, core.StackTrace
]), |
| 5533 scheduleMicrotask: dart.functionType(dart.void, [dart.functionType(dart.vo
id, [])]), | 5533 scheduleMicrotask: dart.functionType(dart.void, [dart.functionType(dart.vo
id, [])]), |
| 5534 createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(da
rt.void, [])]), | 5534 createTimer: dart.functionType(Timer, [core.Duration, dart.functionType(da
rt.void, [])]), |
| 5535 createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functio
nType(dart.void, [Timer])]), | 5535 createPeriodicTimer: dart.functionType(Timer, [core.Duration, dart.functio
nType(dart.void, [Timer])]), |
| 5536 print: dart.functionType(dart.void, [core.String]) | 5536 print: dart.functionType(dart.void, [core.String]) |
| 5537 }) | 5537 }) |
| 5538 }); | 5538 }); |
| 5539 function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) { | 5539 function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) { |
| 5540 _schedulePriorityAsyncCallback(dart.fn(() => { | 5540 _schedulePriorityAsyncCallback(dart.fn(() => { |
| 5541 throw new _UncaughtAsyncError(error, stackTrace); | 5541 throw new _UncaughtAsyncError(error, stackTrace); |
| 5542 })); | 5542 })); |
| 5543 } | 5543 } |
| 5544 dart.fn(_rootHandleUncaughtError, dart.void, [Zone, ZoneDelegate, Zone, dart.d
ynamic, core.StackTrace]); | 5544 dart.fn(_rootHandleUncaughtError, dart.void, [Zone, ZoneDelegate, Zone, core.O
bject, core.StackTrace]); |
| 5545 function _rootRun(self, parent, zone, f) { | 5545 function _rootRun(self, parent, zone, f) { |
| 5546 if (dart.equals(Zone._current, zone)) | 5546 if (dart.equals(Zone._current, zone)) |
| 5547 return f(); | 5547 return f(); |
| 5548 let old = Zone._enter(zone); | 5548 let old = Zone._enter(zone); |
| 5549 try { | 5549 try { |
| 5550 return f(); | 5550 return f(); |
| 5551 } finally { | 5551 } finally { |
| 5552 Zone._leave(old); | 5552 Zone._leave(old); |
| 5553 } | 5553 } |
| 5554 } | 5554 } |
| 5555 dart.fn(_rootRun, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(d
art.dynamic, [])]); | 5555 dart.fn(_rootRun, core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(co
re.Object, [])]); |
| 5556 function _rootRunUnary(self, parent, zone, f, arg) { | 5556 function _rootRunUnary(self, parent, zone, f, arg) { |
| 5557 if (dart.equals(Zone._current, zone)) | 5557 if (dart.equals(Zone._current, zone)) |
| 5558 return dart.dcall(f, arg); | 5558 return dart.dcall(f, arg); |
| 5559 let old = Zone._enter(zone); | 5559 let old = Zone._enter(zone); |
| 5560 try { | 5560 try { |
| 5561 return dart.dcall(f, arg); | 5561 return dart.dcall(f, arg); |
| 5562 } finally { | 5562 } finally { |
| 5563 Zone._leave(old); | 5563 Zone._leave(old); |
| 5564 } | 5564 } |
| 5565 } | 5565 } |
| 5566 dart.fn(_rootRunUnary, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionT
ype(dart.dynamic, [dart.dynamic]), dart.dynamic]); | 5566 dart.fn(_rootRunUnary, core.Object, [Zone, ZoneDelegate, Zone, dart.functionTy
pe(core.Object, [dart.bottom]), core.Object]); |
| 5567 function _rootRunBinary(self, parent, zone, f, arg1, arg2) { | 5567 function _rootRunBinary(self, parent, zone, f, arg1, arg2) { |
| 5568 if (dart.equals(Zone._current, zone)) | 5568 if (dart.equals(Zone._current, zone)) |
| 5569 return dart.dcall(f, arg1, arg2); | 5569 return dart.dcall(f, arg1, arg2); |
| 5570 let old = Zone._enter(zone); | 5570 let old = Zone._enter(zone); |
| 5571 try { | 5571 try { |
| 5572 return dart.dcall(f, arg1, arg2); | 5572 return dart.dcall(f, arg1, arg2); |
| 5573 } finally { | 5573 } finally { |
| 5574 Zone._leave(old); | 5574 Zone._leave(old); |
| 5575 } | 5575 } |
| 5576 } | 5576 } |
| 5577 dart.fn(_rootRunBinary, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.function
Type(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]); | 5577 dart.fn(_rootRunBinary, core.Object, [Zone, ZoneDelegate, Zone, dart.functionT
ype(core.Object, [dart.bottom, dart.bottom]), core.Object, core.Object]); |
| 5578 function _rootRegisterCallback(self, parent, zone, f) { | 5578 function _rootRegisterCallback(self, parent, zone, f) { |
| 5579 return f; | 5579 return f; |
| 5580 } | 5580 } |
| 5581 dart.fn(_rootRegisterCallback, ZoneCallback, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [])]); | 5581 dart.fn(_rootRegisterCallback, ZoneCallback, [Zone, ZoneDelegate, Zone, dart.f
unctionType(core.Object, [])]); |
| 5582 function _rootRegisterUnaryCallback(self, parent, zone, f) { | 5582 function _rootRegisterUnaryCallback(self, parent, zone, f) { |
| 5583 return f; | 5583 return f; |
| 5584 } | 5584 } |
| 5585 dart.fn(_rootRegisterUnaryCallback, ZoneUnaryCallback, [Zone, ZoneDelegate, Zo
ne, dart.functionType(dart.dynamic, [dart.dynamic])]); | 5585 dart.fn(_rootRegisterUnaryCallback, ZoneUnaryCallback, [Zone, ZoneDelegate, Zo
ne, dart.functionType(core.Object, [dart.bottom])]); |
| 5586 function _rootRegisterBinaryCallback(self, parent, zone, f) { | 5586 function _rootRegisterBinaryCallback(self, parent, zone, f) { |
| 5587 return f; | 5587 return f; |
| 5588 } | 5588 } |
| 5589 dart.fn(_rootRegisterBinaryCallback, ZoneBinaryCallback, [Zone, ZoneDelegate,
Zone, dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]); | 5589 dart.fn(_rootRegisterBinaryCallback, ZoneBinaryCallback, [Zone, ZoneDelegate,
Zone, dart.functionType(core.Object, [dart.bottom, dart.bottom])]); |
| 5590 function _rootErrorCallback(self, parent, zone, error, stackTrace) { | 5590 function _rootErrorCallback(self, parent, zone, error, stackTrace) { |
| 5591 return null; | 5591 return null; |
| 5592 } | 5592 } |
| 5593 dart.fn(_rootErrorCallback, AsyncError, [Zone, ZoneDelegate, Zone, core.Object
, core.StackTrace]); | 5593 dart.fn(_rootErrorCallback, AsyncError, [Zone, ZoneDelegate, Zone, core.Object
, core.StackTrace]); |
| 5594 function _rootScheduleMicrotask(self, parent, zone, f) { | 5594 function _rootScheduleMicrotask(self, parent, zone, f) { |
| 5595 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { | 5595 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { |
| 5596 let hasErrorHandler = !dart.notNull(_ROOT_ZONE.inSameErrorZone(zone)); | 5596 let hasErrorHandler = !dart.notNull(_ROOT_ZONE.inSameErrorZone(zone)); |
| 5597 f = zone.bindCallback(f, {runGuarded: hasErrorHandler}); | 5597 f = zone.bindCallback(f, {runGuarded: hasErrorHandler}); |
| 5598 } | 5598 } |
| 5599 _scheduleAsyncCallback(f); | 5599 _scheduleAsyncCallback(f); |
| 5600 } | 5600 } |
| 5601 dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [])]); | 5601 dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(core.Object, [])]); |
| 5602 function _rootCreateTimer(self, parent, zone, duration, callback) { | 5602 function _rootCreateTimer(self, parent, zone, duration, callback) { |
| 5603 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { | 5603 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { |
| 5604 callback = zone.bindCallback(callback); | 5604 callback = zone.bindCallback(callback); |
| 5605 } | 5605 } |
| 5606 return Timer._createTimer(duration, callback); | 5606 return Timer._createTimer(duration, callback); |
| 5607 } | 5607 } |
| 5608 dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dar
t.functionType(dart.void, [])]); | 5608 dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dar
t.functionType(dart.void, [])]); |
| 5609 function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) { | 5609 function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) { |
| 5610 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { | 5610 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { |
| 5611 callback = dart.as(zone.bindUnaryCallback(callback), __CastType36); | 5611 callback = dart.as(zone.bindUnaryCallback(callback), __CastType36); |
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5704 return self.parent.runUnary(dart.as(onError, __CastType38), error); | 5704 return self.parent.runUnary(dart.as(onError, __CastType38), error); |
| 5705 } catch (e) { | 5705 } catch (e) { |
| 5706 let s = dart.stackTrace(e); | 5706 let s = dart.stackTrace(e); |
| 5707 if (core.identical(e, error)) { | 5707 if (core.identical(e, error)) { |
| 5708 return parent.handleUncaughtError(zone, error, stackTrace); | 5708 return parent.handleUncaughtError(zone, error, stackTrace); |
| 5709 } else { | 5709 } else { |
| 5710 return parent.handleUncaughtError(zone, e, s); | 5710 return parent.handleUncaughtError(zone, e, s); |
| 5711 } | 5711 } |
| 5712 } | 5712 } |
| 5713 | 5713 |
| 5714 }, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]
); | 5714 }, core.Object, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]); |
| 5715 } | 5715 } |
| 5716 if (zoneSpecification == null) { | 5716 if (zoneSpecification == null) { |
| 5717 zoneSpecification = new ZoneSpecification({handleUncaughtError: errorHandl
er}); | 5717 zoneSpecification = new ZoneSpecification({handleUncaughtError: errorHandl
er}); |
| 5718 } else if (errorHandler != null) { | 5718 } else if (errorHandler != null) { |
| 5719 zoneSpecification = new ZoneSpecification.from(zoneSpecification, {handleU
ncaughtError: errorHandler}); | 5719 zoneSpecification = new ZoneSpecification.from(zoneSpecification, {handleU
ncaughtError: errorHandler}); |
| 5720 } | 5720 } |
| 5721 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); | 5721 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); |
| 5722 if (onError != null) { | 5722 if (onError != null) { |
| 5723 return zone.runGuarded(body); | 5723 return zone.runGuarded(body); |
| 5724 } else { | 5724 } else { |
| 5725 return zone.run(body); | 5725 return zone.run(body); |
| 5726 } | 5726 } |
| 5727 } | 5727 } |
| 5728 dart.fn(runZoned, dart.dynamic, [dart.functionType(dart.dynamic, [])], {oneVal
ue: core.Map, oneSpecificatio: ZoneSpecification, nErro: core.Function}); | 5728 dart.fn(runZoned, core.Object, [dart.functionType(core.Object, [])], {oneValue
: core.Map, oneSpecificatio: ZoneSpecification, nErro: core.Function}); |
| 5729 let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.v
oid, [Timer])); | 5729 let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.v
oid, [Timer])); |
| 5730 let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); | 5730 let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(core.O
bject, [dart.bottom])); |
| 5731 dart.copyProperties(exports, { | 5731 dart.copyProperties(exports, { |
| 5732 get _hasDocument() { | 5732 get _hasDocument() { |
| 5733 return typeof document == 'object'; | 5733 return typeof document == 'object'; |
| 5734 } | 5734 } |
| 5735 }); | 5735 }); |
| 5736 // Exports: | 5736 // Exports: |
| 5737 exports.AsyncError = AsyncError; | 5737 exports.AsyncError = AsyncError; |
| 5738 exports.Stream$ = Stream$; | 5738 exports.Stream$ = Stream$; |
| 5739 exports.Stream = Stream; | 5739 exports.Stream = Stream; |
| 5740 exports.DeferredLibrary = DeferredLibrary; | 5740 exports.DeferredLibrary = DeferredLibrary; |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5776 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5776 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
| 5777 exports.CreateTimerHandler = CreateTimerHandler; | 5777 exports.CreateTimerHandler = CreateTimerHandler; |
| 5778 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5778 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
| 5779 exports.PrintHandler = PrintHandler; | 5779 exports.PrintHandler = PrintHandler; |
| 5780 exports.ForkHandler = ForkHandler; | 5780 exports.ForkHandler = ForkHandler; |
| 5781 exports.ZoneSpecification = ZoneSpecification; | 5781 exports.ZoneSpecification = ZoneSpecification; |
| 5782 exports.ZoneDelegate = ZoneDelegate; | 5782 exports.ZoneDelegate = ZoneDelegate; |
| 5783 exports.Zone = Zone; | 5783 exports.Zone = Zone; |
| 5784 exports.runZoned = runZoned; | 5784 exports.runZoned = runZoned; |
| 5785 })(async, core, _internal, _js_helper, _isolate_helper, collection); | 5785 })(async, core, _internal, _js_helper, _isolate_helper, collection); |
| OLD | NEW |