OLD | NEW |
1 dart_library.library('dart/async', null, /* Imports */[ | 1 dart_library.library('dart/async', null, /* Imports */[ |
2 "dart_runtime/dart", | 2 "dart_runtime/dart", |
3 'dart/core', | 3 'dart/core', |
4 'dart/_internal', | 4 'dart/_internal', |
5 'dart/collection' | 5 'dart/collection' |
6 ], /* Lazy imports */[ | 6 ], /* Lazy imports */[ |
7 'dart/_isolate_helper', | 7 'dart/_isolate_helper', |
8 'dart/_js_helper' | 8 'dart/_js_helper' |
9 ], function(exports, dart, core, _internal, collection, _isolate_helper, _js_hel
per) { | 9 ], function(exports, dart, core, _internal, collection, _isolate_helper, _js_hel
per) { |
10 'use strict'; | 10 'use strict'; |
11 let dartx = dart.dartx; | 11 let dartx = dart.dartx; |
12 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 12 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
13 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 13 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
14 return dart.dcall(errorHandler, error, stackTrace); | 14 return dart.dcall(errorHandler, error, stackTrace); |
15 } else { | 15 } else { |
16 return dart.dcall(errorHandler, error); | 16 return dart.dcall(errorHandler, error); |
17 } | 17 } |
18 } | 18 } |
19 dart.fn(_invokeErrorHandler, core.Object, [core.Function, core.Object, core.St
ackTrace]); | 19 dart.fn(_invokeErrorHandler, dart.dynamic, [core.Function, core.Object, core.S
tackTrace]); |
20 function _registerErrorHandler(errorHandler, zone) { | 20 function _registerErrorHandler(errorHandler, zone) { |
21 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 21 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
22 return zone.registerBinaryCallback(errorHandler); | 22 return zone.registerBinaryCallback(errorHandler); |
23 } else { | 23 } else { |
24 return zone.registerUnaryCallback(dart.as(errorHandler, __CastType0)); | 24 return zone.registerUnaryCallback(dart.as(errorHandler, __CastType0)); |
25 } | 25 } |
26 } | 26 } |
27 dart.fn(_registerErrorHandler, () => dart.functionType(core.Function, [core.Fu
nction, Zone])); | 27 dart.fn(_registerErrorHandler, () => dart.definiteFunctionType(core.Function,
[core.Function, Zone])); |
28 class AsyncError extends core.Object { | 28 class AsyncError extends core.Object { |
29 AsyncError(error, stackTrace) { | 29 AsyncError(error, stackTrace) { |
30 this.error = error; | 30 this.error = error; |
31 this.stackTrace = stackTrace; | 31 this.stackTrace = stackTrace; |
32 } | 32 } |
33 toString() { | 33 toString() { |
34 return dart.toString(this.error); | 34 return dart.toString(this.error); |
35 } | 35 } |
36 } | 36 } |
37 AsyncError[dart.implements] = () => [core.Error]; | 37 AsyncError[dart.implements] = () => [core.Error]; |
38 dart.setSignature(AsyncError, { | 38 dart.setSignature(AsyncError, { |
39 constructors: () => ({AsyncError: [AsyncError, [core.Object, core.StackTrace
]]}) | 39 constructors: () => ({AsyncError: [AsyncError, [dart.dynamic, core.StackTrac
e]]}) |
40 }); | 40 }); |
41 class _UncaughtAsyncError extends AsyncError { | 41 class _UncaughtAsyncError extends AsyncError { |
42 _UncaughtAsyncError(error, stackTrace) { | 42 _UncaughtAsyncError(error, stackTrace) { |
43 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac
kTrace)); | 43 super.AsyncError(error, _UncaughtAsyncError._getBestStackTrace(error, stac
kTrace)); |
44 } | 44 } |
45 static _getBestStackTrace(error, stackTrace) { | 45 static _getBestStackTrace(error, stackTrace) { |
46 if (stackTrace != null) | 46 if (stackTrace != null) |
47 return stackTrace; | 47 return stackTrace; |
48 if (dart.is(error, core.Error)) { | 48 if (dart.is(error, core.Error)) { |
49 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); | 49 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); |
50 } | 50 } |
51 return null; | 51 return null; |
52 } | 52 } |
53 toString() { | 53 toString() { |
54 let result = `Uncaught Error: ${this.error}`; | 54 let result = `Uncaught Error: ${this.error}`; |
55 if (this.stackTrace != null) { | 55 if (this.stackTrace != null) { |
56 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; | 56 result = dart.notNull(result) + `\nStack Trace:\n${this.stackTrace}`; |
57 } | 57 } |
58 return result; | 58 return result; |
59 } | 59 } |
60 } | 60 } |
61 dart.setSignature(_UncaughtAsyncError, { | 61 dart.setSignature(_UncaughtAsyncError, { |
62 constructors: () => ({_UncaughtAsyncError: [_UncaughtAsyncError, [core.Objec
t, core.StackTrace]]}), | 62 constructors: () => ({_UncaughtAsyncError: [_UncaughtAsyncError, [dart.dynam
ic, core.StackTrace]]}), |
63 statics: () => ({_getBestStackTrace: [core.StackTrace, [core.Object, core.St
ackTrace]]}), | 63 statics: () => ({_getBestStackTrace: [core.StackTrace, [dart.dynamic, core.S
tackTrace]]}), |
64 names: ['_getBestStackTrace'] | 64 names: ['_getBestStackTrace'] |
65 }); | 65 }); |
66 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(core.Obj
ect, [dart.bottom])); | 66 let __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dyn
amic, [dart.dynamic])); |
67 let _add = Symbol('_add'); | 67 let _add = Symbol('_add'); |
68 let _closeUnchecked = Symbol('_closeUnchecked'); | 68 let _closeUnchecked = Symbol('_closeUnchecked'); |
69 let _addError = Symbol('_addError'); | 69 let _addError = Symbol('_addError'); |
70 let _completeError = Symbol('_completeError'); | 70 let _completeError = Symbol('_completeError'); |
71 let _complete = Symbol('_complete'); | 71 let _complete = Symbol('_complete'); |
72 let _sink = Symbol('_sink'); | 72 let _sink = Symbol('_sink'); |
73 let Stream$ = dart.generic(function(T) { | 73 let Stream$ = dart.generic(function(T) { |
74 class Stream extends core.Object { | 74 class Stream extends core.Object { |
75 Stream() { | 75 Stream() { |
76 } | 76 } |
77 static fromFuture(future) { | 77 static fromFuture(future) { |
78 let controller = dart.as(StreamController$(T).new({sync: true}), _Stream
Controller$(T)); | 78 let controller = dart.as(StreamController$(T).new({sync: true}), _Stream
Controller$(T)); |
79 future.then(dart.fn(value => { | 79 future.then(dart.fn(value => { |
80 controller[_add](dart.as(value, T)); | 80 controller[_add](dart.as(value, T)); |
81 controller[_closeUnchecked](); | 81 controller[_closeUnchecked](); |
82 }), {onError: dart.fn((error, stackTrace) => { | 82 }), {onError: dart.fn((error, stackTrace) => { |
83 controller[_addError](error, dart.as(stackTrace, core.StackTrace)); | 83 controller[_addError](error, dart.as(stackTrace, core.StackTrace)); |
84 controller[_closeUnchecked](); | 84 controller[_closeUnchecked](); |
85 })}); | 85 })}); |
86 return controller.stream; | 86 return controller.stream; |
87 } | 87 } |
88 static fromIterable(data) { | 88 static fromIterable(data) { |
89 return new (_GeneratedStreamImpl$(T))(dart.fn(() => new (_IterablePendin
gEvents$(T))(data), _IterablePendingEvents$(T), [])); | 89 return new (_GeneratedStreamImpl$(T))(dart.fn(() => new (_IterablePendin
gEvents$(T))(data), _IterablePendingEvents$(T), [])); |
90 } | 90 } |
91 static periodic(period, computation) { | 91 static periodic(period, computation) { |
92 if (computation === void 0) | 92 if (computation === void 0) |
93 computation = null; | 93 computation = null; |
94 if (computation == null) | 94 if (computation == null) |
95 computation = dart.fn(i => null, dart.bottom, [core.Object]); | 95 computation = dart.fn(i => null, dart.bottom, [dart.dynamic]); |
96 let timer = null; | 96 let timer = null; |
97 let computationCount = 0; | 97 let computationCount = 0; |
98 let controller = null; | 98 let controller = null; |
99 let watch = new core.Stopwatch(); | 99 let watch = new core.Stopwatch(); |
100 let sendEvent = () => { | 100 let sendEvent = () => { |
101 watch.reset(); | 101 watch.reset(); |
102 let data = computation((() => { | 102 let data = computation((() => { |
103 let x = computationCount; | 103 let x = computationCount; |
104 computationCount = dart.notNull(x) + 1; | 104 computationCount = dart.notNull(x) + 1; |
105 return x; | 105 return x; |
106 })()); | 106 })()); |
107 controller.add(data); | 107 controller.add(data); |
108 }; | 108 }; |
109 dart.fn(sendEvent, dart.void, []); | 109 dart.fn(sendEvent, dart.void, []); |
110 let startPeriodicTimer = () => { | 110 let startPeriodicTimer = () => { |
111 dart.assert(timer == null); | 111 dart.assert(timer == null); |
112 timer = Timer.periodic(period, dart.fn(timer => { | 112 timer = Timer.periodic(period, dart.fn(timer => { |
113 sendEvent(); | 113 sendEvent(); |
114 }, core.Object, [Timer])); | 114 }, dart.dynamic, [Timer])); |
115 }; | 115 }; |
116 dart.fn(startPeriodicTimer, dart.void, []); | 116 dart.fn(startPeriodicTimer, dart.void, []); |
117 controller = StreamController$(T).new({sync: true, onListen: dart.fn(()
=> { | 117 controller = StreamController$(T).new({sync: true, onListen: dart.fn(()
=> { |
118 watch.start(); | 118 watch.start(); |
119 startPeriodicTimer(); | 119 startPeriodicTimer(); |
120 }), onPause: dart.fn(() => { | 120 }), onPause: dart.fn(() => { |
121 timer.cancel(); | 121 timer.cancel(); |
122 timer = null; | 122 timer = null; |
123 watch.stop(); | 123 watch.stop(); |
124 }), onResume: dart.fn(() => { | 124 }), onResume: dart.fn(() => { |
125 dart.assert(timer == null); | 125 dart.assert(timer == null); |
126 let elapsed = watch.elapsed; | 126 let elapsed = watch.elapsed; |
127 watch.start(); | 127 watch.start(); |
128 timer = Timer.new(period['-'](elapsed), dart.fn(() => { | 128 timer = Timer.new(period['-'](elapsed), dart.fn(() => { |
129 timer = null; | 129 timer = null; |
130 startPeriodicTimer(); | 130 startPeriodicTimer(); |
131 sendEvent(); | 131 sendEvent(); |
132 })); | 132 })); |
133 }), onCancel: dart.fn(() => { | 133 }), onCancel: dart.fn(() => { |
134 if (timer != null) | 134 if (timer != null) |
135 timer.cancel(); | 135 timer.cancel(); |
136 timer = null; | 136 timer = null; |
137 })}); | 137 })}); |
138 return controller.stream; | 138 return controller.stream; |
139 } | 139 } |
140 static eventTransformed(source, mapSink) { | 140 static eventTransformed(source, mapSink) { |
141 return new (_BoundSinkStream$(core.Object, T))(source, dart.as(mapSink,
_SinkMapper)); | 141 return new (_BoundSinkStream$(dart.dynamic, T))(source, dart.as(mapSink,
_SinkMapper)); |
142 } | 142 } |
143 get isBroadcast() { | 143 get isBroadcast() { |
144 return false; | 144 return false; |
145 } | 145 } |
146 asBroadcastStream(opts) { | 146 asBroadcastStream(opts) { |
147 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 147 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
148 dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)])
); | 148 dart.as(onListen, dart.functionType(dart.void, [StreamSubscription$(T)])
); |
149 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 149 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
150 dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)])
); | 150 dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription$(T)])
); |
151 return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType12
), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription]))); | 151 return new (_AsBroadcastStream$(T))(this, dart.as(onListen, __CastType12
), dart.as(onCancel, dart.functionType(dart.void, [StreamSubscription]))); |
152 } | 152 } |
153 where(test) { | 153 where(test) { |
154 dart.as(test, dart.functionType(core.bool, [T])); | 154 dart.as(test, dart.functionType(core.bool, [T])); |
155 return new (_WhereStream$(T))(this, test); | 155 return new (_WhereStream$(T))(this, test); |
156 } | 156 } |
157 map(convert) { | 157 map(convert) { |
158 dart.as(convert, dart.functionType(core.Object, [T])); | 158 dart.as(convert, dart.functionType(dart.dynamic, [T])); |
159 return new (_MapStream$(T, core.Object))(this, convert); | 159 return new (_MapStream$(T, dart.dynamic))(this, convert); |
160 } | 160 } |
161 asyncMap(convert) { | 161 asyncMap(convert) { |
162 dart.as(convert, dart.functionType(core.Object, [T])); | 162 dart.as(convert, dart.functionType(dart.dynamic, [T])); |
163 let controller = null; | 163 let controller = null; |
164 let subscription = null; | 164 let subscription = null; |
165 let onListen = () => { | 165 let onListen = () => { |
166 let add = dart.bind(controller, 'add'); | 166 let add = dart.bind(controller, 'add'); |
167 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); | 167 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); |
168 let eventSink = controller; | 168 let eventSink = controller; |
169 let addError = eventSink[_addError]; | 169 let addError = eventSink[_addError]; |
170 subscription = this.listen(dart.fn(event => { | 170 subscription = this.listen(dart.fn(event => { |
171 dart.as(event, T); | 171 dart.as(event, T); |
172 let newValue = null; | 172 let newValue = null; |
173 try { | 173 try { |
174 newValue = convert(event); | 174 newValue = convert(event); |
175 } catch (e) { | 175 } catch (e) { |
176 let s = dart.stackTrace(e); | 176 let s = dart.stackTrace(e); |
177 controller.addError(e, s); | 177 controller.addError(e, s); |
178 return; | 178 return; |
179 } | 179 } |
180 | 180 |
181 if (dart.is(newValue, Future)) { | 181 if (dart.is(newValue, Future)) { |
182 subscription.pause(); | 182 subscription.pause(); |
183 dart.dsend(dart.dsend(newValue, 'then', add, {onError: addError}),
'whenComplete', dart.bind(subscription, 'resume')); | 183 dart.dsend(dart.dsend(newValue, 'then', add, {onError: addError}),
'whenComplete', dart.bind(subscription, 'resume')); |
184 } else { | 184 } else { |
185 controller.add(newValue); | 185 controller.add(newValue); |
186 } | 186 } |
187 }, core.Object, [T]), {onError: dart.as(addError, core.Function), onDo
ne: dart.bind(controller, 'close')}); | 187 }, dart.dynamic, [T]), {onError: dart.as(addError, core.Function), onD
one: dart.bind(controller, 'close')}); |
188 }; | 188 }; |
189 dart.fn(onListen, dart.void, []); | 189 dart.fn(onListen, dart.void, []); |
190 if (dart.notNull(this.isBroadcast)) { | 190 if (dart.notNull(this.isBroadcast)) { |
191 controller = StreamController.broadcast({onListen: onListen, onCancel:
dart.fn(() => { | 191 controller = StreamController.broadcast({onListen: onListen, onCancel:
dart.fn(() => { |
192 subscription.cancel(); | 192 subscription.cancel(); |
193 }), sync: true}); | 193 }), sync: true}); |
194 } else { | 194 } else { |
195 controller = StreamController.new({onListen: onListen, onPause: dart.f
n(() => { | 195 controller = StreamController.new({onListen: onListen, onPause: dart.f
n(() => { |
196 subscription.pause(); | 196 subscription.pause(); |
197 }), onResume: dart.fn(() => { | 197 }), onResume: dart.fn(() => { |
(...skipping 19 matching lines...) Expand all Loading... |
217 } catch (e) { | 217 } catch (e) { |
218 let s = dart.stackTrace(e); | 218 let s = dart.stackTrace(e); |
219 controller.addError(e, s); | 219 controller.addError(e, s); |
220 return; | 220 return; |
221 } | 221 } |
222 | 222 |
223 if (newStream != null) { | 223 if (newStream != null) { |
224 subscription.pause(); | 224 subscription.pause(); |
225 controller.addStream(newStream).whenComplete(dart.bind(subscriptio
n, 'resume')); | 225 controller.addStream(newStream).whenComplete(dart.bind(subscriptio
n, 'resume')); |
226 } | 226 } |
227 }, core.Object, [T]), {onError: dart.as(eventSink[_addError], core.Fun
ction), onDone: dart.bind(controller, 'close')}); | 227 }, dart.dynamic, [T]), {onError: dart.as(eventSink[_addError], core.Fu
nction), onDone: dart.bind(controller, 'close')}); |
228 }; | 228 }; |
229 dart.fn(onListen, dart.void, []); | 229 dart.fn(onListen, dart.void, []); |
230 if (dart.notNull(this.isBroadcast)) { | 230 if (dart.notNull(this.isBroadcast)) { |
231 controller = StreamController.broadcast({onListen: onListen, onCancel:
dart.fn(() => { | 231 controller = StreamController.broadcast({onListen: onListen, onCancel:
dart.fn(() => { |
232 subscription.cancel(); | 232 subscription.cancel(); |
233 }), sync: true}); | 233 }), sync: true}); |
234 } else { | 234 } else { |
235 controller = StreamController.new({onListen: onListen, onPause: dart.f
n(() => { | 235 controller = StreamController.new({onListen: onListen, onPause: dart.f
n(() => { |
236 subscription.pause(); | 236 subscription.pause(); |
237 }), onResume: dart.fn(() => { | 237 }), onResume: dart.fn(() => { |
238 subscription.resume(); | 238 subscription.resume(); |
239 }), onCancel: dart.fn(() => { | 239 }), onCancel: dart.fn(() => { |
240 subscription.cancel(); | 240 subscription.cancel(); |
241 }), sync: true}); | 241 }), sync: true}); |
242 } | 242 } |
243 return controller.stream; | 243 return controller.stream; |
244 } | 244 } |
245 handleError(onError, opts) { | 245 handleError(onError, opts) { |
246 let test = opts && 'test' in opts ? opts.test : null; | 246 let test = opts && 'test' in opts ? opts.test : null; |
247 dart.as(test, dart.functionType(core.bool, [dart.bottom])); | 247 dart.as(test, dart.functionType(core.bool, [dart.dynamic])); |
248 return new (_HandleErrorStream$(T))(this, onError, test); | 248 return new (_HandleErrorStream$(T))(this, onError, test); |
249 } | 249 } |
250 expand(convert) { | 250 expand(convert) { |
251 dart.as(convert, dart.functionType(core.Iterable, [T])); | 251 dart.as(convert, dart.functionType(core.Iterable, [T])); |
252 return new (_ExpandStream$(T, core.Object))(this, convert); | 252 return new (_ExpandStream$(T, dart.dynamic))(this, convert); |
253 } | 253 } |
254 pipe(streamConsumer) { | 254 pipe(streamConsumer) { |
255 dart.as(streamConsumer, StreamConsumer$(T)); | 255 dart.as(streamConsumer, StreamConsumer$(T)); |
256 return streamConsumer.addStream(this).then(dart.fn(_ => streamConsumer.c
lose(), Future, [core.Object])); | 256 return streamConsumer.addStream(this).then(dart.fn(_ => streamConsumer.c
lose(), Future, [dart.dynamic])); |
257 } | 257 } |
258 transform(streamTransformer) { | 258 transform(streamTransformer) { |
259 dart.as(streamTransformer, StreamTransformer$(T, core.Object)); | 259 dart.as(streamTransformer, StreamTransformer$(T, dart.dynamic)); |
260 return streamTransformer.bind(this); | 260 return streamTransformer.bind(this); |
261 } | 261 } |
262 reduce(combine) { | 262 reduce(combine) { |
263 dart.as(combine, dart.functionType(T, [T, T])); | 263 dart.as(combine, dart.functionType(T, [T, T])); |
264 let result = new (_Future$(T))(); | 264 let result = new (_Future$(T))(); |
265 let seenFirst = false; | 265 let seenFirst = false; |
266 let value = null; | 266 let value = null; |
267 let subscription = null; | 267 let subscription = null; |
268 subscription = this.listen(dart.fn(element => { | 268 subscription = this.listen(dart.fn(element => { |
269 dart.as(element, T); | 269 dart.as(element, T); |
270 if (dart.notNull(seenFirst)) { | 270 if (dart.notNull(seenFirst)) { |
271 _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(
newValue => { | 271 _runUserCode(dart.fn(() => combine(value, element), T, []), dart.fn(
newValue => { |
272 dart.as(newValue, T); | 272 dart.as(newValue, T); |
273 value = newValue; | 273 value = newValue; |
274 }, core.Object, [T]), dart.as(_cancelAndErrorClosure(subscription, r
esult), __CastType14)); | 274 }, dart.dynamic, [T]), dart.as(_cancelAndErrorClosure(subscription,
result), __CastType14)); |
275 } else { | 275 } else { |
276 value = element; | 276 value = element; |
277 seenFirst = true; | 277 seenFirst = true; |
278 } | 278 } |
279 }, core.Object, [T]), {onError: dart.bind(result, _completeError), onDon
e: dart.fn(() => { | 279 }, dart.dynamic, [T]), {onError: dart.bind(result, _completeError), onDo
ne: dart.fn(() => { |
280 if (!dart.notNull(seenFirst)) { | 280 if (!dart.notNull(seenFirst)) { |
281 try { | 281 try { |
282 throw _internal.IterableElementError.noElement(); | 282 throw _internal.IterableElementError.noElement(); |
283 } catch (e) { | 283 } catch (e) { |
284 let s = dart.stackTrace(e); | 284 let s = dart.stackTrace(e); |
285 _completeWithErrorCallback(result, e, s); | 285 _completeWithErrorCallback(result, e, s); |
286 } | 286 } |
287 | 287 |
288 } else { | 288 } else { |
289 result[_complete](value); | 289 result[_complete](value); |
290 } | 290 } |
291 }), cancelOnError: true}); | 291 }), cancelOnError: true}); |
292 return result; | 292 return result; |
293 } | 293 } |
294 fold(initialValue, combine) { | 294 fold(initialValue, combine) { |
295 dart.as(combine, dart.functionType(core.Object, [dart.bottom, T])); | 295 dart.as(combine, dart.functionType(dart.dynamic, [dart.dynamic, T])); |
296 let result = new _Future(); | 296 let result = new _Future(); |
297 let value = initialValue; | 297 let value = initialValue; |
298 let subscription = null; | 298 let subscription = null; |
299 subscription = this.listen(dart.fn(element => { | 299 subscription = this.listen(dart.fn(element => { |
300 dart.as(element, T); | 300 dart.as(element, T); |
301 _runUserCode(dart.fn(() => dart.dcall(combine, value, element)), dart.
fn(newValue => { | 301 _runUserCode(dart.fn(() => dart.dcall(combine, value, element)), dart.
fn(newValue => { |
302 value = newValue; | 302 value = newValue; |
303 }), dart.as(_cancelAndErrorClosure(subscription, result), dart.functio
nType(core.Object, [dart.bottom, core.StackTrace]))); | 303 }), dart.as(_cancelAndErrorClosure(subscription, result), dart.functio
nType(dart.dynamic, [dart.dynamic, core.StackTrace]))); |
304 }, core.Object, [T]), {onError: dart.fn((e, st) => { | 304 }, dart.dynamic, [T]), {onError: dart.fn((e, st) => { |
305 result[_completeError](e, dart.as(st, core.StackTrace)); | 305 result[_completeError](e, dart.as(st, core.StackTrace)); |
306 }), onDone: dart.fn(() => { | 306 }), onDone: dart.fn(() => { |
307 result[_complete](value); | 307 result[_complete](value); |
308 }), cancelOnError: true}); | 308 }), cancelOnError: true}); |
309 return result; | 309 return result; |
310 } | 310 } |
311 join(separator) { | 311 join(separator) { |
312 if (separator === void 0) | 312 if (separator === void 0) |
313 separator = ""; | 313 separator = ""; |
314 let result = new (_Future$(core.String))(); | 314 let result = new (_Future$(core.String))(); |
315 let buffer = new core.StringBuffer(); | 315 let buffer = new core.StringBuffer(); |
316 let subscription = null; | 316 let subscription = null; |
317 let first = true; | 317 let first = true; |
318 subscription = this.listen(dart.fn(element => { | 318 subscription = this.listen(dart.fn(element => { |
319 dart.as(element, T); | 319 dart.as(element, T); |
320 if (!dart.notNull(first)) { | 320 if (!dart.notNull(first)) { |
321 buffer.write(separator); | 321 buffer.write(separator); |
322 } | 322 } |
323 first = false; | 323 first = false; |
324 try { | 324 try { |
325 buffer.write(element); | 325 buffer.write(element); |
326 } catch (e) { | 326 } catch (e) { |
327 let s = dart.stackTrace(e); | 327 let s = dart.stackTrace(e); |
328 _cancelAndErrorWithReplacement(subscription, result, e, s); | 328 _cancelAndErrorWithReplacement(subscription, result, e, s); |
329 } | 329 } |
330 | 330 |
331 }, core.Object, [T]), {onError: dart.fn(e => { | 331 }, dart.dynamic, [T]), {onError: dart.fn(e => { |
332 result[_completeError](e); | 332 result[_completeError](e); |
333 }), onDone: dart.fn(() => { | 333 }), onDone: dart.fn(() => { |
334 result[_complete](dart.toString(buffer)); | 334 result[_complete](dart.toString(buffer)); |
335 }), cancelOnError: true}); | 335 }), cancelOnError: true}); |
336 return result; | 336 return result; |
337 } | 337 } |
338 contains(needle) { | 338 contains(needle) { |
339 let future = new (_Future$(core.bool))(); | 339 let future = new (_Future$(core.bool))(); |
340 let subscription = null; | 340 let subscription = null; |
341 subscription = this.listen(dart.fn(element => { | 341 subscription = this.listen(dart.fn(element => { |
342 dart.as(element, T); | 342 dart.as(element, T); |
343 _runUserCode(dart.fn(() => dart.equals(element, needle), core.bool, []
), dart.fn(isMatch => { | 343 _runUserCode(dart.fn(() => dart.equals(element, needle), core.bool, []
), dart.fn(isMatch => { |
344 if (dart.notNull(isMatch)) { | 344 if (dart.notNull(isMatch)) { |
345 _cancelAndValue(subscription, future, true); | 345 _cancelAndValue(subscription, future, true); |
346 } | 346 } |
347 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); | 347 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); |
348 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 348 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
349 future[_complete](false); | 349 future[_complete](false); |
350 }), cancelOnError: true}); | 350 }), cancelOnError: true}); |
351 return future; | 351 return future; |
352 } | 352 } |
353 forEach(action) { | 353 forEach(action) { |
354 dart.as(action, dart.functionType(dart.void, [T])); | 354 dart.as(action, dart.functionType(dart.void, [T])); |
355 let future = new _Future(); | 355 let future = new _Future(); |
356 let subscription = null; | 356 let subscription = null; |
357 subscription = this.listen(dart.fn(element => { | 357 subscription = this.listen(dart.fn(element => { |
358 dart.as(element, T); | 358 dart.as(element, T); |
359 _runUserCode(dart.fn(() => action(element), dart.void, []), dart.fn(_
=> { | 359 _runUserCode(dart.fn(() => action(element), dart.void, []), dart.fn(_
=> { |
360 }), dart.as(_cancelAndErrorClosure(subscription, future), dart.functio
nType(core.Object, [dart.bottom, core.StackTrace]))); | 360 }), dart.as(_cancelAndErrorClosure(subscription, future), dart.functio
nType(dart.dynamic, [dart.dynamic, core.StackTrace]))); |
361 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 361 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
362 future[_complete](null); | 362 future[_complete](null); |
363 }), cancelOnError: true}); | 363 }), cancelOnError: true}); |
364 return future; | 364 return future; |
365 } | 365 } |
366 every(test) { | 366 every(test) { |
367 dart.as(test, dart.functionType(core.bool, [T])); | 367 dart.as(test, dart.functionType(core.bool, [T])); |
368 let future = new (_Future$(core.bool))(); | 368 let future = new (_Future$(core.bool))(); |
369 let subscription = null; | 369 let subscription = null; |
370 subscription = this.listen(dart.fn(element => { | 370 subscription = this.listen(dart.fn(element => { |
371 dart.as(element, T); | 371 dart.as(element, T); |
372 _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMa
tch => { | 372 _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMa
tch => { |
373 if (!dart.notNull(isMatch)) { | 373 if (!dart.notNull(isMatch)) { |
374 _cancelAndValue(subscription, future, false); | 374 _cancelAndValue(subscription, future, false); |
375 } | 375 } |
376 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); | 376 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); |
377 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 377 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
378 future[_complete](true); | 378 future[_complete](true); |
379 }), cancelOnError: true}); | 379 }), cancelOnError: true}); |
380 return future; | 380 return future; |
381 } | 381 } |
382 any(test) { | 382 any(test) { |
383 dart.as(test, dart.functionType(core.bool, [T])); | 383 dart.as(test, dart.functionType(core.bool, [T])); |
384 let future = new (_Future$(core.bool))(); | 384 let future = new (_Future$(core.bool))(); |
385 let subscription = null; | 385 let subscription = null; |
386 subscription = this.listen(dart.fn(element => { | 386 subscription = this.listen(dart.fn(element => { |
387 dart.as(element, T); | 387 dart.as(element, T); |
388 _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMa
tch => { | 388 _runUserCode(dart.fn(() => test(element), core.bool, []), dart.fn(isMa
tch => { |
389 if (dart.notNull(isMatch)) { | 389 if (dart.notNull(isMatch)) { |
390 _cancelAndValue(subscription, future, true); | 390 _cancelAndValue(subscription, future, true); |
391 } | 391 } |
392 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); | 392 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); |
393 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 393 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
394 future[_complete](false); | 394 future[_complete](false); |
395 }), cancelOnError: true}); | 395 }), cancelOnError: true}); |
396 return future; | 396 return future; |
397 } | 397 } |
398 get length() { | 398 get length() { |
399 let future = new (_Future$(core.int))(); | 399 let future = new (_Future$(core.int))(); |
400 let count = 0; | 400 let count = 0; |
401 this.listen(dart.fn(_ => { | 401 this.listen(dart.fn(_ => { |
402 count = dart.notNull(count) + 1; | 402 count = dart.notNull(count) + 1; |
403 }), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => { | 403 }), {onError: dart.bind(future, _completeError), onDone: dart.fn(() => { |
(...skipping 10 matching lines...) Expand all Loading... |
414 future[_complete](true); | 414 future[_complete](true); |
415 }), cancelOnError: true}); | 415 }), cancelOnError: true}); |
416 return future; | 416 return future; |
417 } | 417 } |
418 toList() { | 418 toList() { |
419 let result = dart.list([], T); | 419 let result = dart.list([], T); |
420 let future = new (_Future$(core.List$(T)))(); | 420 let future = new (_Future$(core.List$(T)))(); |
421 this.listen(dart.fn(data => { | 421 this.listen(dart.fn(data => { |
422 dart.as(data, T); | 422 dart.as(data, T); |
423 result[dartx.add](data); | 423 result[dartx.add](data); |
424 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 424 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
425 future[_complete](result); | 425 future[_complete](result); |
426 }), cancelOnError: true}); | 426 }), cancelOnError: true}); |
427 return future; | 427 return future; |
428 } | 428 } |
429 toSet() { | 429 toSet() { |
430 let result = core.Set$(T).new(); | 430 let result = core.Set$(T).new(); |
431 let future = new (_Future$(core.Set$(T)))(); | 431 let future = new (_Future$(core.Set$(T)))(); |
432 this.listen(dart.fn(data => { | 432 this.listen(dart.fn(data => { |
433 dart.as(data, T); | 433 dart.as(data, T); |
434 result.add(data); | 434 result.add(data); |
435 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 435 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
436 future[_complete](result); | 436 future[_complete](result); |
437 }), cancelOnError: true}); | 437 }), cancelOnError: true}); |
438 return future; | 438 return future; |
439 } | 439 } |
440 drain(futureValue) { | 440 drain(futureValue) { |
441 if (futureValue === void 0) | 441 if (futureValue === void 0) |
442 futureValue = null; | 442 futureValue = null; |
443 return this.listen(null, {cancelOnError: true}).asFuture(futureValue); | 443 return this.listen(null, {cancelOnError: true}).asFuture(futureValue); |
444 } | 444 } |
445 take(count) { | 445 take(count) { |
(...skipping 15 matching lines...) Expand all Loading... |
461 equals = null; | 461 equals = null; |
462 dart.as(equals, dart.functionType(core.bool, [T, T])); | 462 dart.as(equals, dart.functionType(core.bool, [T, T])); |
463 return new (_DistinctStream$(T))(this, equals); | 463 return new (_DistinctStream$(T))(this, equals); |
464 } | 464 } |
465 get first() { | 465 get first() { |
466 let future = new (_Future$(T))(); | 466 let future = new (_Future$(T))(); |
467 let subscription = null; | 467 let subscription = null; |
468 subscription = this.listen(dart.fn(value => { | 468 subscription = this.listen(dart.fn(value => { |
469 dart.as(value, T); | 469 dart.as(value, T); |
470 _cancelAndValue(subscription, future, value); | 470 _cancelAndValue(subscription, future, value); |
471 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 471 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
472 try { | 472 try { |
473 throw _internal.IterableElementError.noElement(); | 473 throw _internal.IterableElementError.noElement(); |
474 } catch (e) { | 474 } catch (e) { |
475 let s = dart.stackTrace(e); | 475 let s = dart.stackTrace(e); |
476 _completeWithErrorCallback(future, e, s); | 476 _completeWithErrorCallback(future, e, s); |
477 } | 477 } |
478 | 478 |
479 }), cancelOnError: true}); | 479 }), cancelOnError: true}); |
480 return future; | 480 return future; |
481 } | 481 } |
482 get last() { | 482 get last() { |
483 let future = new (_Future$(T))(); | 483 let future = new (_Future$(T))(); |
484 let result = null; | 484 let result = null; |
485 let foundResult = false; | 485 let foundResult = false; |
486 let subscription = null; | 486 let subscription = null; |
487 subscription = this.listen(dart.fn(value => { | 487 subscription = this.listen(dart.fn(value => { |
488 dart.as(value, T); | 488 dart.as(value, T); |
489 foundResult = true; | 489 foundResult = true; |
490 result = value; | 490 result = value; |
491 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 491 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
492 if (dart.notNull(foundResult)) { | 492 if (dart.notNull(foundResult)) { |
493 future[_complete](result); | 493 future[_complete](result); |
494 return; | 494 return; |
495 } | 495 } |
496 try { | 496 try { |
497 throw _internal.IterableElementError.noElement(); | 497 throw _internal.IterableElementError.noElement(); |
498 } catch (e) { | 498 } catch (e) { |
499 let s = dart.stackTrace(e); | 499 let s = dart.stackTrace(e); |
500 _completeWithErrorCallback(future, e, s); | 500 _completeWithErrorCallback(future, e, s); |
501 } | 501 } |
(...skipping 13 matching lines...) Expand all Loading... |
515 throw _internal.IterableElementError.tooMany(); | 515 throw _internal.IterableElementError.tooMany(); |
516 } catch (e) { | 516 } catch (e) { |
517 let s = dart.stackTrace(e); | 517 let s = dart.stackTrace(e); |
518 _cancelAndErrorWithReplacement(subscription, future, e, s); | 518 _cancelAndErrorWithReplacement(subscription, future, e, s); |
519 } | 519 } |
520 | 520 |
521 return; | 521 return; |
522 } | 522 } |
523 foundResult = true; | 523 foundResult = true; |
524 result = value; | 524 result = value; |
525 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 525 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
526 if (dart.notNull(foundResult)) { | 526 if (dart.notNull(foundResult)) { |
527 future[_complete](result); | 527 future[_complete](result); |
528 return; | 528 return; |
529 } | 529 } |
530 try { | 530 try { |
531 throw _internal.IterableElementError.noElement(); | 531 throw _internal.IterableElementError.noElement(); |
532 } catch (e) { | 532 } catch (e) { |
533 let s = dart.stackTrace(e); | 533 let s = dart.stackTrace(e); |
534 _completeWithErrorCallback(future, e, s); | 534 _completeWithErrorCallback(future, e, s); |
535 } | 535 } |
536 | 536 |
537 }), cancelOnError: true}); | 537 }), cancelOnError: true}); |
538 return future; | 538 return future; |
539 } | 539 } |
540 firstWhere(test, opts) { | 540 firstWhere(test, opts) { |
541 dart.as(test, dart.functionType(core.bool, [T])); | 541 dart.as(test, dart.functionType(core.bool, [T])); |
542 let defaultValue = opts && 'defaultValue' in opts ? opts.defaultValue :
null; | 542 let defaultValue = opts && 'defaultValue' in opts ? opts.defaultValue :
null; |
543 dart.as(defaultValue, dart.functionType(core.Object, [])); | 543 dart.as(defaultValue, dart.functionType(core.Object, [])); |
544 let future = new _Future(); | 544 let future = new _Future(); |
545 let subscription = null; | 545 let subscription = null; |
546 subscription = this.listen(dart.fn(value => { | 546 subscription = this.listen(dart.fn(value => { |
547 dart.as(value, T); | 547 dart.as(value, T); |
548 _runUserCode(dart.fn(() => test(value), core.bool, []), dart.fn(isMatc
h => { | 548 _runUserCode(dart.fn(() => test(value), core.bool, []), dart.fn(isMatc
h => { |
549 if (dart.notNull(isMatch)) { | 549 if (dart.notNull(isMatch)) { |
550 _cancelAndValue(subscription, future, value); | 550 _cancelAndValue(subscription, future, value); |
551 } | 551 } |
552 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); | 552 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); |
553 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 553 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
554 if (defaultValue != null) { | 554 if (defaultValue != null) { |
555 _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind
(future, _completeError)); | 555 _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind
(future, _completeError)); |
556 return; | 556 return; |
557 } | 557 } |
558 try { | 558 try { |
559 throw _internal.IterableElementError.noElement(); | 559 throw _internal.IterableElementError.noElement(); |
560 } catch (e) { | 560 } catch (e) { |
561 let s = dart.stackTrace(e); | 561 let s = dart.stackTrace(e); |
562 _completeWithErrorCallback(future, e, s); | 562 _completeWithErrorCallback(future, e, s); |
563 } | 563 } |
564 | 564 |
565 }), cancelOnError: true}); | 565 }), cancelOnError: true}); |
566 return future; | 566 return future; |
567 } | 567 } |
568 lastWhere(test, opts) { | 568 lastWhere(test, opts) { |
569 dart.as(test, dart.functionType(core.bool, [T])); | 569 dart.as(test, dart.functionType(core.bool, [T])); |
570 let defaultValue = opts && 'defaultValue' in opts ? opts.defaultValue :
null; | 570 let defaultValue = opts && 'defaultValue' in opts ? opts.defaultValue :
null; |
571 dart.as(defaultValue, dart.functionType(core.Object, [])); | 571 dart.as(defaultValue, dart.functionType(core.Object, [])); |
572 let future = new _Future(); | 572 let future = new _Future(); |
573 let result = null; | 573 let result = null; |
574 let foundResult = false; | 574 let foundResult = false; |
575 let subscription = null; | 575 let subscription = null; |
576 subscription = this.listen(dart.fn(value => { | 576 subscription = this.listen(dart.fn(value => { |
577 dart.as(value, T); | 577 dart.as(value, T); |
578 _runUserCode(dart.fn(() => true == test(value), core.bool, []), dart.f
n(isMatch => { | 578 _runUserCode(dart.fn(() => true == test(value), core.bool, []), dart.f
n(isMatch => { |
579 if (dart.notNull(isMatch)) { | 579 if (dart.notNull(isMatch)) { |
580 foundResult = true; | 580 foundResult = true; |
581 result = value; | 581 result = value; |
582 } | 582 } |
583 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); | 583 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); |
584 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 584 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
585 if (dart.notNull(foundResult)) { | 585 if (dart.notNull(foundResult)) { |
586 future[_complete](result); | 586 future[_complete](result); |
587 return; | 587 return; |
588 } | 588 } |
589 if (defaultValue != null) { | 589 if (defaultValue != null) { |
590 _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind
(future, _completeError)); | 590 _runUserCode(defaultValue, dart.bind(future, _complete), dart.bind
(future, _completeError)); |
591 return; | 591 return; |
592 } | 592 } |
593 try { | 593 try { |
594 throw _internal.IterableElementError.noElement(); | 594 throw _internal.IterableElementError.noElement(); |
(...skipping 21 matching lines...) Expand all Loading... |
616 } catch (e) { | 616 } catch (e) { |
617 let s = dart.stackTrace(e); | 617 let s = dart.stackTrace(e); |
618 _cancelAndErrorWithReplacement(subscription, future, e, s); | 618 _cancelAndErrorWithReplacement(subscription, future, e, s); |
619 } | 619 } |
620 | 620 |
621 return; | 621 return; |
622 } | 622 } |
623 foundResult = true; | 623 foundResult = true; |
624 result = value; | 624 result = value; |
625 } | 625 } |
626 }, core.Object, [core.bool]), dart.as(_cancelAndErrorClosure(subscript
ion, future), dart.functionType(core.Object, [dart.bottom, core.StackTrace]))); | 626 }, dart.dynamic, [core.bool]), dart.as(_cancelAndErrorClosure(subscrip
tion, future), dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]))
); |
627 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 627 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
628 if (dart.notNull(foundResult)) { | 628 if (dart.notNull(foundResult)) { |
629 future[_complete](result); | 629 future[_complete](result); |
630 return; | 630 return; |
631 } | 631 } |
632 try { | 632 try { |
633 throw _internal.IterableElementError.noElement(); | 633 throw _internal.IterableElementError.noElement(); |
634 } catch (e) { | 634 } catch (e) { |
635 let s = dart.stackTrace(e); | 635 let s = dart.stackTrace(e); |
636 _completeWithErrorCallback(future, e, s); | 636 _completeWithErrorCallback(future, e, s); |
637 } | 637 } |
638 | 638 |
639 }), cancelOnError: true}); | 639 }), cancelOnError: true}); |
640 return future; | 640 return future; |
641 } | 641 } |
642 elementAt(index) { | 642 elementAt(index) { |
643 if (!(typeof index == 'number') || dart.notNull(index) < 0) | 643 if (!(typeof index == 'number') || dart.notNull(index) < 0) |
644 throw new core.ArgumentError(index); | 644 throw new core.ArgumentError(index); |
645 let future = new (_Future$(T))(); | 645 let future = new (_Future$(T))(); |
646 let subscription = null; | 646 let subscription = null; |
647 let elementIndex = 0; | 647 let elementIndex = 0; |
648 subscription = this.listen(dart.fn(value => { | 648 subscription = this.listen(dart.fn(value => { |
649 dart.as(value, T); | 649 dart.as(value, T); |
650 if (index == elementIndex) { | 650 if (index == elementIndex) { |
651 _cancelAndValue(subscription, future, value); | 651 _cancelAndValue(subscription, future, value); |
652 return; | 652 return; |
653 } | 653 } |
654 elementIndex = dart.notNull(elementIndex) + 1; | 654 elementIndex = dart.notNull(elementIndex) + 1; |
655 }, core.Object, [T]), {onError: dart.bind(future, _completeError), onDon
e: dart.fn(() => { | 655 }, dart.dynamic, [T]), {onError: dart.bind(future, _completeError), onDo
ne: dart.fn(() => { |
656 future[_completeError](core.RangeError.index(index, this, "index", n
ull, elementIndex)); | 656 future[_completeError](core.RangeError.index(index, this, "index", n
ull, elementIndex)); |
657 }), cancelOnError: true}); | 657 }), cancelOnError: true}); |
658 return future; | 658 return future; |
659 } | 659 } |
660 timeout(timeLimit, opts) { | 660 timeout(timeLimit, opts) { |
661 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; | 661 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; |
662 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); | 662 dart.as(onTimeout, dart.functionType(dart.void, [EventSink])); |
663 let controller = null; | 663 let controller = null; |
664 let subscription = null; | 664 let subscription = null; |
665 let timer = null; | 665 let timer = null; |
666 let zone = null; | 666 let zone = null; |
667 let timeout = null; | 667 let timeout = null; |
668 let onData = event => { | 668 let onData = event => { |
669 dart.as(event, T); | 669 dart.as(event, T); |
670 timer.cancel(); | 670 timer.cancel(); |
671 controller.add(event); | 671 controller.add(event); |
672 timer = zone.createTimer(timeLimit, dart.as(timeout, __CastType17)); | 672 timer = zone.createTimer(timeLimit, dart.as(timeout, __CastType17)); |
673 }; | 673 }; |
674 dart.fn(onData, dart.void, [T]); | 674 dart.fn(onData, dart.void, [T]); |
675 let onError = (error, stackTrace) => { | 675 let onError = (error, stackTrace) => { |
676 timer.cancel(); | 676 timer.cancel(); |
677 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); | 677 dart.assert(dart.is(controller, _StreamController) || dart.is(controll
er, _BroadcastStreamController)); |
678 let eventSink = controller; | 678 let eventSink = controller; |
679 dart.dcall(eventSink[_addError], error, stackTrace); | 679 dart.dcall(eventSink[_addError], error, stackTrace); |
680 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType
(dart.void, []))); | 680 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.functionType
(dart.void, []))); |
681 }; | 681 }; |
682 dart.fn(onError, dart.void, [core.Object, core.StackTrace]); | 682 dart.fn(onError, dart.void, [dart.dynamic, core.StackTrace]); |
683 let onDone = () => { | 683 let onDone = () => { |
684 timer.cancel(); | 684 timer.cancel(); |
685 controller.close(); | 685 controller.close(); |
686 }; | 686 }; |
687 dart.fn(onDone, dart.void, []); | 687 dart.fn(onDone, dart.void, []); |
688 let onListen = () => { | 688 let onListen = () => { |
689 zone = Zone.current; | 689 zone = Zone.current; |
690 if (onTimeout == null) { | 690 if (onTimeout == null) { |
691 timeout = dart.fn(() => { | 691 timeout = dart.fn(() => { |
692 controller.addError(new TimeoutException("No stream event", timeLi
mit), null); | 692 controller.addError(new TimeoutException("No stream event", timeLi
mit), null); |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
725 constructors: () => ({ | 725 constructors: () => ({ |
726 Stream: [Stream$(T), []], | 726 Stream: [Stream$(T), []], |
727 fromFuture: [Stream$(T), [Future$(T)]], | 727 fromFuture: [Stream$(T), [Future$(T)]], |
728 fromIterable: [Stream$(T), [core.Iterable$(T)]], | 728 fromIterable: [Stream$(T), [core.Iterable$(T)]], |
729 periodic: [Stream$(T), [core.Duration], [dart.functionType(T, [core.int]
)]], | 729 periodic: [Stream$(T), [core.Duration], [dart.functionType(T, [core.int]
)]], |
730 eventTransformed: [Stream$(T), [Stream$(), dart.functionType(EventSink,
[EventSink$(T)])]] | 730 eventTransformed: [Stream$(T), [Stream$(), dart.functionType(EventSink,
[EventSink$(T)])]] |
731 }), | 731 }), |
732 methods: () => ({ | 732 methods: () => ({ |
733 asBroadcastStream: [Stream$(T), [], {onListen: dart.functionType(dart.vo
id, [StreamSubscription$(T)]), onCancel: dart.functionType(dart.void, [StreamSub
scription$(T)])}], | 733 asBroadcastStream: [Stream$(T), [], {onListen: dart.functionType(dart.vo
id, [StreamSubscription$(T)]), onCancel: dart.functionType(dart.void, [StreamSub
scription$(T)])}], |
734 where: [Stream$(T), [dart.functionType(core.bool, [T])]], | 734 where: [Stream$(T), [dart.functionType(core.bool, [T])]], |
735 map: [Stream$(), [dart.functionType(core.Object, [T])]], | 735 map: [Stream$(), [dart.functionType(dart.dynamic, [T])]], |
736 asyncMap: [Stream$(), [dart.functionType(core.Object, [T])]], | 736 asyncMap: [Stream$(), [dart.functionType(dart.dynamic, [T])]], |
737 asyncExpand: [Stream$(), [dart.functionType(Stream$(), [T])]], | 737 asyncExpand: [Stream$(), [dart.functionType(Stream$(), [T])]], |
738 handleError: [Stream$(T), [core.Function], {test: dart.functionType(core
.bool, [dart.bottom])}], | 738 handleError: [Stream$(T), [core.Function], {test: dart.functionType(core
.bool, [dart.dynamic])}], |
739 expand: [Stream$(), [dart.functionType(core.Iterable, [T])]], | 739 expand: [Stream$(), [dart.functionType(core.Iterable, [T])]], |
740 pipe: [Future, [StreamConsumer$(T)]], | 740 pipe: [Future, [StreamConsumer$(T)]], |
741 transform: [Stream$(), [StreamTransformer$(T, core.Object)]], | 741 transform: [Stream$(), [StreamTransformer$(T, dart.dynamic)]], |
742 reduce: [Future$(T), [dart.functionType(T, [T, T])]], | 742 reduce: [Future$(T), [dart.functionType(T, [T, T])]], |
743 fold: [Future, [core.Object, dart.functionType(core.Object, [dart.bottom
, T])]], | 743 fold: [Future, [dart.dynamic, dart.functionType(dart.dynamic, [dart.dyna
mic, T])]], |
744 join: [Future$(core.String), [], [core.String]], | 744 join: [Future$(core.String), [], [core.String]], |
745 contains: [Future$(core.bool), [core.Object]], | 745 contains: [Future$(core.bool), [core.Object]], |
746 forEach: [Future, [dart.functionType(dart.void, [T])]], | 746 forEach: [Future, [dart.functionType(dart.void, [T])]], |
747 every: [Future$(core.bool), [dart.functionType(core.bool, [T])]], | 747 every: [Future$(core.bool), [dart.functionType(core.bool, [T])]], |
748 any: [Future$(core.bool), [dart.functionType(core.bool, [T])]], | 748 any: [Future$(core.bool), [dart.functionType(core.bool, [T])]], |
749 toList: [Future$(core.List$(T)), []], | 749 toList: [Future$(core.List$(T)), []], |
750 toSet: [Future$(core.Set$(T)), []], | 750 toSet: [Future$(core.Set$(T)), []], |
751 drain: [Future, [], [core.Object]], | 751 drain: [Future, [], [dart.dynamic]], |
752 take: [Stream$(T), [core.int]], | 752 take: [Stream$(T), [core.int]], |
753 takeWhile: [Stream$(T), [dart.functionType(core.bool, [T])]], | 753 takeWhile: [Stream$(T), [dart.functionType(core.bool, [T])]], |
754 skip: [Stream$(T), [core.int]], | 754 skip: [Stream$(T), [core.int]], |
755 skipWhile: [Stream$(T), [dart.functionType(core.bool, [T])]], | 755 skipWhile: [Stream$(T), [dart.functionType(core.bool, [T])]], |
756 distinct: [Stream$(T), [], [dart.functionType(core.bool, [T, T])]], | 756 distinct: [Stream$(T), [], [dart.functionType(core.bool, [T, T])]], |
757 firstWhere: [Future, [dart.functionType(core.bool, [T])], {defaultValue:
dart.functionType(core.Object, [])}], | 757 firstWhere: [Future, [dart.functionType(core.bool, [T])], {defaultValue:
dart.functionType(core.Object, [])}], |
758 lastWhere: [Future, [dart.functionType(core.bool, [T])], {defaultValue:
dart.functionType(core.Object, [])}], | 758 lastWhere: [Future, [dart.functionType(core.bool, [T])], {defaultValue:
dart.functionType(core.Object, [])}], |
759 singleWhere: [Future$(T), [dart.functionType(core.bool, [T])]], | 759 singleWhere: [Future$(T), [dart.functionType(core.bool, [T])]], |
760 elementAt: [Future$(T), [core.int]], | 760 elementAt: [Future$(T), [core.int]], |
761 timeout: [Stream$(), [core.Duration], {onTimeout: dart.functionType(dart
.void, [EventSink])}] | 761 timeout: [Stream$(), [core.Duration], {onTimeout: dart.functionType(dart
.void, [EventSink])}] |
(...skipping 431 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1193 constructors: () => ({_BufferingStreamSubscription: [_BufferingStreamSubsc
ription$(T), [dart.functionType(dart.void, [T]), core.Function, dart.functionTyp
e(dart.void, []), core.bool]]}), | 1193 constructors: () => ({_BufferingStreamSubscription: [_BufferingStreamSubsc
ription$(T), [dart.functionType(dart.void, [T]), core.Function, dart.functionTyp
e(dart.void, []), core.bool]]}), |
1194 methods: () => ({ | 1194 methods: () => ({ |
1195 [_setPendingEvents]: [dart.void, [_PendingEvents]], | 1195 [_setPendingEvents]: [dart.void, [_PendingEvents]], |
1196 [_extractPending]: [_PendingEvents, []], | 1196 [_extractPending]: [_PendingEvents, []], |
1197 onData: [dart.void, [dart.functionType(dart.void, [T])]], | 1197 onData: [dart.void, [dart.functionType(dart.void, [T])]], |
1198 onError: [dart.void, [core.Function]], | 1198 onError: [dart.void, [core.Function]], |
1199 onDone: [dart.void, [dart.functionType(dart.void, [])]], | 1199 onDone: [dart.void, [dart.functionType(dart.void, [])]], |
1200 pause: [dart.void, [], [Future]], | 1200 pause: [dart.void, [], [Future]], |
1201 resume: [dart.void, []], | 1201 resume: [dart.void, []], |
1202 cancel: [Future, []], | 1202 cancel: [Future, []], |
1203 asFuture: [Future, [], [core.Object]], | 1203 asFuture: [Future, [], [dart.dynamic]], |
1204 [_cancel]: [dart.void, []], | 1204 [_cancel]: [dart.void, []], |
1205 [_incrementPauseCount]: [dart.void, []], | 1205 [_incrementPauseCount]: [dart.void, []], |
1206 [_decrementPauseCount]: [dart.void, []], | 1206 [_decrementPauseCount]: [dart.void, []], |
1207 [_add]: [dart.void, [T]], | 1207 [_add]: [dart.void, [T]], |
1208 [_addError]: [dart.void, [core.Object, core.StackTrace]], | 1208 [_addError]: [dart.void, [core.Object, core.StackTrace]], |
1209 [_close]: [dart.void, []], | 1209 [_close]: [dart.void, []], |
1210 [_onPause]: [dart.void, []], | 1210 [_onPause]: [dart.void, []], |
1211 [_onResume]: [dart.void, []], | 1211 [_onResume]: [dart.void, []], |
1212 [_onCancel]: [Future, []], | 1212 [_onCancel]: [Future, []], |
1213 [_addPending]: [dart.void, [_DelayedEvent]], | 1213 [_addPending]: [dart.void, [_DelayedEvent]], |
1214 [_sendData]: [dart.void, [T]], | 1214 [_sendData]: [dart.void, [T]], |
1215 [_sendError]: [dart.void, [core.Object, core.StackTrace]], | 1215 [_sendError]: [dart.void, [core.Object, core.StackTrace]], |
1216 [_sendDone]: [dart.void, []], | 1216 [_sendDone]: [dart.void, []], |
1217 [_guardCallback]: [dart.void, [core.Object]], | 1217 [_guardCallback]: [dart.void, [dart.dynamic]], |
1218 [_checkState]: [dart.void, [core.bool]] | 1218 [_checkState]: [dart.void, [core.bool]] |
1219 }) | 1219 }) |
1220 }); | 1220 }); |
1221 return _BufferingStreamSubscription; | 1221 return _BufferingStreamSubscription; |
1222 }); | 1222 }); |
1223 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); | 1223 let _BufferingStreamSubscription = _BufferingStreamSubscription$(); |
1224 let _recordCancel = Symbol('_recordCancel'); | 1224 let _recordCancel = Symbol('_recordCancel'); |
1225 let _recordPause = Symbol('_recordPause'); | 1225 let _recordPause = Symbol('_recordPause'); |
1226 let _recordResume = Symbol('_recordResume'); | 1226 let _recordResume = Symbol('_recordResume'); |
1227 let _ControllerSubscription$ = dart.generic(function(T) { | 1227 let _ControllerSubscription$ = dart.generic(function(T) { |
(...skipping 336 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1564 subscription[_add](data); | 1564 subscription[_add](data); |
1565 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastSt
reamController._STATE_FIRING); | 1565 this[_state] = dart.notNull(this[_state]) & ~dart.notNull(_BroadcastSt
reamController._STATE_FIRING); |
1566 if (dart.notNull(this[_isEmpty])) { | 1566 if (dart.notNull(this[_isEmpty])) { |
1567 this[_callOnCancel](); | 1567 this[_callOnCancel](); |
1568 } | 1568 } |
1569 return; | 1569 return; |
1570 } | 1570 } |
1571 this[_forEachListener](dart.fn(subscription => { | 1571 this[_forEachListener](dart.fn(subscription => { |
1572 dart.as(subscription, _BufferingStreamSubscription$(T)); | 1572 dart.as(subscription, _BufferingStreamSubscription$(T)); |
1573 subscription[_add](data); | 1573 subscription[_add](data); |
1574 }, core.Object, [_BufferingStreamSubscription$(T)])); | 1574 }, dart.dynamic, [_BufferingStreamSubscription$(T)])); |
1575 } | 1575 } |
1576 [_sendError](error, stackTrace) { | 1576 [_sendError](error, stackTrace) { |
1577 if (dart.notNull(this[_isEmpty])) | 1577 if (dart.notNull(this[_isEmpty])) |
1578 return; | 1578 return; |
1579 this[_forEachListener](dart.fn(subscription => { | 1579 this[_forEachListener](dart.fn(subscription => { |
1580 dart.as(subscription, _BufferingStreamSubscription$(T)); | 1580 dart.as(subscription, _BufferingStreamSubscription$(T)); |
1581 subscription[_addError](error, stackTrace); | 1581 subscription[_addError](error, stackTrace); |
1582 }, core.Object, [_BufferingStreamSubscription$(T)])); | 1582 }, dart.dynamic, [_BufferingStreamSubscription$(T)])); |
1583 } | 1583 } |
1584 [_sendDone]() { | 1584 [_sendDone]() { |
1585 if (!dart.notNull(this[_isEmpty])) { | 1585 if (!dart.notNull(this[_isEmpty])) { |
1586 this[_forEachListener](dart.as(dart.fn(subscription => { | 1586 this[_forEachListener](dart.as(dart.fn(subscription => { |
1587 dart.as(subscription, _BroadcastSubscription$(T)); | 1587 dart.as(subscription, _BroadcastSubscription$(T)); |
1588 subscription[_close](); | 1588 subscription[_close](); |
1589 }, core.Object, [_BroadcastSubscription$(T)]), __CastType2)); | 1589 }, dart.dynamic, [_BroadcastSubscription$(T)]), __CastType2)); |
1590 } else { | 1590 } else { |
1591 dart.assert(this[_doneFuture] != null); | 1591 dart.assert(this[_doneFuture] != null); |
1592 dart.assert(this[_doneFuture][_mayComplete]); | 1592 dart.assert(this[_doneFuture][_mayComplete]); |
1593 this[_doneFuture][_asyncComplete](null); | 1593 this[_doneFuture][_asyncComplete](null); |
1594 } | 1594 } |
1595 } | 1595 } |
1596 } | 1596 } |
1597 dart.setSignature(_SyncBroadcastStreamController, { | 1597 dart.setSignature(_SyncBroadcastStreamController, { |
1598 constructors: () => ({_SyncBroadcastStreamController: [_SyncBroadcastStrea
mController$(T), [dart.functionType(dart.void, []), dart.functionType(dart.void,
[])]]}), | 1598 constructors: () => ({_SyncBroadcastStreamController: [_SyncBroadcastStrea
mController$(T), [dart.functionType(dart.void, []), dart.functionType(dart.void,
[])]]}), |
1599 methods: () => ({ | 1599 methods: () => ({ |
(...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1759 } | 1759 } |
1760 } | 1760 } |
1761 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; | 1761 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)]; |
1762 dart.setSignature(_DoneSubscription, { | 1762 dart.setSignature(_DoneSubscription, { |
1763 methods: () => ({ | 1763 methods: () => ({ |
1764 onData: [dart.void, [dart.functionType(dart.void, [T])]], | 1764 onData: [dart.void, [dart.functionType(dart.void, [T])]], |
1765 onError: [dart.void, [core.Function]], | 1765 onError: [dart.void, [core.Function]], |
1766 onDone: [dart.void, [dart.functionType(dart.void, [])]], | 1766 onDone: [dart.void, [dart.functionType(dart.void, [])]], |
1767 pause: [dart.void, [], [Future]], | 1767 pause: [dart.void, [], [Future]], |
1768 resume: [dart.void, []], | 1768 resume: [dart.void, []], |
1769 [_resume]: [dart.void, [core.Object]], | 1769 [_resume]: [dart.void, [dart.dynamic]], |
1770 cancel: [Future, []], | 1770 cancel: [Future, []], |
1771 asFuture: [Future, [], [core.Object]] | 1771 asFuture: [Future, [], [core.Object]] |
1772 }) | 1772 }) |
1773 }); | 1773 }); |
1774 return _DoneSubscription; | 1774 return _DoneSubscription; |
1775 }); | 1775 }); |
1776 let _DoneSubscription = _DoneSubscription$(); | 1776 let _DoneSubscription = _DoneSubscription$(); |
1777 let __CastType2$ = dart.generic(function(T) { | 1777 let __CastType2$ = dart.generic(function(T) { |
1778 let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.v
oid, [_BufferingStreamSubscription$(T)])); | 1778 let __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.v
oid, [_BufferingStreamSubscription$(T)])); |
1779 return __CastType2; | 1779 return __CastType2; |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1875 let s = dart.stackTrace(e); | 1875 let s = dart.stackTrace(e); |
1876 _completeWithErrorCallback(result, e, s); | 1876 _completeWithErrorCallback(result, e, s); |
1877 } | 1877 } |
1878 | 1878 |
1879 })); | 1879 })); |
1880 return dart.as(result, Future$(T)); | 1880 return dart.as(result, Future$(T)); |
1881 } | 1881 } |
1882 static wait(futures, opts) { | 1882 static wait(futures, opts) { |
1883 let eagerError = opts && 'eagerError' in opts ? opts.eagerError : false; | 1883 let eagerError = opts && 'eagerError' in opts ? opts.eagerError : false; |
1884 let cleanUp = opts && 'cleanUp' in opts ? opts.cleanUp : null; | 1884 let cleanUp = opts && 'cleanUp' in opts ? opts.cleanUp : null; |
1885 dart.as(cleanUp, dart.functionType(dart.void, [dart.bottom])); | 1885 dart.as(cleanUp, dart.functionType(dart.void, [dart.dynamic])); |
1886 let result = new (_Future$(core.List))(); | 1886 let result = new (_Future$(core.List))(); |
1887 let values = null; | 1887 let values = null; |
1888 let remaining = 0; | 1888 let remaining = 0; |
1889 let error = null; | 1889 let error = null; |
1890 let stackTrace = null; | 1890 let stackTrace = null; |
1891 let handleError = (theError, theStackTrace) => { | 1891 let handleError = (theError, theStackTrace) => { |
1892 remaining = dart.notNull(remaining) - 1; | 1892 remaining = dart.notNull(remaining) - 1; |
1893 if (values != null) { | 1893 if (values != null) { |
1894 if (cleanUp != null) { | 1894 if (cleanUp != null) { |
1895 for (let value of values) { | 1895 for (let value of values) { |
1896 if (value != null) { | 1896 if (value != null) { |
1897 Future$().sync(dart.fn(() => { | 1897 Future$().sync(dart.fn(() => { |
1898 dart.dcall(cleanUp, value); | 1898 dart.dcall(cleanUp, value); |
1899 })); | 1899 })); |
1900 } | 1900 } |
1901 } | 1901 } |
1902 } | 1902 } |
1903 values = null; | 1903 values = null; |
1904 if (remaining == 0 || dart.notNull(eagerError)) { | 1904 if (remaining == 0 || dart.notNull(eagerError)) { |
1905 result[_completeError](theError, dart.as(theStackTrace, core.Stack
Trace)); | 1905 result[_completeError](theError, dart.as(theStackTrace, core.Stack
Trace)); |
1906 } else { | 1906 } else { |
1907 error = theError; | 1907 error = theError; |
1908 stackTrace = dart.as(theStackTrace, core.StackTrace); | 1908 stackTrace = dart.as(theStackTrace, core.StackTrace); |
1909 } | 1909 } |
1910 } else if (remaining == 0 && !dart.notNull(eagerError)) { | 1910 } else if (remaining == 0 && !dart.notNull(eagerError)) { |
1911 result[_completeError](error, stackTrace); | 1911 result[_completeError](error, stackTrace); |
1912 } | 1912 } |
1913 }; | 1913 }; |
1914 dart.fn(handleError, dart.void, [core.Object, core.Object]); | 1914 dart.fn(handleError, dart.void, [dart.dynamic, dart.dynamic]); |
1915 for (let future of futures) { | 1915 for (let future of futures) { |
1916 let pos = remaining; | 1916 let pos = remaining; |
1917 remaining = dart.notNull(pos) + 1; | 1917 remaining = dart.notNull(pos) + 1; |
1918 future.then(dart.fn(value => { | 1918 future.then(dart.fn(value => { |
1919 remaining = dart.notNull(remaining) - 1; | 1919 remaining = dart.notNull(remaining) - 1; |
1920 if (values != null) { | 1920 if (values != null) { |
1921 values[dartx.set](pos, value); | 1921 values[dartx.set](pos, value); |
1922 if (remaining == 0) { | 1922 if (remaining == 0) { |
1923 result[_completeWithValue](values); | 1923 result[_completeWithValue](values); |
1924 } | 1924 } |
1925 } else { | 1925 } else { |
1926 if (cleanUp != null && value != null) { | 1926 if (cleanUp != null && value != null) { |
1927 Future$().sync(dart.fn(() => { | 1927 Future$().sync(dart.fn(() => { |
1928 dart.dcall(cleanUp, value); | 1928 dart.dcall(cleanUp, value); |
1929 })); | 1929 })); |
1930 } | 1930 } |
1931 if (remaining == 0 && !dart.notNull(eagerError)) { | 1931 if (remaining == 0 && !dart.notNull(eagerError)) { |
1932 result[_completeError](error, stackTrace); | 1932 result[_completeError](error, stackTrace); |
1933 } | 1933 } |
1934 } | 1934 } |
1935 }, core.Object, [core.Object]), {onError: handleError}); | 1935 }, dart.dynamic, [core.Object]), {onError: handleError}); |
1936 } | 1936 } |
1937 if (remaining == 0) { | 1937 if (remaining == 0) { |
1938 return Future$(core.List).value(dart.const([])); | 1938 return Future$(core.List).value(dart.const([])); |
1939 } | 1939 } |
1940 values = core.List.new(remaining); | 1940 values = core.List.new(remaining); |
1941 return result; | 1941 return result; |
1942 } | 1942 } |
1943 static forEach(input, f) { | 1943 static forEach(input, f) { |
1944 dart.as(f, dart.functionType(core.Object, [dart.bottom])); | 1944 dart.as(f, dart.functionType(dart.dynamic, [dart.dynamic])); |
1945 let iterator = input[dartx.iterator]; | 1945 let iterator = input[dartx.iterator]; |
1946 return Future$().doWhile(dart.fn(() => { | 1946 return Future$().doWhile(dart.fn(() => { |
1947 if (!dart.notNull(iterator.moveNext())) | 1947 if (!dart.notNull(iterator.moveNext())) |
1948 return false; | 1948 return false; |
1949 return Future$().sync(dart.fn(() => dart.dcall(f, iterator.current))).
then(dart.fn(_ => true, core.bool, [core.Object])); | 1949 return Future$().sync(dart.fn(() => dart.dcall(f, iterator.current))).
then(dart.fn(_ => true, core.bool, [dart.dynamic])); |
1950 })); | 1950 })); |
1951 } | 1951 } |
1952 static doWhile(f) { | 1952 static doWhile(f) { |
1953 dart.as(f, dart.functionType(core.Object, [])); | 1953 dart.as(f, dart.functionType(dart.dynamic, [])); |
1954 let doneSignal = new _Future(); | 1954 let doneSignal = new _Future(); |
1955 let nextIteration = null; | 1955 let nextIteration = null; |
1956 nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => { | 1956 nextIteration = Zone.current.bindUnaryCallback(dart.fn(keepGoing => { |
1957 if (dart.notNull(keepGoing)) { | 1957 if (dart.notNull(keepGoing)) { |
1958 Future$().sync(f).then(dart.as(nextIteration, __CastType4), {onError
: dart.bind(doneSignal, _completeError)}); | 1958 Future$().sync(f).then(dart.as(nextIteration, __CastType4), {onError
: dart.bind(doneSignal, _completeError)}); |
1959 } else { | 1959 } else { |
1960 doneSignal[_complete](null); | 1960 doneSignal[_complete](null); |
1961 } | 1961 } |
1962 }, core.Object, [core.bool]), {runGuarded: true}); | 1962 }, dart.dynamic, [core.bool]), {runGuarded: true}); |
1963 dart.dcall(nextIteration, true); | 1963 dart.dcall(nextIteration, true); |
1964 return doneSignal; | 1964 return doneSignal; |
1965 } | 1965 } |
1966 } | 1966 } |
1967 dart.setSignature(Future, { | 1967 dart.setSignature(Future, { |
1968 constructors: () => ({ | 1968 constructors: () => ({ |
1969 new: [Future$(T), [dart.functionType(core.Object, [])]], | 1969 new: [Future$(T), [dart.functionType(dart.dynamic, [])]], |
1970 microtask: [Future$(T), [dart.functionType(core.Object, [])]], | 1970 microtask: [Future$(T), [dart.functionType(dart.dynamic, [])]], |
1971 sync: [Future$(T), [dart.functionType(core.Object, [])]], | 1971 sync: [Future$(T), [dart.functionType(dart.dynamic, [])]], |
1972 value: [Future$(T), [], [core.Object]], | 1972 value: [Future$(T), [], [dart.dynamic]], |
1973 error: [Future$(T), [core.Object], [core.StackTrace]], | 1973 error: [Future$(T), [core.Object], [core.StackTrace]], |
1974 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]] | 1974 delayed: [Future$(T), [core.Duration], [dart.functionType(T, [])]] |
1975 }), | 1975 }), |
1976 statics: () => ({ | 1976 statics: () => ({ |
1977 wait: [Future$(core.List), [core.Iterable$(Future$())], {eagerError: cor
e.bool, cleanUp: dart.functionType(dart.void, [dart.bottom])}], | 1977 wait: [Future$(core.List), [core.Iterable$(Future$())], {eagerError: cor
e.bool, cleanUp: dart.functionType(dart.void, [dart.dynamic])}], |
1978 forEach: [Future$(), [core.Iterable, dart.functionType(core.Object, [dar
t.bottom])]], | 1978 forEach: [Future$(), [core.Iterable, dart.functionType(dart.dynamic, [da
rt.dynamic])]], |
1979 doWhile: [Future$(), [dart.functionType(core.Object, [])]] | 1979 doWhile: [Future$(), [dart.functionType(dart.dynamic, [])]] |
1980 }), | 1980 }), |
1981 names: ['wait', 'forEach', 'doWhile'] | 1981 names: ['wait', 'forEach', 'doWhile'] |
1982 }); | 1982 }); |
1983 return Future; | 1983 return Future; |
1984 }); | 1984 }); |
1985 let Future = Future$(); | 1985 let Future = Future$(); |
1986 dart.defineLazyProperties(Future, { | 1986 dart.defineLazyProperties(Future, { |
1987 get _nullFuture() { | 1987 get _nullFuture() { |
1988 return new _Future.immediate(null); | 1988 return new _Future.immediate(null); |
1989 } | 1989 } |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2027 }); | 2027 }); |
2028 let Completer = Completer$(); | 2028 let Completer = Completer$(); |
2029 function _completeWithErrorCallback(result, error, stackTrace) { | 2029 function _completeWithErrorCallback(result, error, stackTrace) { |
2030 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); | 2030 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); |
2031 if (replacement != null) { | 2031 if (replacement != null) { |
2032 error = _nonNullError(replacement.error); | 2032 error = _nonNullError(replacement.error); |
2033 stackTrace = replacement.stackTrace; | 2033 stackTrace = replacement.stackTrace; |
2034 } | 2034 } |
2035 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 2035 result[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
2036 } | 2036 } |
2037 dart.fn(_completeWithErrorCallback, () => dart.functionType(dart.void, [_Futur
e, core.Object, core.Object])); | 2037 dart.fn(_completeWithErrorCallback, () => dart.definiteFunctionType(dart.void,
[_Future, dart.dynamic, dart.dynamic])); |
2038 function _nonNullError(error) { | 2038 function _nonNullError(error) { |
2039 return error != null ? error : new core.NullThrownError(); | 2039 return error != null ? error : new core.NullThrownError(); |
2040 } | 2040 } |
2041 dart.fn(_nonNullError, core.Object, [core.Object]); | 2041 dart.fn(_nonNullError, core.Object, [core.Object]); |
2042 let __CastType4 = dart.typedef('__CastType4', () => dart.functionType(core.Obj
ect, [dart.bottom])); | 2042 let __CastType4 = dart.typedef('__CastType4', () => dart.functionType(dart.dyn
amic, [dart.dynamic])); |
2043 let _FutureOnValue$ = dart.generic(function(T) { | 2043 let _FutureOnValue$ = dart.generic(function(T) { |
2044 let _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionType(
core.Object, [T])); | 2044 let _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionType(
dart.dynamic, [T])); |
2045 return _FutureOnValue; | 2045 return _FutureOnValue; |
2046 }); | 2046 }); |
2047 let _FutureOnValue = _FutureOnValue$(); | 2047 let _FutureOnValue = _FutureOnValue$(); |
2048 let _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionTyp
e(core.bool, [dart.bottom])); | 2048 let _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionTyp
e(core.bool, [dart.dynamic])); |
2049 let _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(core
.Object, [])); | 2049 let _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(dart
.dynamic, [])); |
2050 let _Completer$ = dart.generic(function(T) { | 2050 let _Completer$ = dart.generic(function(T) { |
2051 class _Completer extends core.Object { | 2051 class _Completer extends core.Object { |
2052 _Completer() { | 2052 _Completer() { |
2053 this.future = new (_Future$(T))(); | 2053 this.future = new (_Future$(T))(); |
2054 } | 2054 } |
2055 completeError(error, stackTrace) { | 2055 completeError(error, stackTrace) { |
2056 if (stackTrace === void 0) | 2056 if (stackTrace === void 0) |
2057 stackTrace = null; | 2057 stackTrace = null; |
2058 error = _nonNullError(error); | 2058 error = _nonNullError(error); |
2059 if (!dart.notNull(this.future[_mayComplete])) | 2059 if (!dart.notNull(this.future[_mayComplete])) |
(...skipping 28 matching lines...) Expand all Loading... |
2088 if (!dart.notNull(this.future[_mayComplete])) | 2088 if (!dart.notNull(this.future[_mayComplete])) |
2089 throw new core.StateError("Future already completed"); | 2089 throw new core.StateError("Future already completed"); |
2090 this.future[_asyncComplete](value); | 2090 this.future[_asyncComplete](value); |
2091 } | 2091 } |
2092 [_completeError](error, stackTrace) { | 2092 [_completeError](error, stackTrace) { |
2093 this.future[_asyncCompleteError](error, stackTrace); | 2093 this.future[_asyncCompleteError](error, stackTrace); |
2094 } | 2094 } |
2095 } | 2095 } |
2096 dart.setSignature(_AsyncCompleter, { | 2096 dart.setSignature(_AsyncCompleter, { |
2097 methods: () => ({ | 2097 methods: () => ({ |
2098 complete: [dart.void, [], [core.Object]], | 2098 complete: [dart.void, [], [dart.dynamic]], |
2099 [_completeError]: [dart.void, [core.Object, core.StackTrace]] | 2099 [_completeError]: [dart.void, [core.Object, core.StackTrace]] |
2100 }) | 2100 }) |
2101 }); | 2101 }); |
2102 return _AsyncCompleter; | 2102 return _AsyncCompleter; |
2103 }); | 2103 }); |
2104 let _AsyncCompleter = _AsyncCompleter$(); | 2104 let _AsyncCompleter = _AsyncCompleter$(); |
2105 let _SyncCompleter$ = dart.generic(function(T) { | 2105 let _SyncCompleter$ = dart.generic(function(T) { |
2106 class _SyncCompleter extends _Completer$(T) { | 2106 class _SyncCompleter extends _Completer$(T) { |
2107 _SyncCompleter() { | 2107 _SyncCompleter() { |
2108 super._Completer(); | 2108 super._Completer(); |
2109 } | 2109 } |
2110 complete(value) { | 2110 complete(value) { |
2111 if (value === void 0) | 2111 if (value === void 0) |
2112 value = null; | 2112 value = null; |
2113 if (!dart.notNull(this.future[_mayComplete])) | 2113 if (!dart.notNull(this.future[_mayComplete])) |
2114 throw new core.StateError("Future already completed"); | 2114 throw new core.StateError("Future already completed"); |
2115 this.future[_complete](value); | 2115 this.future[_complete](value); |
2116 } | 2116 } |
2117 [_completeError](error, stackTrace) { | 2117 [_completeError](error, stackTrace) { |
2118 this.future[_completeError](error, stackTrace); | 2118 this.future[_completeError](error, stackTrace); |
2119 } | 2119 } |
2120 } | 2120 } |
2121 dart.setSignature(_SyncCompleter, { | 2121 dart.setSignature(_SyncCompleter, { |
2122 methods: () => ({ | 2122 methods: () => ({ |
2123 complete: [dart.void, [], [core.Object]], | 2123 complete: [dart.void, [], [dart.dynamic]], |
2124 [_completeError]: [dart.void, [core.Object, core.StackTrace]] | 2124 [_completeError]: [dart.void, [core.Object, core.StackTrace]] |
2125 }) | 2125 }) |
2126 }); | 2126 }); |
2127 return _SyncCompleter; | 2127 return _SyncCompleter; |
2128 }); | 2128 }); |
2129 let _SyncCompleter = _SyncCompleter$(); | 2129 let _SyncCompleter = _SyncCompleter$(); |
2130 let _nextListener = Symbol('_nextListener'); | 2130 let _nextListener = Symbol('_nextListener'); |
2131 let _onValue = Symbol('_onValue'); | 2131 let _onValue = Symbol('_onValue'); |
2132 let _errorTest = Symbol('_errorTest'); | 2132 let _errorTest = Symbol('_errorTest'); |
2133 let _whenCompleteAction = Symbol('_whenCompleteAction'); | 2133 let _whenCompleteAction = Symbol('_whenCompleteAction'); |
(...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2264 set [_isChained](value) { | 2264 set [_isChained](value) { |
2265 if (dart.notNull(value)) { | 2265 if (dart.notNull(value)) { |
2266 dart.assert(!dart.notNull(this[_isComplete])); | 2266 dart.assert(!dart.notNull(this[_isComplete])); |
2267 this[_state] = _Future$()._CHAINED; | 2267 this[_state] = _Future$()._CHAINED; |
2268 } else { | 2268 } else { |
2269 dart.assert(this[_isChained]); | 2269 dart.assert(this[_isChained]); |
2270 this[_state] = _Future$()._INCOMPLETE; | 2270 this[_state] = _Future$()._INCOMPLETE; |
2271 } | 2271 } |
2272 } | 2272 } |
2273 then(f, opts) { | 2273 then(f, opts) { |
2274 dart.as(f, dart.functionType(core.Object, [T])); | 2274 dart.as(f, dart.functionType(dart.dynamic, [T])); |
2275 let onError = opts && 'onError' in opts ? opts.onError : null; | 2275 let onError = opts && 'onError' in opts ? opts.onError : null; |
2276 let result = new (_Future$())(); | 2276 let result = new (_Future$())(); |
2277 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2277 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
2278 f = dart.as(result[_zone].registerUnaryCallback(f), __CastType6); | 2278 f = dart.as(result[_zone].registerUnaryCallback(f), __CastType6); |
2279 if (onError != null) { | 2279 if (onError != null) { |
2280 onError = _registerErrorHandler(onError, result[_zone]); | 2280 onError = _registerErrorHandler(onError, result[_zone]); |
2281 } | 2281 } |
2282 } | 2282 } |
2283 this[_addListener](new _FutureListener.then(result, f, onError)); | 2283 this[_addListener](new _FutureListener.then(result, f, onError)); |
2284 return result; | 2284 return result; |
2285 } | 2285 } |
2286 catchError(onError, opts) { | 2286 catchError(onError, opts) { |
2287 let test = opts && 'test' in opts ? opts.test : null; | 2287 let test = opts && 'test' in opts ? opts.test : null; |
2288 dart.as(test, dart.functionType(core.bool, [dart.bottom])); | 2288 dart.as(test, dart.functionType(core.bool, [dart.dynamic])); |
2289 let result = new (_Future$())(); | 2289 let result = new (_Future$())(); |
2290 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2290 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
2291 onError = _registerErrorHandler(onError, result[_zone]); | 2291 onError = _registerErrorHandler(onError, result[_zone]); |
2292 if (test != null) | 2292 if (test != null) |
2293 test = dart.as(result[_zone].registerUnaryCallback(test), __CastType
8); | 2293 test = dart.as(result[_zone].registerUnaryCallback(test), __CastType
8); |
2294 } | 2294 } |
2295 this[_addListener](new _FutureListener.catchError(result, onError, test)
); | 2295 this[_addListener](new _FutureListener.catchError(result, onError, test)
); |
2296 return result; | 2296 return result; |
2297 } | 2297 } |
2298 whenComplete(action) { | 2298 whenComplete(action) { |
2299 dart.as(action, dart.functionType(core.Object, [])); | 2299 dart.as(action, dart.functionType(dart.dynamic, [])); |
2300 let result = new (_Future$(T))(); | 2300 let result = new (_Future$(T))(); |
2301 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 2301 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
2302 action = result[_zone].registerCallback(action); | 2302 action = result[_zone].registerCallback(action); |
2303 } | 2303 } |
2304 this[_addListener](new _FutureListener.whenComplete(result, action)); | 2304 this[_addListener](new _FutureListener.whenComplete(result, action)); |
2305 return dart.as(result, Future$(T)); | 2305 return dart.as(result, Future$(T)); |
2306 } | 2306 } |
2307 asStream() { | 2307 asStream() { |
2308 return Stream$(T).fromFuture(this); | 2308 return Stream$(T).fromFuture(this); |
2309 } | 2309 } |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2363 dart.assert(!dart.is(source, _Future$())); | 2363 dart.assert(!dart.is(source, _Future$())); |
2364 target[_isChained] = true; | 2364 target[_isChained] = true; |
2365 source.then(dart.fn(value => { | 2365 source.then(dart.fn(value => { |
2366 dart.assert(target[_isChained]); | 2366 dart.assert(target[_isChained]); |
2367 target[_completeWithValue](value); | 2367 target[_completeWithValue](value); |
2368 }), {onError: dart.fn((error, stackTrace) => { | 2368 }), {onError: dart.fn((error, stackTrace) => { |
2369 if (stackTrace === void 0) | 2369 if (stackTrace === void 0) |
2370 stackTrace = null; | 2370 stackTrace = null; |
2371 dart.assert(target[_isChained]); | 2371 dart.assert(target[_isChained]); |
2372 target[_completeError](error, dart.as(stackTrace, core.StackTrace)); | 2372 target[_completeError](error, dart.as(stackTrace, core.StackTrace)); |
2373 }, core.Object, [core.Object], [core.Object])}); | 2373 }, dart.dynamic, [dart.dynamic], [dart.dynamic])}); |
2374 } | 2374 } |
2375 static _chainCoreFuture(source, target) { | 2375 static _chainCoreFuture(source, target) { |
2376 dart.assert(!dart.notNull(target[_isComplete])); | 2376 dart.assert(!dart.notNull(target[_isComplete])); |
2377 dart.assert(dart.is(source, _Future$())); | 2377 dart.assert(dart.is(source, _Future$())); |
2378 target[_isChained] = true; | 2378 target[_isChained] = true; |
2379 let listener = new _FutureListener.chain(target); | 2379 let listener = new _FutureListener.chain(target); |
2380 if (dart.notNull(source[_isComplete])) { | 2380 if (dart.notNull(source[_isComplete])) { |
2381 _Future$()._propagateToListeners(source, listener); | 2381 _Future$()._propagateToListeners(source, listener); |
2382 } else { | 2382 } else { |
2383 source[_addListener](listener); | 2383 source[_addListener](listener); |
(...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2550 dart.dsend(completeResult, 'then', dart.fn(ignored => { | 2550 dart.dsend(completeResult, 'then', dart.fn(ignored => { |
2551 _Future$()._propagateToListeners(source, new _FutureListener.c
hain(result)); | 2551 _Future$()._propagateToListeners(source, new _FutureListener.c
hain(result)); |
2552 }), {onError: dart.fn((error, stackTrace) => { | 2552 }), {onError: dart.fn((error, stackTrace) => { |
2553 if (stackTrace === void 0) | 2553 if (stackTrace === void 0) |
2554 stackTrace = null; | 2554 stackTrace = null; |
2555 if (!dart.is(completeResult, _Future$())) { | 2555 if (!dart.is(completeResult, _Future$())) { |
2556 completeResult = new (_Future$())(); | 2556 completeResult = new (_Future$())(); |
2557 dart.dsend(completeResult, _setError, error, stackTrace); | 2557 dart.dsend(completeResult, _setError, error, stackTrace); |
2558 } | 2558 } |
2559 _Future$()._propagateToListeners(dart.as(completeResult, _Fu
ture$()), new _FutureListener.chain(result)); | 2559 _Future$()._propagateToListeners(dart.as(completeResult, _Fu
ture$()), new _FutureListener.chain(result)); |
2560 }, core.Object, [core.Object], [core.Object])}); | 2560 }, dart.dynamic, [dart.dynamic], [dart.dynamic])}); |
2561 } | 2561 } |
2562 }; | 2562 }; |
2563 dart.fn(handleWhenCompleteCallback, dart.void, []); | 2563 dart.fn(handleWhenCompleteCallback, dart.void, []); |
2564 if (!dart.notNull(hasError)) { | 2564 if (!dart.notNull(hasError)) { |
2565 if (dart.notNull(listener.handlesValue)) { | 2565 if (dart.notNull(listener.handlesValue)) { |
2566 listenerHasValue = handleValueCallback(); | 2566 listenerHasValue = handleValueCallback(); |
2567 } | 2567 } |
2568 } else { | 2568 } else { |
2569 handleError(); | 2569 handleError(); |
2570 } | 2570 } |
(...skipping 28 matching lines...) Expand all Loading... |
2599 result[_setValue](listenerValueOrError); | 2599 result[_setValue](listenerValueOrError); |
2600 } else { | 2600 } else { |
2601 let asyncError = dart.as(listenerValueOrError, AsyncError); | 2601 let asyncError = dart.as(listenerValueOrError, AsyncError); |
2602 result[_setErrorObject](asyncError); | 2602 result[_setErrorObject](asyncError); |
2603 } | 2603 } |
2604 source = result; | 2604 source = result; |
2605 } | 2605 } |
2606 } | 2606 } |
2607 timeout(timeLimit, opts) { | 2607 timeout(timeLimit, opts) { |
2608 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; | 2608 let onTimeout = opts && 'onTimeout' in opts ? opts.onTimeout : null; |
2609 dart.as(onTimeout, dart.functionType(core.Object, [])); | 2609 dart.as(onTimeout, dart.functionType(dart.dynamic, [])); |
2610 if (dart.notNull(this[_isComplete])) | 2610 if (dart.notNull(this[_isComplete])) |
2611 return new (_Future$()).immediate(this); | 2611 return new (_Future$()).immediate(this); |
2612 let result = new (_Future$())(); | 2612 let result = new (_Future$())(); |
2613 let timer = null; | 2613 let timer = null; |
2614 if (onTimeout == null) { | 2614 if (onTimeout == null) { |
2615 timer = Timer.new(timeLimit, dart.fn(() => { | 2615 timer = Timer.new(timeLimit, dart.fn(() => { |
2616 result[_completeError](new TimeoutException("Future not completed",
timeLimit)); | 2616 result[_completeError](new TimeoutException("Future not completed",
timeLimit)); |
2617 })); | 2617 })); |
2618 } else { | 2618 } else { |
2619 let zone = Zone.current; | 2619 let zone = Zone.current; |
2620 onTimeout = zone.registerCallback(onTimeout); | 2620 onTimeout = zone.registerCallback(onTimeout); |
2621 timer = Timer.new(timeLimit, dart.fn(() => { | 2621 timer = Timer.new(timeLimit, dart.fn(() => { |
2622 try { | 2622 try { |
2623 result[_complete](zone.run(onTimeout)); | 2623 result[_complete](zone.run(onTimeout)); |
2624 } catch (e) { | 2624 } catch (e) { |
2625 let s = dart.stackTrace(e); | 2625 let s = dart.stackTrace(e); |
2626 result[_completeError](e, s); | 2626 result[_completeError](e, s); |
2627 } | 2627 } |
2628 | 2628 |
2629 })); | 2629 })); |
2630 } | 2630 } |
2631 this.then(dart.fn(v => { | 2631 this.then(dart.fn(v => { |
2632 dart.as(v, T); | 2632 dart.as(v, T); |
2633 if (dart.notNull(timer.isActive)) { | 2633 if (dart.notNull(timer.isActive)) { |
2634 timer.cancel(); | 2634 timer.cancel(); |
2635 result[_completeWithValue](v); | 2635 result[_completeWithValue](v); |
2636 } | 2636 } |
2637 }, core.Object, [T]), {onError: dart.fn((e, s) => { | 2637 }, dart.dynamic, [T]), {onError: dart.fn((e, s) => { |
2638 if (dart.notNull(timer.isActive)) { | 2638 if (dart.notNull(timer.isActive)) { |
2639 timer.cancel(); | 2639 timer.cancel(); |
2640 result[_completeError](e, dart.as(s, core.StackTrace)); | 2640 result[_completeError](e, dart.as(s, core.StackTrace)); |
2641 } | 2641 } |
2642 })}); | 2642 })}); |
2643 return result; | 2643 return result; |
2644 } | 2644 } |
2645 } | 2645 } |
2646 _Future[dart.implements] = () => [Future$(T)]; | 2646 _Future[dart.implements] = () => [Future$(T)]; |
2647 dart.defineNamedConstructor(_Future, 'immediate'); | 2647 dart.defineNamedConstructor(_Future, 'immediate'); |
2648 dart.defineNamedConstructor(_Future, 'immediateError'); | 2648 dart.defineNamedConstructor(_Future, 'immediateError'); |
2649 dart.setSignature(_Future, { | 2649 dart.setSignature(_Future, { |
2650 constructors: () => ({ | 2650 constructors: () => ({ |
2651 _Future: [_Future$(T), []], | 2651 _Future: [_Future$(T), []], |
2652 immediate: [_Future$(T), [core.Object]], | 2652 immediate: [_Future$(T), [dart.dynamic]], |
2653 immediateError: [_Future$(T), [core.Object], [core.StackTrace]] | 2653 immediateError: [_Future$(T), [dart.dynamic], [core.StackTrace]] |
2654 }), | 2654 }), |
2655 methods: () => ({ | 2655 methods: () => ({ |
2656 then: [Future, [dart.functionType(core.Object, [T])], {onError: core.Fun
ction}], | 2656 then: [Future, [dart.functionType(dart.dynamic, [T])], {onError: core.Fu
nction}], |
2657 catchError: [Future, [core.Function], {test: dart.functionType(core.bool
, [dart.bottom])}], | 2657 catchError: [Future, [core.Function], {test: dart.functionType(core.bool
, [dart.dynamic])}], |
2658 whenComplete: [Future$(T), [dart.functionType(core.Object, [])]], | 2658 whenComplete: [Future$(T), [dart.functionType(dart.dynamic, [])]], |
2659 asStream: [Stream$(T), []], | 2659 asStream: [Stream$(T), []], |
2660 [_markPendingCompletion]: [dart.void, []], | 2660 [_markPendingCompletion]: [dart.void, []], |
2661 [_setValue]: [dart.void, [T]], | 2661 [_setValue]: [dart.void, [T]], |
2662 [_setErrorObject]: [dart.void, [AsyncError]], | 2662 [_setErrorObject]: [dart.void, [AsyncError]], |
2663 [_setError]: [dart.void, [core.Object, core.StackTrace]], | 2663 [_setError]: [dart.void, [core.Object, core.StackTrace]], |
2664 [_addListener]: [dart.void, [_FutureListener]], | 2664 [_addListener]: [dart.void, [_FutureListener]], |
2665 [_removeListeners]: [_FutureListener, []], | 2665 [_removeListeners]: [_FutureListener, []], |
2666 [_complete]: [dart.void, [core.Object]], | 2666 [_complete]: [dart.void, [dart.dynamic]], |
2667 [_completeWithValue]: [dart.void, [core.Object]], | 2667 [_completeWithValue]: [dart.void, [dart.dynamic]], |
2668 [_completeError]: [dart.void, [core.Object], [core.StackTrace]], | 2668 [_completeError]: [dart.void, [dart.dynamic], [core.StackTrace]], |
2669 [_asyncComplete]: [dart.void, [core.Object]], | 2669 [_asyncComplete]: [dart.void, [dart.dynamic]], |
2670 [_asyncCompleteError]: [dart.void, [core.Object, core.StackTrace]], | 2670 [_asyncCompleteError]: [dart.void, [dart.dynamic, core.StackTrace]], |
2671 timeout: [Future, [core.Duration], {onTimeout: dart.functionType(core.Ob
ject, [])}] | 2671 timeout: [Future, [core.Duration], {onTimeout: dart.functionType(dart.dy
namic, [])}] |
2672 }), | 2672 }), |
2673 statics: () => ({ | 2673 statics: () => ({ |
2674 _chainForeignFuture: [dart.void, [Future, _Future$()]], | 2674 _chainForeignFuture: [dart.void, [Future, _Future$()]], |
2675 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]], | 2675 _chainCoreFuture: [dart.void, [_Future$(), _Future$()]], |
2676 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]] | 2676 _propagateToListeners: [dart.void, [_Future$(), _FutureListener]] |
2677 }), | 2677 }), |
2678 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] | 2678 names: ['_chainForeignFuture', '_chainCoreFuture', '_propagateToListeners'
] |
2679 }); | 2679 }); |
2680 return _Future; | 2680 return _Future; |
2681 }); | 2681 }); |
2682 let _Future = _Future$(); | 2682 let _Future = _Future$(); |
2683 _Future._INCOMPLETE = 0; | 2683 _Future._INCOMPLETE = 0; |
2684 _Future._PENDING_COMPLETE = 1; | 2684 _Future._PENDING_COMPLETE = 1; |
2685 _Future._CHAINED = 2; | 2685 _Future._CHAINED = 2; |
2686 _Future._VALUE = 4; | 2686 _Future._VALUE = 4; |
2687 _Future._ERROR = 8; | 2687 _Future._ERROR = 8; |
2688 let __CastType6$ = dart.generic(function(T) { | 2688 let __CastType6$ = dart.generic(function(T) { |
2689 let __CastType6 = dart.typedef('__CastType6', () => dart.functionType(core.O
bject, [T])); | 2689 let __CastType6 = dart.typedef('__CastType6', () => dart.functionType(dart.d
ynamic, [T])); |
2690 return __CastType6; | 2690 return __CastType6; |
2691 }); | 2691 }); |
2692 let __CastType6 = __CastType6$(); | 2692 let __CastType6 = __CastType6$(); |
2693 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo
l, [dart.bottom])); | 2693 let __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.boo
l, [dart.dynamic])); |
2694 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(core.O
bject, [dart.bottom])); | 2694 let __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
2695 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da
rt.void, [])); | 2695 let _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(da
rt.void, [])); |
2696 class _AsyncCallbackEntry extends core.Object { | 2696 class _AsyncCallbackEntry extends core.Object { |
2697 _AsyncCallbackEntry(callback) { | 2697 _AsyncCallbackEntry(callback) { |
2698 this.callback = callback; | 2698 this.callback = callback; |
2699 this.next = null; | 2699 this.next = null; |
2700 } | 2700 } |
2701 } | 2701 } |
2702 dart.setSignature(_AsyncCallbackEntry, { | 2702 dart.setSignature(_AsyncCallbackEntry, { |
2703 constructors: () => ({_AsyncCallbackEntry: [_AsyncCallbackEntry, [_AsyncCall
back]]}) | 2703 constructors: () => ({_AsyncCallbackEntry: [_AsyncCallbackEntry, [_AsyncCall
back]]}) |
2704 }); | 2704 }); |
(...skipping 29 matching lines...) Expand all Loading... |
2734 exports._nextCallback = exports._lastCallback = new _AsyncCallbackEntry(da
rt.as(callback, _AsyncCallback)); | 2734 exports._nextCallback = exports._lastCallback = new _AsyncCallbackEntry(da
rt.as(callback, _AsyncCallback)); |
2735 if (!dart.notNull(exports._isInCallbackLoop)) { | 2735 if (!dart.notNull(exports._isInCallbackLoop)) { |
2736 _AsyncRun._scheduleImmediate(_asyncRunCallback); | 2736 _AsyncRun._scheduleImmediate(_asyncRunCallback); |
2737 } | 2737 } |
2738 } else { | 2738 } else { |
2739 let newEntry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); | 2739 let newEntry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); |
2740 exports._lastCallback.next = newEntry; | 2740 exports._lastCallback.next = newEntry; |
2741 exports._lastCallback = newEntry; | 2741 exports._lastCallback = newEntry; |
2742 } | 2742 } |
2743 } | 2743 } |
2744 dart.fn(_scheduleAsyncCallback, dart.void, [core.Object]); | 2744 dart.fn(_scheduleAsyncCallback, dart.void, [dart.dynamic]); |
2745 function _schedulePriorityAsyncCallback(callback) { | 2745 function _schedulePriorityAsyncCallback(callback) { |
2746 let entry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); | 2746 let entry = new _AsyncCallbackEntry(dart.as(callback, _AsyncCallback)); |
2747 if (exports._nextCallback == null) { | 2747 if (exports._nextCallback == null) { |
2748 _scheduleAsyncCallback(callback); | 2748 _scheduleAsyncCallback(callback); |
2749 exports._lastPriorityCallback = exports._lastCallback; | 2749 exports._lastPriorityCallback = exports._lastCallback; |
2750 } else if (exports._lastPriorityCallback == null) { | 2750 } else if (exports._lastPriorityCallback == null) { |
2751 entry.next = exports._nextCallback; | 2751 entry.next = exports._nextCallback; |
2752 exports._nextCallback = exports._lastPriorityCallback = entry; | 2752 exports._nextCallback = exports._lastPriorityCallback = entry; |
2753 } else { | 2753 } else { |
2754 entry.next = exports._lastPriorityCallback.next; | 2754 entry.next = exports._lastPriorityCallback.next; |
2755 exports._lastPriorityCallback.next = entry; | 2755 exports._lastPriorityCallback.next = entry; |
2756 exports._lastPriorityCallback = entry; | 2756 exports._lastPriorityCallback = entry; |
2757 if (entry.next == null) { | 2757 if (entry.next == null) { |
2758 exports._lastCallback = entry; | 2758 exports._lastCallback = entry; |
2759 } | 2759 } |
2760 } | 2760 } |
2761 } | 2761 } |
2762 dart.fn(_schedulePriorityAsyncCallback, dart.void, [core.Object]); | 2762 dart.fn(_schedulePriorityAsyncCallback, dart.void, [dart.dynamic]); |
2763 function scheduleMicrotask(callback) { | 2763 function scheduleMicrotask(callback) { |
2764 if (dart.notNull(core.identical(_ROOT_ZONE, Zone.current))) { | 2764 if (dart.notNull(core.identical(_ROOT_ZONE, Zone.current))) { |
2765 _rootScheduleMicrotask(null, null, _ROOT_ZONE, callback); | 2765 _rootScheduleMicrotask(null, null, _ROOT_ZONE, callback); |
2766 return; | 2766 return; |
2767 } | 2767 } |
2768 Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuard
ed: true})); | 2768 Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuard
ed: true})); |
2769 } | 2769 } |
2770 dart.fn(scheduleMicrotask, dart.void, [dart.functionType(dart.void, [])]); | 2770 dart.fn(scheduleMicrotask, dart.void, [dart.functionType(dart.void, [])]); |
2771 class _AsyncRun extends core.Object { | 2771 class _AsyncRun extends core.Object { |
2772 static _scheduleImmediate(callback) { | 2772 static _scheduleImmediate(callback) { |
(...skipping 15 matching lines...) Expand all Loading... |
2788 }; | 2788 }; |
2789 dart.fn(internalCallback); | 2789 dart.fn(internalCallback); |
2790 ; | 2790 ; |
2791 let observer = new self.MutationObserver(_js_helper.convertDartClosureTo
JS(internalCallback, 1)); | 2791 let observer = new self.MutationObserver(_js_helper.convertDartClosureTo
JS(internalCallback, 1)); |
2792 observer.observe(div, {childList: true}); | 2792 observer.observe(div, {childList: true}); |
2793 return dart.fn(callback => { | 2793 return dart.fn(callback => { |
2794 dart.assert(storedCallback == null); | 2794 dart.assert(storedCallback == null); |
2795 _isolate_helper.enterJsAsync(); | 2795 _isolate_helper.enterJsAsync(); |
2796 storedCallback = callback; | 2796 storedCallback = callback; |
2797 div.firstChild ? div.removeChild(span) : div.appendChild(span); | 2797 div.firstChild ? div.removeChild(span) : div.appendChild(span); |
2798 }, core.Object, [dart.functionType(dart.void, [])]); | 2798 }, dart.dynamic, [dart.functionType(dart.void, [])]); |
2799 } else if (self.setImmediate != null) { | 2799 } else if (self.setImmediate != null) { |
2800 return _AsyncRun._scheduleImmediateWithSetImmediate; | 2800 return _AsyncRun._scheduleImmediateWithSetImmediate; |
2801 } | 2801 } |
2802 return _AsyncRun._scheduleImmediateWithTimer; | 2802 return _AsyncRun._scheduleImmediateWithTimer; |
2803 } | 2803 } |
2804 static _scheduleImmediateJsOverride(callback) { | 2804 static _scheduleImmediateJsOverride(callback) { |
2805 let internalCallback = () => { | 2805 let internalCallback = () => { |
2806 _isolate_helper.leaveJsAsync(); | 2806 _isolate_helper.leaveJsAsync(); |
2807 callback(); | 2807 callback(); |
2808 }; | 2808 }; |
(...skipping 135 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2944 } | 2944 } |
2945 close() { | 2945 close() { |
2946 this[_sink].close(); | 2946 this[_sink].close(); |
2947 } | 2947 } |
2948 } | 2948 } |
2949 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; | 2949 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)]; |
2950 dart.setSignature(_ControllerEventSinkWrapper, { | 2950 dart.setSignature(_ControllerEventSinkWrapper, { |
2951 constructors: () => ({_ControllerEventSinkWrapper: [_ControllerEventSinkWr
apper$(T), [EventSink]]}), | 2951 constructors: () => ({_ControllerEventSinkWrapper: [_ControllerEventSinkWr
apper$(T), [EventSink]]}), |
2952 methods: () => ({ | 2952 methods: () => ({ |
2953 add: [dart.void, [T]], | 2953 add: [dart.void, [T]], |
2954 addError: [dart.void, [core.Object], [core.StackTrace]], | 2954 addError: [dart.void, [dart.dynamic], [core.StackTrace]], |
2955 close: [dart.void, []] | 2955 close: [dart.void, []] |
2956 }) | 2956 }) |
2957 }); | 2957 }); |
2958 return _ControllerEventSinkWrapper; | 2958 return _ControllerEventSinkWrapper; |
2959 }); | 2959 }); |
2960 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); | 2960 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(); |
2961 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v
oid, [StreamSubscription])); | 2961 let __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.v
oid, [StreamSubscription])); |
2962 let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(core.O
bject, [dart.bottom, core.StackTrace])); | 2962 let __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart.d
ynamic, [dart.dynamic, core.StackTrace])); |
2963 let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.v
oid, [])); | 2963 let __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.v
oid, [])); |
2964 let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.v
oid, [EventSink])); | 2964 let __CastType18 = dart.typedef('__CastType18', () => dart.functionType(dart.v
oid, [EventSink])); |
2965 let StreamController$ = dart.generic(function(T) { | 2965 let StreamController$ = dart.generic(function(T) { |
2966 class StreamController extends core.Object { | 2966 class StreamController extends core.Object { |
2967 static new(opts) { | 2967 static new(opts) { |
2968 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2968 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
2969 let onPause = opts && 'onPause' in opts ? opts.onPause : null; | 2969 let onPause = opts && 'onPause' in opts ? opts.onPause : null; |
2970 let onResume = opts && 'onResume' in opts ? opts.onResume : null; | 2970 let onResume = opts && 'onResume' in opts ? opts.onResume : null; |
2971 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2971 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
2972 let sync = opts && 'sync' in opts ? opts.sync : false; | 2972 let sync = opts && 'sync' in opts ? opts.sync : false; |
2973 if (onListen == null && onPause == null && onResume == null && onCancel
== null) { | 2973 if (onListen == null && onPause == null && onResume == null && onCancel
== null) { |
2974 return dart.as(dart.notNull(sync) ? new _NoCallbackSyncStreamControlle
r() : new _NoCallbackAsyncStreamController(), StreamController$(T)); | 2974 return dart.as(dart.notNull(sync) ? new _NoCallbackSyncStreamControlle
r() : new _NoCallbackAsyncStreamController(), StreamController$(T)); |
2975 } | 2975 } |
2976 return dart.notNull(sync) ? new (_SyncStreamController$(T))(onListen, on
Pause, onResume, onCancel) : new (_AsyncStreamController$(T))(onListen, onPause,
onResume, onCancel); | 2976 return dart.notNull(sync) ? new (_SyncStreamController$(T))(onListen, on
Pause, onResume, onCancel) : new (_AsyncStreamController$(T))(onListen, onPause,
onResume, onCancel); |
2977 } | 2977 } |
2978 static broadcast(opts) { | 2978 static broadcast(opts) { |
2979 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 2979 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
2980 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 2980 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
2981 let sync = opts && 'sync' in opts ? opts.sync : false; | 2981 let sync = opts && 'sync' in opts ? opts.sync : false; |
2982 return dart.notNull(sync) ? new (_SyncBroadcastStreamController$(T))(onL
isten, onCancel) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel)
; | 2982 return dart.notNull(sync) ? new (_SyncBroadcastStreamController$(T))(onL
isten, onCancel) : new (_AsyncBroadcastStreamController$(T))(onListen, onCancel)
; |
2983 } | 2983 } |
2984 } | 2984 } |
2985 StreamController[dart.implements] = () => [StreamSink$(T)]; | 2985 StreamController[dart.implements] = () => [StreamSink$(T)]; |
2986 dart.setSignature(StreamController, { | 2986 dart.setSignature(StreamController, { |
2987 constructors: () => ({ | 2987 constructors: () => ({ |
2988 new: [StreamController$(T), [], {onListen: dart.functionType(dart.void,
[]), onPause: dart.functionType(dart.void, []), onResume: dart.functionType(dart
.void, []), onCancel: dart.functionType(core.Object, []), sync: core.bool}], | 2988 new: [StreamController$(T), [], {onListen: dart.functionType(dart.void,
[]), onPause: dart.functionType(dart.void, []), onResume: dart.functionType(dart
.void, []), onCancel: dart.functionType(dart.dynamic, []), sync: core.bool}], |
2989 broadcast: [StreamController$(T), [], {onListen: dart.functionType(dart.
void, []), onCancel: dart.functionType(dart.void, []), sync: core.bool}] | 2989 broadcast: [StreamController$(T), [], {onListen: dart.functionType(dart.
void, []), onCancel: dart.functionType(dart.void, []), sync: core.bool}] |
2990 }) | 2990 }) |
2991 }); | 2991 }); |
2992 return StreamController; | 2992 return StreamController; |
2993 }); | 2993 }); |
2994 let StreamController = StreamController$(); | 2994 let StreamController = StreamController$(); |
2995 let _StreamControllerLifecycle$ = dart.generic(function(T) { | 2995 let _StreamControllerLifecycle$ = dart.generic(function(T) { |
2996 class _StreamControllerLifecycle extends core.Object { | 2996 class _StreamControllerLifecycle extends core.Object { |
2997 [_recordPause](subscription) { | 2997 [_recordPause](subscription) { |
2998 dart.as(subscription, StreamSubscription$(T)); | 2998 dart.as(subscription, StreamSubscription$(T)); |
(...skipping 327 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3326 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { | 3326 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn
cStreamControllerDispatch$(T)) { |
3327 _AsyncStreamController(onListen, onPause, onResume, onCancel) { | 3327 _AsyncStreamController(onListen, onPause, onResume, onCancel) { |
3328 this[_onListen] = onListen; | 3328 this[_onListen] = onListen; |
3329 this[_onPause] = onPause; | 3329 this[_onPause] = onPause; |
3330 this[_onResume] = onResume; | 3330 this[_onResume] = onResume; |
3331 this[_onCancel] = onCancel; | 3331 this[_onCancel] = onCancel; |
3332 super._StreamController(); | 3332 super._StreamController(); |
3333 } | 3333 } |
3334 } | 3334 } |
3335 dart.setSignature(_AsyncStreamController, { | 3335 dart.setSignature(_AsyncStreamController, { |
3336 constructors: () => ({_AsyncStreamController: [_AsyncStreamController$(T),
[dart.functionType(dart.void, []), dart.functionType(dart.void, []), dart.funct
ionType(dart.void, []), dart.functionType(core.Object, [])]]}) | 3336 constructors: () => ({_AsyncStreamController: [_AsyncStreamController$(T),
[dart.functionType(dart.void, []), dart.functionType(dart.void, []), dart.funct
ionType(dart.void, []), dart.functionType(dart.dynamic, [])]]}) |
3337 }); | 3337 }); |
3338 return _AsyncStreamController; | 3338 return _AsyncStreamController; |
3339 }); | 3339 }); |
3340 let _AsyncStreamController = _AsyncStreamController$(); | 3340 let _AsyncStreamController = _AsyncStreamController$(); |
3341 let _SyncStreamController$ = dart.generic(function(T) { | 3341 let _SyncStreamController$ = dart.generic(function(T) { |
3342 class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncS
treamControllerDispatch$(T)) { | 3342 class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncS
treamControllerDispatch$(T)) { |
3343 _SyncStreamController(onListen, onPause, onResume, onCancel) { | 3343 _SyncStreamController(onListen, onPause, onResume, onCancel) { |
3344 this[_onListen] = onListen; | 3344 this[_onListen] = onListen; |
3345 this[_onPause] = onPause; | 3345 this[_onPause] = onPause; |
3346 this[_onResume] = onResume; | 3346 this[_onResume] = onResume; |
3347 this[_onCancel] = onCancel; | 3347 this[_onCancel] = onCancel; |
3348 super._StreamController(); | 3348 super._StreamController(); |
3349 } | 3349 } |
3350 } | 3350 } |
3351 dart.setSignature(_SyncStreamController, { | 3351 dart.setSignature(_SyncStreamController, { |
3352 constructors: () => ({_SyncStreamController: [_SyncStreamController$(T), [
dart.functionType(dart.void, []), dart.functionType(dart.void, []), dart.functio
nType(dart.void, []), dart.functionType(core.Object, [])]]}) | 3352 constructors: () => ({_SyncStreamController: [_SyncStreamController$(T), [
dart.functionType(dart.void, []), dart.functionType(dart.void, []), dart.functio
nType(dart.void, []), dart.functionType(dart.dynamic, [])]]}) |
3353 }); | 3353 }); |
3354 return _SyncStreamController; | 3354 return _SyncStreamController; |
3355 }); | 3355 }); |
3356 let _SyncStreamController = _SyncStreamController$(); | 3356 let _SyncStreamController = _SyncStreamController$(); |
3357 class _NoCallbacks extends core.Object { | 3357 class _NoCallbacks extends core.Object { |
3358 get [_onListen]() { | 3358 get [_onListen]() { |
3359 return null; | 3359 return null; |
3360 } | 3360 } |
3361 get [_onPause]() { | 3361 get [_onPause]() { |
3362 return null; | 3362 return null; |
3363 } | 3363 } |
3364 get [_onResume]() { | 3364 get [_onResume]() { |
3365 return null; | 3365 return null; |
3366 } | 3366 } |
3367 get [_onCancel]() { | 3367 get [_onCancel]() { |
3368 return null; | 3368 return null; |
3369 } | 3369 } |
3370 } | 3370 } |
3371 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _
AsyncStreamControllerDispatch, _NoCallbacks) {} | 3371 class _NoCallbackAsyncStreamController extends dart.mixin(_StreamController, _
AsyncStreamControllerDispatch, _NoCallbacks) {} |
3372 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S
yncStreamControllerDispatch, _NoCallbacks) {} | 3372 class _NoCallbackSyncStreamController extends dart.mixin(_StreamController, _S
yncStreamControllerDispatch, _NoCallbacks) {} |
3373 let _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.fun
ctionType(core.Object, [])); | 3373 let _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.fun
ctionType(dart.dynamic, [])); |
3374 function _runGuarded(notificationHandler) { | 3374 function _runGuarded(notificationHandler) { |
3375 if (notificationHandler == null) | 3375 if (notificationHandler == null) |
3376 return null; | 3376 return null; |
3377 try { | 3377 try { |
3378 let result = notificationHandler(); | 3378 let result = notificationHandler(); |
3379 if (dart.is(result, Future)) | 3379 if (dart.is(result, Future)) |
3380 return dart.as(result, Future); | 3380 return dart.as(result, Future); |
3381 return null; | 3381 return null; |
3382 } catch (e) { | 3382 } catch (e) { |
3383 let s = dart.stackTrace(e); | 3383 let s = dart.stackTrace(e); |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3429 let _AddStreamState$ = dart.generic(function(T) { | 3429 let _AddStreamState$ = dart.generic(function(T) { |
3430 class _AddStreamState extends core.Object { | 3430 class _AddStreamState extends core.Object { |
3431 _AddStreamState(controller, source, cancelOnError) { | 3431 _AddStreamState(controller, source, cancelOnError) { |
3432 this.addStreamFuture = new _Future(); | 3432 this.addStreamFuture = new _Future(); |
3433 this.addSubscription = source.listen(dart.bind(controller, _add), {onErr
or: dart.notNull(cancelOnError) ? dart.as(_AddStreamState$().makeErrorHandler(co
ntroller), core.Function) : dart.bind(controller, _addError), onDone: dart.bind(
controller, _close), cancelOnError: cancelOnError}); | 3433 this.addSubscription = source.listen(dart.bind(controller, _add), {onErr
or: dart.notNull(cancelOnError) ? dart.as(_AddStreamState$().makeErrorHandler(co
ntroller), core.Function) : dart.bind(controller, _addError), onDone: dart.bind(
controller, _close), cancelOnError: cancelOnError}); |
3434 } | 3434 } |
3435 static makeErrorHandler(controller) { | 3435 static makeErrorHandler(controller) { |
3436 return dart.fn((e, s) => { | 3436 return dart.fn((e, s) => { |
3437 controller[_addError](e, s); | 3437 controller[_addError](e, s); |
3438 controller[_close](); | 3438 controller[_close](); |
3439 }, core.Object, [core.Object, core.StackTrace]); | 3439 }, dart.dynamic, [dart.dynamic, core.StackTrace]); |
3440 } | 3440 } |
3441 pause() { | 3441 pause() { |
3442 this.addSubscription.pause(); | 3442 this.addSubscription.pause(); |
3443 } | 3443 } |
3444 resume() { | 3444 resume() { |
3445 this.addSubscription.resume(); | 3445 this.addSubscription.resume(); |
3446 } | 3446 } |
3447 cancel() { | 3447 cancel() { |
3448 let cancel = this.addSubscription.cancel(); | 3448 let cancel = this.addSubscription.cancel(); |
3449 if (cancel == null) { | 3449 if (cancel == null) { |
3450 this.addStreamFuture[_asyncComplete](null); | 3450 this.addStreamFuture[_asyncComplete](null); |
3451 return null; | 3451 return null; |
3452 } | 3452 } |
3453 return cancel.whenComplete(dart.fn(() => { | 3453 return cancel.whenComplete(dart.fn(() => { |
3454 this.addStreamFuture[_asyncComplete](null); | 3454 this.addStreamFuture[_asyncComplete](null); |
3455 })); | 3455 })); |
3456 } | 3456 } |
3457 complete() { | 3457 complete() { |
3458 this.addStreamFuture[_asyncComplete](null); | 3458 this.addStreamFuture[_asyncComplete](null); |
3459 } | 3459 } |
3460 } | 3460 } |
3461 dart.setSignature(_AddStreamState, { | 3461 dart.setSignature(_AddStreamState, { |
3462 constructors: () => ({_AddStreamState: [_AddStreamState$(T), [_EventSink$(
T), Stream, core.bool]]}), | 3462 constructors: () => ({_AddStreamState: [_AddStreamState$(T), [_EventSink$(
T), Stream, core.bool]]}), |
3463 methods: () => ({ | 3463 methods: () => ({ |
3464 pause: [dart.void, []], | 3464 pause: [dart.void, []], |
3465 resume: [dart.void, []], | 3465 resume: [dart.void, []], |
3466 cancel: [Future, []], | 3466 cancel: [Future, []], |
3467 complete: [dart.void, []] | 3467 complete: [dart.void, []] |
3468 }), | 3468 }), |
3469 statics: () => ({makeErrorHandler: [core.Object, [_EventSink]]}), | 3469 statics: () => ({makeErrorHandler: [dart.dynamic, [_EventSink]]}), |
3470 names: ['makeErrorHandler'] | 3470 names: ['makeErrorHandler'] |
3471 }); | 3471 }); |
3472 return _AddStreamState; | 3472 return _AddStreamState; |
3473 }); | 3473 }); |
3474 let _AddStreamState = _AddStreamState$(); | 3474 let _AddStreamState = _AddStreamState$(); |
3475 let _StreamControllerAddStreamState$ = dart.generic(function(T) { | 3475 let _StreamControllerAddStreamState$ = dart.generic(function(T) { |
3476 class _StreamControllerAddStreamState extends _AddStreamState$(T) { | 3476 class _StreamControllerAddStreamState extends _AddStreamState$(T) { |
3477 _StreamControllerAddStreamState(controller, varData, source, cancelOnError
) { | 3477 _StreamControllerAddStreamState(controller, varData, source, cancelOnError
) { |
3478 this.varData = varData; | 3478 this.varData = varData; |
3479 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance
lOnError); | 3479 super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cance
lOnError); |
3480 if (dart.notNull(controller.isPaused)) { | 3480 if (dart.notNull(controller.isPaused)) { |
3481 this.addSubscription.pause(); | 3481 this.addSubscription.pause(); |
3482 } | 3482 } |
3483 } | 3483 } |
3484 } | 3484 } |
3485 dart.setSignature(_StreamControllerAddStreamState, { | 3485 dart.setSignature(_StreamControllerAddStreamState, { |
3486 constructors: () => ({_StreamControllerAddStreamState: [_StreamControllerA
ddStreamState$(T), [_StreamController, core.Object, Stream, core.bool]]}) | 3486 constructors: () => ({_StreamControllerAddStreamState: [_StreamControllerA
ddStreamState$(T), [_StreamController, dart.dynamic, Stream, core.bool]]}) |
3487 }); | 3487 }); |
3488 return _StreamControllerAddStreamState; | 3488 return _StreamControllerAddStreamState; |
3489 }); | 3489 }); |
3490 let _StreamControllerAddStreamState = _StreamControllerAddStreamState$(); | 3490 let _StreamControllerAddStreamState = _StreamControllerAddStreamState$(); |
3491 let _EventSink$ = dart.generic(function(T) { | 3491 let _EventSink$ = dart.generic(function(T) { |
3492 class _EventSink extends core.Object {} | 3492 class _EventSink extends core.Object {} |
3493 return _EventSink; | 3493 return _EventSink; |
3494 }); | 3494 }); |
3495 let _EventSink = _EventSink$(); | 3495 let _EventSink = _EventSink$(); |
3496 let _EventDispatch$ = dart.generic(function(T) { | 3496 let _EventDispatch$ = dart.generic(function(T) { |
(...skipping 126 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3623 }); | 3623 }); |
3624 let _IterablePendingEvents = _IterablePendingEvents$(); | 3624 let _IterablePendingEvents = _IterablePendingEvents$(); |
3625 let _DataHandler$ = dart.generic(function(T) { | 3625 let _DataHandler$ = dart.generic(function(T) { |
3626 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart
.void, [T])); | 3626 let _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart
.void, [T])); |
3627 return _DataHandler; | 3627 return _DataHandler; |
3628 }); | 3628 }); |
3629 let _DataHandler = _DataHandler$(); | 3629 let _DataHandler = _DataHandler$(); |
3630 let _DoneHandler = dart.typedef('_DoneHandler', () => dart.functionType(dart.v
oid, [])); | 3630 let _DoneHandler = dart.typedef('_DoneHandler', () => dart.functionType(dart.v
oid, [])); |
3631 function _nullDataHandler(value) { | 3631 function _nullDataHandler(value) { |
3632 } | 3632 } |
3633 dart.fn(_nullDataHandler, dart.void, [core.Object]); | 3633 dart.fn(_nullDataHandler, dart.void, [dart.dynamic]); |
3634 function _nullErrorHandler(error, stackTrace) { | 3634 function _nullErrorHandler(error, stackTrace) { |
3635 if (stackTrace === void 0) | 3635 if (stackTrace === void 0) |
3636 stackTrace = null; | 3636 stackTrace = null; |
3637 Zone.current.handleUncaughtError(error, stackTrace); | 3637 Zone.current.handleUncaughtError(error, stackTrace); |
3638 } | 3638 } |
3639 dart.fn(_nullErrorHandler, dart.void, [core.Object], [core.StackTrace]); | 3639 dart.fn(_nullErrorHandler, dart.void, [dart.dynamic], [core.StackTrace]); |
3640 function _nullDoneHandler() { | 3640 function _nullDoneHandler() { |
3641 } | 3641 } |
3642 dart.fn(_nullDoneHandler, dart.void, []); | 3642 dart.fn(_nullDoneHandler, dart.void, []); |
3643 let _DelayedEvent$ = dart.generic(function(T) { | 3643 let _DelayedEvent$ = dart.generic(function(T) { |
3644 class _DelayedEvent extends core.Object { | 3644 class _DelayedEvent extends core.Object { |
3645 _DelayedEvent() { | 3645 _DelayedEvent() { |
3646 this.next = null; | 3646 this.next = null; |
3647 } | 3647 } |
3648 } | 3648 } |
3649 return _DelayedEvent; | 3649 return _DelayedEvent; |
(...skipping 21 matching lines...) Expand all Loading... |
3671 _DelayedError(error, stackTrace) { | 3671 _DelayedError(error, stackTrace) { |
3672 this.error = error; | 3672 this.error = error; |
3673 this.stackTrace = stackTrace; | 3673 this.stackTrace = stackTrace; |
3674 super._DelayedEvent(); | 3674 super._DelayedEvent(); |
3675 } | 3675 } |
3676 perform(dispatch) { | 3676 perform(dispatch) { |
3677 dispatch[_sendError](this.error, this.stackTrace); | 3677 dispatch[_sendError](this.error, this.stackTrace); |
3678 } | 3678 } |
3679 } | 3679 } |
3680 dart.setSignature(_DelayedError, { | 3680 dart.setSignature(_DelayedError, { |
3681 constructors: () => ({_DelayedError: [_DelayedError, [core.Object, core.Stac
kTrace]]}), | 3681 constructors: () => ({_DelayedError: [_DelayedError, [dart.dynamic, core.Sta
ckTrace]]}), |
3682 methods: () => ({perform: [dart.void, [_EventDispatch]]}) | 3682 methods: () => ({perform: [dart.void, [_EventDispatch]]}) |
3683 }); | 3683 }); |
3684 class _DelayedDone extends core.Object { | 3684 class _DelayedDone extends core.Object { |
3685 _DelayedDone() { | 3685 _DelayedDone() { |
3686 } | 3686 } |
3687 perform(dispatch) { | 3687 perform(dispatch) { |
3688 dispatch[_sendDone](); | 3688 dispatch[_sendDone](); |
3689 } | 3689 } |
3690 get next() { | 3690 get next() { |
3691 return null; | 3691 return null; |
(...skipping 149 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3841 dart.setSignature(_DoneStreamSubscription, { | 3841 dart.setSignature(_DoneStreamSubscription, { |
3842 constructors: () => ({_DoneStreamSubscription: [_DoneStreamSubscription$(T
), [_DoneHandler]]}), | 3842 constructors: () => ({_DoneStreamSubscription: [_DoneStreamSubscription$(T
), [_DoneHandler]]}), |
3843 methods: () => ({ | 3843 methods: () => ({ |
3844 [_schedule]: [dart.void, []], | 3844 [_schedule]: [dart.void, []], |
3845 onData: [dart.void, [dart.functionType(dart.void, [T])]], | 3845 onData: [dart.void, [dart.functionType(dart.void, [T])]], |
3846 onError: [dart.void, [core.Function]], | 3846 onError: [dart.void, [core.Function]], |
3847 onDone: [dart.void, [dart.functionType(dart.void, [])]], | 3847 onDone: [dart.void, [dart.functionType(dart.void, [])]], |
3848 pause: [dart.void, [], [Future]], | 3848 pause: [dart.void, [], [Future]], |
3849 resume: [dart.void, []], | 3849 resume: [dart.void, []], |
3850 cancel: [Future, []], | 3850 cancel: [Future, []], |
3851 asFuture: [Future, [], [core.Object]], | 3851 asFuture: [Future, [], [dart.dynamic]], |
3852 [_sendDone]: [dart.void, []] | 3852 [_sendDone]: [dart.void, []] |
3853 }) | 3853 }) |
3854 }); | 3854 }); |
3855 return _DoneStreamSubscription; | 3855 return _DoneStreamSubscription; |
3856 }); | 3856 }); |
3857 let _DoneStreamSubscription = _DoneStreamSubscription$(); | 3857 let _DoneStreamSubscription = _DoneStreamSubscription$(); |
3858 _DoneStreamSubscription._DONE_SENT = 1; | 3858 _DoneStreamSubscription._DONE_SENT = 1; |
3859 _DoneStreamSubscription._SCHEDULED = 2; | 3859 _DoneStreamSubscription._SCHEDULED = 2; |
3860 _DoneStreamSubscription._PAUSED = 4; | 3860 _DoneStreamSubscription._PAUSED = 4; |
3861 let _source = Symbol('_source'); | 3861 let _source = Symbol('_source'); |
(...skipping 128 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3990 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; | 3990 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$(
T)]; |
3991 dart.setSignature(_BroadcastSubscriptionWrapper, { | 3991 dart.setSignature(_BroadcastSubscriptionWrapper, { |
3992 constructors: () => ({_BroadcastSubscriptionWrapper: [_BroadcastSubscripti
onWrapper$(T), [_AsBroadcastStream]]}), | 3992 constructors: () => ({_BroadcastSubscriptionWrapper: [_BroadcastSubscripti
onWrapper$(T), [_AsBroadcastStream]]}), |
3993 methods: () => ({ | 3993 methods: () => ({ |
3994 onData: [dart.void, [dart.functionType(dart.void, [T])]], | 3994 onData: [dart.void, [dart.functionType(dart.void, [T])]], |
3995 onError: [dart.void, [core.Function]], | 3995 onError: [dart.void, [core.Function]], |
3996 onDone: [dart.void, [dart.functionType(dart.void, [])]], | 3996 onDone: [dart.void, [dart.functionType(dart.void, [])]], |
3997 pause: [dart.void, [], [Future]], | 3997 pause: [dart.void, [], [Future]], |
3998 resume: [dart.void, []], | 3998 resume: [dart.void, []], |
3999 cancel: [Future, []], | 3999 cancel: [Future, []], |
4000 asFuture: [Future, [], [core.Object]] | 4000 asFuture: [Future, [], [dart.dynamic]] |
4001 }) | 4001 }) |
4002 }); | 4002 }); |
4003 return _BroadcastSubscriptionWrapper; | 4003 return _BroadcastSubscriptionWrapper; |
4004 }); | 4004 }); |
4005 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); | 4005 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(); |
4006 let _current = Symbol('_current'); | 4006 let _current = Symbol('_current'); |
4007 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); | 4007 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); |
4008 let _clear = Symbol('_clear'); | 4008 let _clear = Symbol('_clear'); |
4009 let _StreamIteratorImpl$ = dart.generic(function(T) { | 4009 let _StreamIteratorImpl$ = dart.generic(function(T) { |
4010 class _StreamIteratorImpl extends core.Object { | 4010 class _StreamIteratorImpl extends core.Object { |
(...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4132 _StreamIteratorImpl._STATE_DONE = 1; | 4132 _StreamIteratorImpl._STATE_DONE = 1; |
4133 _StreamIteratorImpl._STATE_MOVING = 2; | 4133 _StreamIteratorImpl._STATE_MOVING = 2; |
4134 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; | 4134 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; |
4135 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; | 4135 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; |
4136 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; | 4136 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; |
4137 let __CastType20$ = dart.generic(function(T) { | 4137 let __CastType20$ = dart.generic(function(T) { |
4138 let __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart
.void, [T])); | 4138 let __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart
.void, [T])); |
4139 return __CastType20; | 4139 return __CastType20; |
4140 }); | 4140 }); |
4141 let __CastType20 = __CastType20$(); | 4141 let __CastType20 = __CastType20$(); |
4142 let __CastType22 = dart.typedef('__CastType22', () => dart.functionType(core.O
bject, [dart.bottom, dart.bottom])); | 4142 let __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart.d
ynamic, [dart.dynamic, dart.dynamic])); |
4143 let __CastType25 = dart.typedef('__CastType25', () => dart.functionType(core.O
bject, [dart.bottom])); | 4143 let __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
4144 function _runUserCode(userCode, onSuccess, onError) { | 4144 function _runUserCode(userCode, onSuccess, onError) { |
4145 try { | 4145 try { |
4146 dart.dcall(onSuccess, userCode()); | 4146 dart.dcall(onSuccess, userCode()); |
4147 } catch (e) { | 4147 } catch (e) { |
4148 let s = dart.stackTrace(e); | 4148 let s = dart.stackTrace(e); |
4149 let replacement = Zone.current.errorCallback(e, s); | 4149 let replacement = Zone.current.errorCallback(e, s); |
4150 if (replacement == null) { | 4150 if (replacement == null) { |
4151 dart.dcall(onError, e, s); | 4151 dart.dcall(onError, e, s); |
4152 } else { | 4152 } else { |
4153 let error = _nonNullError(replacement.error); | 4153 let error = _nonNullError(replacement.error); |
4154 let stackTrace = replacement.stackTrace; | 4154 let stackTrace = replacement.stackTrace; |
4155 dart.dcall(onError, error, stackTrace); | 4155 dart.dcall(onError, error, stackTrace); |
4156 } | 4156 } |
4157 } | 4157 } |
4158 | 4158 |
4159 } | 4159 } |
4160 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])]); | 4160 dart.fn(_runUserCode, dart.dynamic, [dart.functionType(dart.dynamic, []), dart
.functionType(dart.dynamic, [dart.dynamic]), dart.functionType(dart.dynamic, [da
rt.dynamic, core.StackTrace])]); |
4161 function _cancelAndError(subscription, future, error, stackTrace) { | 4161 function _cancelAndError(subscription, future, error, stackTrace) { |
4162 let cancelFuture = subscription.cancel(); | 4162 let cancelFuture = subscription.cancel(); |
4163 if (dart.is(cancelFuture, Future)) { | 4163 if (dart.is(cancelFuture, Future)) { |
4164 cancelFuture.whenComplete(dart.fn(() => future[_completeError](error, stac
kTrace), dart.void, [])); | 4164 cancelFuture.whenComplete(dart.fn(() => future[_completeError](error, stac
kTrace), dart.void, [])); |
4165 } else { | 4165 } else { |
4166 future[_completeError](error, stackTrace); | 4166 future[_completeError](error, stackTrace); |
4167 } | 4167 } |
4168 } | 4168 } |
4169 dart.fn(_cancelAndError, dart.void, [StreamSubscription, _Future, core.Object,
core.StackTrace]); | 4169 dart.fn(_cancelAndError, dart.void, [StreamSubscription, _Future, dart.dynamic
, core.StackTrace]); |
4170 function _cancelAndErrorWithReplacement(subscription, future, error, stackTrac
e) { | 4170 function _cancelAndErrorWithReplacement(subscription, future, error, stackTrac
e) { |
4171 let replacement = Zone.current.errorCallback(error, stackTrace); | 4171 let replacement = Zone.current.errorCallback(error, stackTrace); |
4172 if (replacement != null) { | 4172 if (replacement != null) { |
4173 error = _nonNullError(replacement.error); | 4173 error = _nonNullError(replacement.error); |
4174 stackTrace = replacement.stackTrace; | 4174 stackTrace = replacement.stackTrace; |
4175 } | 4175 } |
4176 _cancelAndError(subscription, future, error, stackTrace); | 4176 _cancelAndError(subscription, future, error, stackTrace); |
4177 } | 4177 } |
4178 dart.fn(_cancelAndErrorWithReplacement, dart.void, [StreamSubscription, _Futur
e, core.Object, core.StackTrace]); | 4178 dart.fn(_cancelAndErrorWithReplacement, dart.void, [StreamSubscription, _Futur
e, dart.dynamic, core.StackTrace]); |
4179 function _cancelAndErrorClosure(subscription, future) { | 4179 function _cancelAndErrorClosure(subscription, future) { |
4180 return dart.fn((error, stackTrace) => _cancelAndError(subscription, future,
error, stackTrace), dart.void, [core.Object, core.StackTrace]); | 4180 return dart.fn((error, stackTrace) => _cancelAndError(subscription, future,
error, stackTrace), dart.void, [dart.dynamic, core.StackTrace]); |
4181 } | 4181 } |
4182 dart.fn(_cancelAndErrorClosure, core.Object, [StreamSubscription, _Future]); | 4182 dart.fn(_cancelAndErrorClosure, dart.dynamic, [StreamSubscription, _Future]); |
4183 function _cancelAndValue(subscription, future, value) { | 4183 function _cancelAndValue(subscription, future, value) { |
4184 let cancelFuture = subscription.cancel(); | 4184 let cancelFuture = subscription.cancel(); |
4185 if (dart.is(cancelFuture, Future)) { | 4185 if (dart.is(cancelFuture, Future)) { |
4186 cancelFuture.whenComplete(dart.fn(() => future[_complete](value), dart.voi
d, [])); | 4186 cancelFuture.whenComplete(dart.fn(() => future[_complete](value), dart.voi
d, [])); |
4187 } else { | 4187 } else { |
4188 future[_complete](value); | 4188 future[_complete](value); |
4189 } | 4189 } |
4190 } | 4190 } |
4191 dart.fn(_cancelAndValue, dart.void, [StreamSubscription, _Future, core.Object]
); | 4191 dart.fn(_cancelAndValue, dart.void, [StreamSubscription, _Future, dart.dynamic
]); |
4192 let _handleData = Symbol('_handleData'); | 4192 let _handleData = Symbol('_handleData'); |
4193 let _handleError = Symbol('_handleError'); | 4193 let _handleError = Symbol('_handleError'); |
4194 let _handleDone = Symbol('_handleDone'); | 4194 let _handleDone = Symbol('_handleDone'); |
4195 let _ForwardingStream$ = dart.generic(function(S, T) { | 4195 let _ForwardingStream$ = dart.generic(function(S, T) { |
4196 class _ForwardingStream extends Stream$(T) { | 4196 class _ForwardingStream extends Stream$(T) { |
4197 _ForwardingStream(source) { | 4197 _ForwardingStream(source) { |
4198 this[_source] = source; | 4198 this[_source] = source; |
4199 super.Stream(); | 4199 super.Stream(); |
4200 } | 4200 } |
4201 get isBroadcast() { | 4201 get isBroadcast() { |
(...skipping 27 matching lines...) Expand all Loading... |
4229 dart.as(sink, _EventSink$(T)); | 4229 dart.as(sink, _EventSink$(T)); |
4230 sink[_close](); | 4230 sink[_close](); |
4231 } | 4231 } |
4232 } | 4232 } |
4233 dart.setSignature(_ForwardingStream, { | 4233 dart.setSignature(_ForwardingStream, { |
4234 constructors: () => ({_ForwardingStream: [_ForwardingStream$(S, T), [Strea
m$(S)]]}), | 4234 constructors: () => ({_ForwardingStream: [_ForwardingStream$(S, T), [Strea
m$(S)]]}), |
4235 methods: () => ({ | 4235 methods: () => ({ |
4236 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {o
nError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnError:
core.bool}], | 4236 listen: [StreamSubscription$(T), [dart.functionType(dart.void, [T])], {o
nError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnError:
core.bool}], |
4237 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart.
void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]], | 4237 [_createSubscription]: [StreamSubscription$(T), [dart.functionType(dart.
void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]], |
4238 [_handleData]: [dart.void, [S, _EventSink$(T)]], | 4238 [_handleData]: [dart.void, [S, _EventSink$(T)]], |
4239 [_handleError]: [dart.void, [core.Object, core.StackTrace, _EventSink$(T
)]], | 4239 [_handleError]: [dart.void, [dart.dynamic, core.StackTrace, _EventSink$(
T)]], |
4240 [_handleDone]: [dart.void, [_EventSink$(T)]] | 4240 [_handleDone]: [dart.void, [_EventSink$(T)]] |
4241 }) | 4241 }) |
4242 }); | 4242 }); |
4243 return _ForwardingStream; | 4243 return _ForwardingStream; |
4244 }); | 4244 }); |
4245 let _ForwardingStream = _ForwardingStream$(); | 4245 let _ForwardingStream = _ForwardingStream$(); |
4246 let _ForwardingStreamSubscription$ = dart.generic(function(S, T) { | 4246 let _ForwardingStreamSubscription$ = dart.generic(function(S, T) { |
4247 class _ForwardingStreamSubscription extends _BufferingStreamSubscription$(T)
{ | 4247 class _ForwardingStreamSubscription extends _BufferingStreamSubscription$(T)
{ |
4248 _ForwardingStreamSubscription(stream, onData, onError, onDone, cancelOnErr
or) { | 4248 _ForwardingStreamSubscription(stream, onData, onError, onDone, cancelOnErr
or) { |
4249 this[_stream] = stream; | 4249 this[_stream] = stream; |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4289 } | 4289 } |
4290 [_handleDone]() { | 4290 [_handleDone]() { |
4291 this[_stream][_handleDone](this); | 4291 this[_stream][_handleDone](this); |
4292 } | 4292 } |
4293 } | 4293 } |
4294 dart.setSignature(_ForwardingStreamSubscription, { | 4294 dart.setSignature(_ForwardingStreamSubscription, { |
4295 constructors: () => ({_ForwardingStreamSubscription: [_ForwardingStreamSub
scription$(S, T), [_ForwardingStream$(S, T), dart.functionType(dart.void, [T]),
core.Function, dart.functionType(dart.void, []), core.bool]]}), | 4295 constructors: () => ({_ForwardingStreamSubscription: [_ForwardingStreamSub
scription$(S, T), [_ForwardingStream$(S, T), dart.functionType(dart.void, [T]),
core.Function, dart.functionType(dart.void, []), core.bool]]}), |
4296 methods: () => ({ | 4296 methods: () => ({ |
4297 [_add]: [dart.void, [T]], | 4297 [_add]: [dart.void, [T]], |
4298 [_handleData]: [dart.void, [S]], | 4298 [_handleData]: [dart.void, [S]], |
4299 [_handleError]: [dart.void, [core.Object, core.StackTrace]], | 4299 [_handleError]: [dart.void, [dart.dynamic, core.StackTrace]], |
4300 [_handleDone]: [dart.void, []] | 4300 [_handleDone]: [dart.void, []] |
4301 }) | 4301 }) |
4302 }); | 4302 }); |
4303 return _ForwardingStreamSubscription; | 4303 return _ForwardingStreamSubscription; |
4304 }); | 4304 }); |
4305 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); | 4305 let _ForwardingStreamSubscription = _ForwardingStreamSubscription$(); |
4306 let _Predicate$ = dart.generic(function(T) { | 4306 let _Predicate$ = dart.generic(function(T) { |
4307 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo
l, [T])); | 4307 let _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.boo
l, [T])); |
4308 return _Predicate; | 4308 return _Predicate; |
4309 }); | 4309 }); |
4310 let _Predicate = _Predicate$(); | 4310 let _Predicate = _Predicate$(); |
4311 function _addErrorWithReplacement(sink, error, stackTrace) { | 4311 function _addErrorWithReplacement(sink, error, stackTrace) { |
4312 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); | 4312 let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core
.StackTrace)); |
4313 if (replacement != null) { | 4313 if (replacement != null) { |
4314 error = _nonNullError(replacement.error); | 4314 error = _nonNullError(replacement.error); |
4315 stackTrace = replacement.stackTrace; | 4315 stackTrace = replacement.stackTrace; |
4316 } | 4316 } |
4317 sink[_addError](error, dart.as(stackTrace, core.StackTrace)); | 4317 sink[_addError](error, dart.as(stackTrace, core.StackTrace)); |
4318 } | 4318 } |
4319 dart.fn(_addErrorWithReplacement, dart.void, [_EventSink, core.Object, core.Ob
ject]); | 4319 dart.fn(_addErrorWithReplacement, dart.void, [_EventSink, dart.dynamic, dart.d
ynamic]); |
4320 let _test = Symbol('_test'); | 4320 let _test = Symbol('_test'); |
4321 let _WhereStream$ = dart.generic(function(T) { | 4321 let _WhereStream$ = dart.generic(function(T) { |
4322 class _WhereStream extends _ForwardingStream$(T, T) { | 4322 class _WhereStream extends _ForwardingStream$(T, T) { |
4323 _WhereStream(source, test) { | 4323 _WhereStream(source, test) { |
4324 this[_test] = test; | 4324 this[_test] = test; |
4325 super._ForwardingStream(source); | 4325 super._ForwardingStream(source); |
4326 } | 4326 } |
4327 [_handleData](inputEvent, sink) { | 4327 [_handleData](inputEvent, sink) { |
4328 dart.as(inputEvent, T); | 4328 dart.as(inputEvent, T); |
4329 dart.as(sink, _EventSink$(T)); | 4329 dart.as(sink, _EventSink$(T)); |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4403 | 4403 |
4404 } | 4404 } |
4405 } | 4405 } |
4406 dart.setSignature(_ExpandStream, { | 4406 dart.setSignature(_ExpandStream, { |
4407 constructors: () => ({_ExpandStream: [_ExpandStream$(S, T), [Stream$(S), d
art.functionType(core.Iterable$(T), [S])]]}), | 4407 constructors: () => ({_ExpandStream: [_ExpandStream$(S, T), [Stream$(S), d
art.functionType(core.Iterable$(T), [S])]]}), |
4408 methods: () => ({[_handleData]: [dart.void, [S, _EventSink$(T)]]}) | 4408 methods: () => ({[_handleData]: [dart.void, [S, _EventSink$(T)]]}) |
4409 }); | 4409 }); |
4410 return _ExpandStream; | 4410 return _ExpandStream; |
4411 }); | 4411 }); |
4412 let _ExpandStream = _ExpandStream$(); | 4412 let _ExpandStream = _ExpandStream$(); |
4413 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool,
[dart.bottom])); | 4413 let _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool,
[dart.dynamic])); |
4414 let _HandleErrorStream$ = dart.generic(function(T) { | 4414 let _HandleErrorStream$ = dart.generic(function(T) { |
4415 class _HandleErrorStream extends _ForwardingStream$(T, T) { | 4415 class _HandleErrorStream extends _ForwardingStream$(T, T) { |
4416 _HandleErrorStream(source, onError, test) { | 4416 _HandleErrorStream(source, onError, test) { |
4417 this[_transform] = onError; | 4417 this[_transform] = onError; |
4418 this[_test] = test; | 4418 this[_test] = test; |
4419 super._ForwardingStream(source); | 4419 super._ForwardingStream(source); |
4420 } | 4420 } |
4421 [_handleError](error, stackTrace, sink) { | 4421 [_handleError](error, stackTrace, sink) { |
4422 dart.as(sink, _EventSink$(T)); | 4422 dart.as(sink, _EventSink$(T)); |
4423 let matches = true; | 4423 let matches = true; |
(...skipping 19 matching lines...) Expand all Loading... |
4443 } | 4443 } |
4444 return; | 4444 return; |
4445 } | 4445 } |
4446 | 4446 |
4447 } else { | 4447 } else { |
4448 sink[_addError](error, stackTrace); | 4448 sink[_addError](error, stackTrace); |
4449 } | 4449 } |
4450 } | 4450 } |
4451 } | 4451 } |
4452 dart.setSignature(_HandleErrorStream, { | 4452 dart.setSignature(_HandleErrorStream, { |
4453 constructors: () => ({_HandleErrorStream: [_HandleErrorStream$(T), [Stream
$(T), core.Function, dart.functionType(core.bool, [dart.bottom])]]}), | 4453 constructors: () => ({_HandleErrorStream: [_HandleErrorStream$(T), [Stream
$(T), core.Function, dart.functionType(core.bool, [dart.dynamic])]]}), |
4454 methods: () => ({[_handleError]: [dart.void, [core.Object, core.StackTrace
, _EventSink$(T)]]}) | 4454 methods: () => ({[_handleError]: [dart.void, [core.Object, core.StackTrace
, _EventSink$(T)]]}) |
4455 }); | 4455 }); |
4456 return _HandleErrorStream; | 4456 return _HandleErrorStream; |
4457 }); | 4457 }); |
4458 let _HandleErrorStream = _HandleErrorStream$(); | 4458 let _HandleErrorStream = _HandleErrorStream$(); |
4459 let _remaining = Symbol('_remaining'); | 4459 let _remaining = Symbol('_remaining'); |
4460 let _TakeStream$ = dart.generic(function(T) { | 4460 let _TakeStream$ = dart.generic(function(T) { |
4461 class _TakeStream extends _ForwardingStream$(T, T) { | 4461 class _TakeStream extends _ForwardingStream$(T, T) { |
4462 _TakeStream(source, count) { | 4462 _TakeStream(source, count) { |
4463 this[_remaining] = count; | 4463 this[_remaining] = count; |
(...skipping 185 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4649 } | 4649 } |
4650 close() { | 4650 close() { |
4651 this[_sink][_close](); | 4651 this[_sink][_close](); |
4652 } | 4652 } |
4653 } | 4653 } |
4654 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)]; | 4654 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)]; |
4655 dart.setSignature(_EventSinkWrapper, { | 4655 dart.setSignature(_EventSinkWrapper, { |
4656 constructors: () => ({_EventSinkWrapper: [_EventSinkWrapper$(T), [_EventSi
nk]]}), | 4656 constructors: () => ({_EventSinkWrapper: [_EventSinkWrapper$(T), [_EventSi
nk]]}), |
4657 methods: () => ({ | 4657 methods: () => ({ |
4658 add: [dart.void, [T]], | 4658 add: [dart.void, [T]], |
4659 addError: [dart.void, [core.Object], [core.StackTrace]], | 4659 addError: [dart.void, [dart.dynamic], [core.StackTrace]], |
4660 close: [dart.void, []] | 4660 close: [dart.void, []] |
4661 }) | 4661 }) |
4662 }); | 4662 }); |
4663 return _EventSinkWrapper; | 4663 return _EventSinkWrapper; |
4664 }); | 4664 }); |
4665 let _EventSinkWrapper = _EventSinkWrapper$(); | 4665 let _EventSinkWrapper = _EventSinkWrapper$(); |
4666 let _transformerSink = Symbol('_transformerSink'); | 4666 let _transformerSink = Symbol('_transformerSink'); |
4667 let _isSubscribed = Symbol('_isSubscribed'); | 4667 let _isSubscribed = Symbol('_isSubscribed'); |
4668 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { | 4668 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { |
4669 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio
n$(T) { | 4669 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio
n$(T) { |
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4747 this[_addError](e, s); | 4747 this[_addError](e, s); |
4748 } | 4748 } |
4749 | 4749 |
4750 } | 4750 } |
4751 } | 4751 } |
4752 dart.setSignature(_SinkTransformerStreamSubscription, { | 4752 dart.setSignature(_SinkTransformerStreamSubscription, { |
4753 constructors: () => ({_SinkTransformerStreamSubscription: [_SinkTransforme
rStreamSubscription$(S, T), [Stream$(S), _SinkMapper$(S, T), dart.functionType(d
art.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]]}), | 4753 constructors: () => ({_SinkTransformerStreamSubscription: [_SinkTransforme
rStreamSubscription$(S, T), [Stream$(S), _SinkMapper$(S, T), dart.functionType(d
art.void, [T]), core.Function, dart.functionType(dart.void, []), core.bool]]}), |
4754 methods: () => ({ | 4754 methods: () => ({ |
4755 [_add]: [dart.void, [T]], | 4755 [_add]: [dart.void, [T]], |
4756 [_handleData]: [dart.void, [S]], | 4756 [_handleData]: [dart.void, [S]], |
4757 [_handleError]: [dart.void, [core.Object], [core.Object]], | 4757 [_handleError]: [dart.void, [dart.dynamic], [dart.dynamic]], |
4758 [_handleDone]: [dart.void, []] | 4758 [_handleDone]: [dart.void, []] |
4759 }) | 4759 }) |
4760 }); | 4760 }); |
4761 return _SinkTransformerStreamSubscription; | 4761 return _SinkTransformerStreamSubscription; |
4762 }); | 4762 }); |
4763 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$()
; | 4763 let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$()
; |
4764 let _SinkMapper$ = dart.generic(function(S, T) { | 4764 let _SinkMapper$ = dart.generic(function(S, T) { |
4765 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS
ink$(S), [EventSink$(T)])); | 4765 let _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventS
ink$(S), [EventSink$(T)])); |
4766 return _SinkMapper; | 4766 return _SinkMapper; |
4767 }); | 4767 }); |
(...skipping 27 matching lines...) Expand all Loading... |
4795 this[_sinkMapper] = sinkMapper; | 4795 this[_sinkMapper] = sinkMapper; |
4796 super.Stream(); | 4796 super.Stream(); |
4797 } | 4797 } |
4798 listen(onData, opts) { | 4798 listen(onData, opts) { |
4799 dart.as(onData, dart.functionType(dart.void, [T])); | 4799 dart.as(onData, dart.functionType(dart.void, [T])); |
4800 let onError = opts && 'onError' in opts ? opts.onError : null; | 4800 let onError = opts && 'onError' in opts ? opts.onError : null; |
4801 let onDone = opts && 'onDone' in opts ? opts.onDone : null; | 4801 let onDone = opts && 'onDone' in opts ? opts.onDone : null; |
4802 dart.as(onDone, dart.functionType(dart.void, [])); | 4802 dart.as(onDone, dart.functionType(dart.void, [])); |
4803 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 4803 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
4804 cancelOnError = core.identical(true, cancelOnError); | 4804 cancelOnError = core.identical(true, cancelOnError); |
4805 let subscription = new (_SinkTransformerStreamSubscription$(core.Object,
T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, on
Done, cancelOnError); | 4805 let subscription = new (_SinkTransformerStreamSubscription$(dart.dynamic
, T))(this[_stream], dart.as(this[_sinkMapper], _SinkMapper), onData, onError, o
nDone, cancelOnError); |
4806 return subscription; | 4806 return subscription; |
4807 } | 4807 } |
4808 } | 4808 } |
4809 dart.setSignature(_BoundSinkStream, { | 4809 dart.setSignature(_BoundSinkStream, { |
4810 constructors: () => ({_BoundSinkStream: [_BoundSinkStream$(S, T), [Stream$
(S), _SinkMapper$(S, T)]]}), | 4810 constructors: () => ({_BoundSinkStream: [_BoundSinkStream$(S, T), [Stream$
(S), _SinkMapper$(S, T)]]}), |
4811 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart.
void, [T])], {onError: core.Function, onDone: dart.functionType(dart.void, []),
cancelOnError: core.bool}]}) | 4811 methods: () => ({listen: [StreamSubscription$(T), [dart.functionType(dart.
void, [T])], {onError: core.Function, onDone: dart.functionType(dart.void, []),
cancelOnError: core.bool}]}) |
4812 }); | 4812 }); |
4813 return _BoundSinkStream; | 4813 return _BoundSinkStream; |
4814 }); | 4814 }); |
4815 let _BoundSinkStream = _BoundSinkStream$(); | 4815 let _BoundSinkStream = _BoundSinkStream$(); |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4869 let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null; | 4869 let handleDone = opts && 'handleDone' in opts ? opts.handleDone : null; |
4870 super._StreamSinkTransformer(dart.as(dart.fn(outputSink => { | 4870 super._StreamSinkTransformer(dart.as(dart.fn(outputSink => { |
4871 dart.as(outputSink, EventSink$(T)); | 4871 dart.as(outputSink, EventSink$(T)); |
4872 if (handleData == null) | 4872 if (handleData == null) |
4873 handleData = dart.as(_StreamHandlerTransformer$()._defaultHandleData
, __CastType27); | 4873 handleData = dart.as(_StreamHandlerTransformer$()._defaultHandleData
, __CastType27); |
4874 if (handleError == null) | 4874 if (handleError == null) |
4875 handleError = dart.as(_StreamHandlerTransformer$()._defaultHandleErr
or, __CastType30); | 4875 handleError = dart.as(_StreamHandlerTransformer$()._defaultHandleErr
or, __CastType30); |
4876 if (handleDone == null) | 4876 if (handleDone == null) |
4877 handleDone = _StreamHandlerTransformer$()._defaultHandleDone; | 4877 handleDone = _StreamHandlerTransformer$()._defaultHandleDone; |
4878 return new (_HandlerEventSink$(S, T))(handleData, handleError, handleD
one, outputSink); | 4878 return new (_HandlerEventSink$(S, T))(handleData, handleError, handleD
one, outputSink); |
4879 }, core.Object, [EventSink$(T)]), _SinkMapper$(S, T))); | 4879 }, dart.dynamic, [EventSink$(T)]), _SinkMapper$(S, T))); |
4880 } | 4880 } |
4881 bind(stream) { | 4881 bind(stream) { |
4882 dart.as(stream, Stream$(S)); | 4882 dart.as(stream, Stream$(S)); |
4883 return super.bind(stream); | 4883 return super.bind(stream); |
4884 } | 4884 } |
4885 static _defaultHandleData(data, sink) { | 4885 static _defaultHandleData(data, sink) { |
4886 sink.add(data); | 4886 sink.add(data); |
4887 } | 4887 } |
4888 static _defaultHandleError(error, stackTrace, sink) { | 4888 static _defaultHandleError(error, stackTrace, sink) { |
4889 sink.addError(error); | 4889 sink.addError(error); |
4890 } | 4890 } |
4891 static _defaultHandleDone(sink) { | 4891 static _defaultHandleDone(sink) { |
4892 sink.close(); | 4892 sink.close(); |
4893 } | 4893 } |
4894 } | 4894 } |
4895 dart.setSignature(_StreamHandlerTransformer, { | 4895 dart.setSignature(_StreamHandlerTransformer, { |
4896 constructors: () => ({_StreamHandlerTransformer: [_StreamHandlerTransforme
r$(S, T), [], {handleData: dart.functionType(dart.void, [S, EventSink$(T)]), han
dleError: dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$
(T)]), handleDone: dart.functionType(dart.void, [EventSink$(T)])}]}), | 4896 constructors: () => ({_StreamHandlerTransformer: [_StreamHandlerTransforme
r$(S, T), [], {handleData: dart.functionType(dart.void, [S, EventSink$(T)]), han
dleError: dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$
(T)]), handleDone: dart.functionType(dart.void, [EventSink$(T)])}]}), |
4897 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}), | 4897 methods: () => ({bind: [Stream$(T), [Stream$(S)]]}), |
4898 statics: () => ({ | 4898 statics: () => ({ |
4899 _defaultHandleData: [dart.void, [core.Object, EventSink]], | 4899 _defaultHandleData: [dart.void, [dart.dynamic, EventSink]], |
4900 _defaultHandleError: [dart.void, [core.Object, core.StackTrace, EventSin
k]], | 4900 _defaultHandleError: [dart.void, [dart.dynamic, core.StackTrace, EventSi
nk]], |
4901 _defaultHandleDone: [dart.void, [EventSink]] | 4901 _defaultHandleDone: [dart.void, [EventSink]] |
4902 }), | 4902 }), |
4903 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone'] | 4903 names: ['_defaultHandleData', '_defaultHandleError', '_defaultHandleDone'] |
4904 }); | 4904 }); |
4905 return _StreamHandlerTransformer; | 4905 return _StreamHandlerTransformer; |
4906 }); | 4906 }); |
4907 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); | 4907 let _StreamHandlerTransformer = _StreamHandlerTransformer$(); |
4908 let _SubscriptionTransformer$ = dart.generic(function(S, T) { | 4908 let _SubscriptionTransformer$ = dart.generic(function(S, T) { |
4909 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () =
> dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool])); | 4909 let _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () =
> dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool])); |
4910 return _SubscriptionTransformer; | 4910 return _SubscriptionTransformer; |
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5002 periodic: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]] | 5002 periodic: [Timer, [core.Duration, dart.functionType(dart.void, [Timer])]] |
5003 }), | 5003 }), |
5004 statics: () => ({ | 5004 statics: () => ({ |
5005 run: [dart.void, [dart.functionType(dart.void, [])]], | 5005 run: [dart.void, [dart.functionType(dart.void, [])]], |
5006 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 5006 _createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
5007 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]] | 5007 _createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]] |
5008 }), | 5008 }), |
5009 names: ['run', '_createTimer', '_createPeriodicTimer'] | 5009 names: ['run', '_createTimer', '_createPeriodicTimer'] |
5010 }); | 5010 }); |
5011 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v
oid, [Timer])); | 5011 let __CastType34 = dart.typedef('__CastType34', () => dart.functionType(dart.v
oid, [Timer])); |
5012 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(core.O
bject, [])); | 5012 let ZoneCallback = dart.typedef('ZoneCallback', () => dart.functionType(dart.d
ynamic, [])); |
5013 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT
ype(core.Object, [dart.bottom])); | 5013 let ZoneUnaryCallback = dart.typedef('ZoneUnaryCallback', () => dart.functionT
ype(dart.dynamic, [dart.dynamic])); |
5014 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functio
nType(core.Object, [dart.bottom, dart.bottom])); | 5014 let ZoneBinaryCallback = dart.typedef('ZoneBinaryCallback', () => dart.functio
nType(dart.dynamic, [dart.dynamic, dart.dynamic])); |
5015 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', ()
=> dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.
StackTrace])); | 5015 let HandleUncaughtErrorHandler = dart.typedef('HandleUncaughtErrorHandler', ()
=> dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, cor
e.StackTrace])); |
5016 let RunHandler = dart.typedef('RunHandler', () => dart.functionType(core.Objec
t, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [])])); | 5016 let RunHandler = dart.typedef('RunHandler', () => dart.functionType(dart.dynam
ic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])])); |
5017 let RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionType(
core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [dart.bot
tom]), dart.bottom])); | 5017 let RunUnaryHandler = dart.typedef('RunUnaryHandler', () => dart.functionType(
dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.d
ynamic]), dart.dynamic])); |
5018 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])); | 5018 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])); |
5019 let RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () => da
rt.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(core.
Object, [])])); | 5019 let RegisterCallbackHandler = dart.typedef('RegisterCallbackHandler', () => da
rt.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.
dynamic, [])])); |
5020 let RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandler'
, () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(core.Object, [dart.bottom])])); | 5020 let RegisterUnaryCallbackHandler = dart.typedef('RegisterUnaryCallbackHandler'
, () => dart.functionType(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [dart.dynamic])])); |
5021 let RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHandle
r', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.
functionType(core.Object, [dart.bottom, dart.bottom])])); | 5021 let RegisterBinaryCallbackHandler = dart.typedef('RegisterBinaryCallbackHandle
r', () => dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.
functionType(dart.dynamic, [dart.dynamic, dart.dynamic])])); |
5022 let ErrorCallbackHandler = dart.typedef('ErrorCallbackHandler', () => dart.fun
ctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]))
; | 5022 let ErrorCallbackHandler = dart.typedef('ErrorCallbackHandler', () => dart.fun
ctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]))
; |
5023 let ScheduleMicrotaskHandler = dart.typedef('ScheduleMicrotaskHandler', () =>
dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(core.O
bject, [])])); | 5023 let ScheduleMicrotaskHandler = dart.typedef('ScheduleMicrotaskHandler', () =>
dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.d
ynamic, [])])); |
5024 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])])); | 5024 let CreateTimerHandler = dart.typedef('CreateTimerHandler', () => dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])])); |
5025 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', ()
=> dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func
tionType(dart.void, [Timer])])); | 5025 let CreatePeriodicTimerHandler = dart.typedef('CreatePeriodicTimerHandler', ()
=> dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.func
tionType(dart.void, [Timer])])); |
5026 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v
oid, [Zone, ZoneDelegate, Zone, core.String])); | 5026 let PrintHandler = dart.typedef('PrintHandler', () => dart.functionType(dart.v
oid, [Zone, ZoneDelegate, Zone, core.String])); |
5027 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z
one, ZoneDelegate, Zone, ZoneSpecification, core.Map])); | 5027 let ForkHandler = dart.typedef('ForkHandler', () => dart.functionType(Zone, [Z
one, ZoneDelegate, Zone, ZoneSpecification, core.Map])); |
5028 class _ZoneFunction extends core.Object { | 5028 class _ZoneFunction extends core.Object { |
5029 _ZoneFunction(zone, func) { | 5029 _ZoneFunction(zone, func) { |
5030 this.zone = zone; | 5030 this.zone = zone; |
5031 this.function = func; | 5031 this.function = func; |
5032 } | 5032 } |
5033 } | 5033 } |
(...skipping 16 matching lines...) Expand all Loading... |
5050 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul
eMicrotask : null; | 5050 let scheduleMicrotask = opts && 'scheduleMicrotask' in opts ? opts.schedul
eMicrotask : null; |
5051 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; | 5051 let createTimer = opts && 'createTimer' in opts ? opts.createTimer : null; |
5052 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; | 5052 let createPeriodicTimer = opts && 'createPeriodicTimer' in opts ? opts.cre
atePeriodicTimer : null; |
5053 let print = opts && 'print' in opts ? opts.print : null; | 5053 let print = opts && 'print' in opts ? opts.print : null; |
5054 let fork = opts && 'fork' in opts ? opts.fork : null; | 5054 let fork = opts && 'fork' in opts ? opts.fork : null; |
5055 return ZoneSpecification.new({handleUncaughtError: handleUncaughtError !=
null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run :
other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r
unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba
ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r
egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba
ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb
ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error
Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s
cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c
reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null
? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print
: other.print, fork: fork != null ? fork : other.fork}); | 5055 return ZoneSpecification.new({handleUncaughtError: handleUncaughtError !=
null ? handleUncaughtError : other.handleUncaughtError, run: run != null ? run :
other.run, runUnary: runUnary != null ? runUnary : other.runUnary, runBinary: r
unBinary != null ? runBinary : other.runBinary, registerCallback: registerCallba
ck != null ? registerCallback : other.registerCallback, registerUnaryCallback: r
egisterUnaryCallback != null ? registerUnaryCallback : other.registerUnaryCallba
ck, registerBinaryCallback: registerBinaryCallback != null ? registerBinaryCallb
ack : other.registerBinaryCallback, errorCallback: errorCallback != null ? error
Callback : other.errorCallback, scheduleMicrotask: scheduleMicrotask != null ? s
cheduleMicrotask : other.scheduleMicrotask, createTimer: createTimer != null ? c
reateTimer : other.createTimer, createPeriodicTimer: createPeriodicTimer != null
? createPeriodicTimer : other.createPeriodicTimer, print: print != null ? print
: other.print, fork: fork != null ? fork : other.fork}); |
5056 } | 5056 } |
5057 } | 5057 } |
5058 dart.setSignature(ZoneSpecification, { | 5058 dart.setSignature(ZoneSpecification, { |
5059 constructors: () => ({ | 5059 constructors: () => ({ |
5060 new: [ZoneSpecification, [], {handleUncaughtError: dart.functionType(core.
Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.StackTrace]), run: dart.fun
ctionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object,
[])]), runUnary: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart
.functionType(core.Object, [dart.bottom]), dart.bottom]), runBinary: dart.functi
onType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [d
art.bottom, dart.bottom]), dart.bottom, dart.bottom]), registerCallback: dart.fu
nctionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionType(core.Objec
t, [])]), registerUnaryCallback: dart.functionType(ZoneUnaryCallback, [Zone, Zon
eDelegate, Zone, dart.functionType(core.Object, [dart.bottom])]), registerBinary
Callback: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDelegate, Zone, dart.
functionType(core.Object, [dart.bottom, dart.bottom])]), errorCallback: dart.fun
ctionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]),
scheduleMicrotask: dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, dart
.functionType(core.Object, [])]), createTimer: dart.functionType(Timer, [Zone, Z
oneDelegate, Zone, core.Duration, dart.functionType(dart.void, [])]), createPeri
odicTimer: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, da
rt.functionType(dart.void, [Timer])]), print: dart.functionType(dart.void, [Zone
, ZoneDelegate, Zone, core.String]), fork: dart.functionType(Zone, [Zone, ZoneDe
legate, Zone, ZoneSpecification, core.Map])}], | 5060 new: [ZoneSpecification, [], {handleUncaughtError: dart.functionType(dart.
dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]), run: dart.f
unctionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dyna
mic, [])]), runUnary: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone,
dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic]), runBinary: dar
t.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(dart.d
ynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]), registerCal
lback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.functionT
ype(dart.dynamic, [])]), registerUnaryCallback: dart.functionType(ZoneUnaryCallb
ack, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic])]
), registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDele
gate, Zone, dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]), err
orCallback: dart.functionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object
, core.StackTrace]), scheduleMicrotask: dart.functionType(dart.void, [Zone, Zone
Delegate, Zone, dart.functionType(dart.dynamic, [])]), createTimer: dart.functio
nType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.vo
id, [])]), createPeriodicTimer: dart.functionType(Timer, [Zone, ZoneDelegate, Zo
ne, core.Duration, dart.functionType(dart.void, [Timer])]), print: dart.function
Type(dart.void, [Zone, ZoneDelegate, Zone, core.String]), fork: dart.functionTyp
e(Zone, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])}], |
5061 from: [ZoneSpecification, [ZoneSpecification], {handleUncaughtError: dart.
functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.bottom, core.StackTrac
e]), run: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functio
nType(core.Object, [])]), runUnary: dart.functionType(core.Object, [Zone, ZoneDe
legate, Zone, dart.functionType(core.Object, [dart.bottom]), dart.bottom]), runB
inary: dart.functionType(core.Object, [Zone, ZoneDelegate, Zone, dart.functionTy
pe(core.Object, [dart.bottom, dart.bottom]), dart.bottom, dart.bottom]), registe
rCallback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zone, dart.funct
ionType(core.Object, [])]), registerUnaryCallback: dart.functionType(ZoneUnaryCa
llback, [Zone, ZoneDelegate, Zone, dart.functionType(core.Object, [dart.bottom])
]), registerBinaryCallback: dart.functionType(ZoneBinaryCallback, [Zone, ZoneDel
egate, Zone, dart.functionType(core.Object, [dart.bottom, dart.bottom])]), error
Callback: dart.functionType(AsyncError, [Zone, ZoneDelegate, Zone, core.Object,
core.StackTrace]), scheduleMicrotask: dart.functionType(dart.void, [Zone, ZoneDe
legate, Zone, dart.functionType(core.Object, [])]), createTimer: dart.functionTy
pe(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void,
[])]), createPeriodicTimer: dart.functionType(Timer, [Zone, ZoneDelegate, Zone,
core.Duration, dart.functionType(dart.void, [Timer])]), print: dart.functionTyp
e(dart.void, [Zone, ZoneDelegate, Zone, core.String]), fork: dart.functionType(Z
one, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map])}] | 5061 from: [ZoneSpecification, [ZoneSpecification], {handleUncaughtError: dart.
functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTr
ace]), run: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.func
tionType(dart.dynamic, [])]), runUnary: dart.functionType(dart.dynamic, [Zone, Z
oneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic]), dart.dynamic
]), runBinary: dart.functionType(dart.dynamic, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dyna
mic]), registerCallback: dart.functionType(ZoneCallback, [Zone, ZoneDelegate, Zo
ne, dart.functionType(dart.dynamic, [])]), registerUnaryCallback: dart.functionT
ype(ZoneUnaryCallback, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic
, [dart.dynamic])]), registerBinaryCallback: dart.functionType(ZoneBinaryCallbac
k, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [dart.dynamic, dar
t.dynamic])]), errorCallback: dart.functionType(AsyncError, [Zone, ZoneDelegate,
Zone, core.Object, core.StackTrace]), scheduleMicrotask: dart.functionType(dart
.void, [Zone, ZoneDelegate, Zone, dart.functionType(dart.dynamic, [])]), createT
imer: dart.functionType(Timer, [Zone, ZoneDelegate, Zone, core.Duration, dart.fu
nctionType(dart.void, [])]), createPeriodicTimer: dart.functionType(Timer, [Zone
, ZoneDelegate, Zone, core.Duration, dart.functionType(dart.void, [Timer])]), pr
int: dart.functionType(dart.void, [Zone, ZoneDelegate, Zone, core.String]), fork
: dart.functionType(Zone, [Zone, ZoneDelegate, Zone, ZoneSpecification, core.Map
])}] |
5062 }) | 5062 }) |
5063 }); | 5063 }); |
5064 class _ZoneSpecification extends core.Object { | 5064 class _ZoneSpecification extends core.Object { |
5065 _ZoneSpecification(opts) { | 5065 _ZoneSpecification(opts) { |
5066 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; | 5066 let handleUncaughtError = opts && 'handleUncaughtError' in opts ? opts.han
dleUncaughtError : null; |
5067 let run = opts && 'run' in opts ? opts.run : null; | 5067 let run = opts && 'run' in opts ? opts.run : null; |
5068 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; | 5068 let runUnary = opts && 'runUnary' in opts ? opts.runUnary : null; |
5069 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; | 5069 let runBinary = opts && 'runBinary' in opts ? opts.runBinary : null; |
5070 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; | 5070 let registerCallback = opts && 'registerCallback' in opts ? opts.registerC
allback : null; |
5071 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; | 5071 let registerUnaryCallback = opts && 'registerUnaryCallback' in opts ? opts
.registerUnaryCallback : null; |
(...skipping 242 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5314 createPeriodicTimer(duration, f) { | 5314 createPeriodicTimer(duration, f) { |
5315 return Timer._createPeriodicTimer(duration, f); | 5315 return Timer._createPeriodicTimer(duration, f); |
5316 } | 5316 } |
5317 print(line) { | 5317 print(line) { |
5318 _internal.printToConsole(line); | 5318 _internal.printToConsole(line); |
5319 } | 5319 } |
5320 } | 5320 } |
5321 dart.setSignature(_RootZone, { | 5321 dart.setSignature(_RootZone, { |
5322 constructors: () => ({_RootZone: [_RootZone, []]}), | 5322 constructors: () => ({_RootZone: [_RootZone, []]}), |
5323 methods: () => ({ | 5323 methods: () => ({ |
5324 runGuarded: [core.Object, [dart.functionType(core.Object, [])]], | 5324 runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]], |
5325 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto
m]), core.Object]], | 5325 runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dyn
amic]), dart.dynamic]], |
5326 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott
om, dart.bottom]), core.Object, core.Object]], | 5326 runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dy
namic, dart.dynamic]), dart.dynamic, dart.dynamic]], |
5327 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {runGua
rded: core.bool}], | 5327 bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {runGu
arded: core.bool}], |
5328 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da
rt.bottom])], {runGuarded: core.bool}], | 5328 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [d
art.dynamic])], {runGuarded: core.bool}], |
5329 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [
dart.bottom, dart.bottom])], {runGuarded: core.bool}], | 5329 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic,
[dart.dynamic, dart.dynamic])], {runGuarded: core.bool}], |
5330 get: [core.Object, [core.Object]], | 5330 get: [dart.dynamic, [core.Object]], |
5331 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]], | 5331 handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]], |
5332 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}]
, | 5332 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}]
, |
5333 run: [core.Object, [dart.functionType(core.Object, [])]], | 5333 run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]], |
5334 runUnary: [core.Object, [dart.functionType(core.Object, [dart.bottom]), co
re.Object]], | 5334 runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]),
dart.dynamic]], |
5335 runBinary: [core.Object, [dart.functionType(core.Object, [dart.bottom, dar
t.bottom]), core.Object, core.Object]], | 5335 runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic,
dart.dynamic]), dart.dynamic, dart.dynamic]], |
5336 registerCallback: [ZoneCallback, [dart.functionType(core.Object, [])]], | 5336 registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]], |
5337 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object,
[dart.bottom])]], | 5337 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic
, [dart.dynamic])]], |
5338 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Objec
t, [dart.bottom, dart.bottom])]], | 5338 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynam
ic, [dart.dynamic, dart.dynamic])]], |
5339 errorCallback: [AsyncError, [core.Object, core.StackTrace]], | 5339 errorCallback: [AsyncError, [core.Object, core.StackTrace]], |
5340 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], | 5340 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], |
5341 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 5341 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
5342 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], | 5342 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], |
5343 print: [dart.void, [core.String]] | 5343 print: [dart.void, [core.String]] |
5344 }) | 5344 }) |
5345 }); | 5345 }); |
5346 let _ROOT_ZONE = dart.const(new _RootZone()); | 5346 let _ROOT_ZONE = dart.const(new _RootZone()); |
5347 Zone.ROOT = _ROOT_ZONE; | 5347 Zone.ROOT = _ROOT_ZONE; |
5348 Zone._current = _ROOT_ZONE; | 5348 Zone._current = _ROOT_ZONE; |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5422 fork(zone, specification, zoneValues) { | 5422 fork(zone, specification, zoneValues) { |
5423 let implementation = this[_delegationTarget][_fork]; | 5423 let implementation = this[_delegationTarget][_fork]; |
5424 let implZone = implementation.zone; | 5424 let implZone = implementation.zone; |
5425 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, specification, zoneValues), Zone); | 5425 return dart.as(dart.dcall(implementation.function, implZone, _parentDelega
te(implZone), zone, specification, zoneValues), Zone); |
5426 } | 5426 } |
5427 } | 5427 } |
5428 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; | 5428 _ZoneDelegate[dart.implements] = () => [ZoneDelegate]; |
5429 dart.setSignature(_ZoneDelegate, { | 5429 dart.setSignature(_ZoneDelegate, { |
5430 constructors: () => ({_ZoneDelegate: [_ZoneDelegate, [_Zone]]}), | 5430 constructors: () => ({_ZoneDelegate: [_ZoneDelegate, [_Zone]]}), |
5431 methods: () => ({ | 5431 methods: () => ({ |
5432 handleUncaughtError: [core.Object, [Zone, core.Object, core.StackTrace]], | 5432 handleUncaughtError: [dart.dynamic, [Zone, dart.dynamic, core.StackTrace]]
, |
5433 run: [core.Object, [Zone, dart.functionType(core.Object, [])]], | 5433 run: [dart.dynamic, [Zone, dart.functionType(dart.dynamic, [])]], |
5434 runUnary: [core.Object, [Zone, dart.functionType(core.Object, [dart.bottom
]), core.Object]], | 5434 runUnary: [dart.dynamic, [Zone, dart.functionType(dart.dynamic, [dart.dyna
mic]), dart.dynamic]], |
5435 runBinary: [core.Object, [Zone, dart.functionType(core.Object, [dart.botto
m, dart.bottom]), core.Object, core.Object]], | 5435 runBinary: [dart.dynamic, [Zone, dart.functionType(dart.dynamic, [dart.dyn
amic, dart.dynamic]), dart.dynamic, dart.dynamic]], |
5436 registerCallback: [ZoneCallback, [Zone, dart.functionType(core.Object, [])
]], | 5436 registerCallback: [ZoneCallback, [Zone, dart.functionType(dart.dynamic, []
)]], |
5437 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(core.O
bject, [dart.bottom])]], | 5437 registerUnaryCallback: [ZoneUnaryCallback, [Zone, dart.functionType(dart.d
ynamic, [dart.dynamic])]], |
5438 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(core
.Object, [dart.bottom, dart.bottom])]], | 5438 registerBinaryCallback: [ZoneBinaryCallback, [Zone, dart.functionType(dart
.dynamic, [dart.dynamic, dart.dynamic])]], |
5439 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]], | 5439 errorCallback: [AsyncError, [Zone, core.Object, core.StackTrace]], |
5440 scheduleMicrotask: [dart.void, [Zone, dart.functionType(core.Object, [])]]
, | 5440 scheduleMicrotask: [dart.void, [Zone, dart.functionType(dart.dynamic, [])]
], |
5441 createTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.void, []
)]], | 5441 createTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.void, []
)]], |
5442 createPeriodicTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.
void, [Timer])]], | 5442 createPeriodicTimer: [Timer, [Zone, core.Duration, dart.functionType(dart.
void, [Timer])]], |
5443 print: [dart.void, [Zone, core.String]], | 5443 print: [dart.void, [Zone, core.String]], |
5444 fork: [Zone, [Zone, ZoneSpecification, core.Map]] | 5444 fork: [Zone, [Zone, ZoneSpecification, core.Map]] |
5445 }) | 5445 }) |
5446 }); | 5446 }); |
5447 let _delegateCache = Symbol('_delegateCache'); | 5447 let _delegateCache = Symbol('_delegateCache'); |
5448 class _CustomZone extends _Zone { | 5448 class _CustomZone extends _Zone { |
5449 get [_delegate]() { | 5449 get [_delegate]() { |
5450 if (this[_delegateCache] != null) | 5450 if (this[_delegateCache] != null) |
(...skipping 184 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5635 print(line) { | 5635 print(line) { |
5636 let implementation = this[_print]; | 5636 let implementation = this[_print]; |
5637 dart.assert(implementation != null); | 5637 dart.assert(implementation != null); |
5638 let parentDelegate = _parentDelegate(implementation.zone); | 5638 let parentDelegate = _parentDelegate(implementation.zone); |
5639 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, line); | 5639 return dart.dcall(implementation.function, implementation.zone, parentDele
gate, this, line); |
5640 } | 5640 } |
5641 } | 5641 } |
5642 dart.setSignature(_CustomZone, { | 5642 dart.setSignature(_CustomZone, { |
5643 constructors: () => ({_CustomZone: [_CustomZone, [_Zone, ZoneSpecification,
core.Map]]}), | 5643 constructors: () => ({_CustomZone: [_CustomZone, [_Zone, ZoneSpecification,
core.Map]]}), |
5644 methods: () => ({ | 5644 methods: () => ({ |
5645 runGuarded: [core.Object, [dart.functionType(core.Object, [])]], | 5645 runGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [])]], |
5646 runUnaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.botto
m]), core.Object]], | 5646 runUnaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dyn
amic]), dart.dynamic]], |
5647 runBinaryGuarded: [core.Object, [dart.functionType(core.Object, [dart.bott
om, dart.bottom]), core.Object, core.Object]], | 5647 runBinaryGuarded: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dy
namic, dart.dynamic]), dart.dynamic, dart.dynamic]], |
5648 bindCallback: [ZoneCallback, [dart.functionType(core.Object, [])], {runGua
rded: core.bool}], | 5648 bindCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])], {runGu
arded: core.bool}], |
5649 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object, [da
rt.bottom])], {runGuarded: core.bool}], | 5649 bindUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic, [d
art.dynamic])], {runGuarded: core.bool}], |
5650 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Object, [
dart.bottom, dart.bottom])], {runGuarded: core.bool}], | 5650 bindBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynamic,
[dart.dynamic, dart.dynamic])], {runGuarded: core.bool}], |
5651 get: [core.Object, [core.Object]], | 5651 get: [dart.dynamic, [core.Object]], |
5652 handleUncaughtError: [core.Object, [core.Object, core.StackTrace]], | 5652 handleUncaughtError: [dart.dynamic, [dart.dynamic, core.StackTrace]], |
5653 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}]
, | 5653 fork: [Zone, [], {specification: ZoneSpecification, zoneValues: core.Map}]
, |
5654 run: [core.Object, [dart.functionType(core.Object, [])]], | 5654 run: [dart.dynamic, [dart.functionType(dart.dynamic, [])]], |
5655 runUnary: [core.Object, [dart.functionType(core.Object, [dart.bottom]), co
re.Object]], | 5655 runUnary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic]),
dart.dynamic]], |
5656 runBinary: [core.Object, [dart.functionType(core.Object, [dart.bottom, dar
t.bottom]), core.Object, core.Object]], | 5656 runBinary: [dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynamic,
dart.dynamic]), dart.dynamic, dart.dynamic]], |
5657 registerCallback: [ZoneCallback, [dart.functionType(core.Object, [])]], | 5657 registerCallback: [ZoneCallback, [dart.functionType(dart.dynamic, [])]], |
5658 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(core.Object,
[dart.bottom])]], | 5658 registerUnaryCallback: [ZoneUnaryCallback, [dart.functionType(dart.dynamic
, [dart.dynamic])]], |
5659 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(core.Objec
t, [dart.bottom, dart.bottom])]], | 5659 registerBinaryCallback: [ZoneBinaryCallback, [dart.functionType(dart.dynam
ic, [dart.dynamic, dart.dynamic])]], |
5660 errorCallback: [AsyncError, [core.Object, core.StackTrace]], | 5660 errorCallback: [AsyncError, [core.Object, core.StackTrace]], |
5661 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], | 5661 scheduleMicrotask: [dart.void, [dart.functionType(dart.void, [])]], |
5662 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], | 5662 createTimer: [Timer, [core.Duration, dart.functionType(dart.void, [])]], |
5663 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], | 5663 createPeriodicTimer: [Timer, [core.Duration, dart.functionType(dart.void,
[Timer])]], |
5664 print: [dart.void, [core.String]] | 5664 print: [dart.void, [core.String]] |
5665 }) | 5665 }) |
5666 }); | 5666 }); |
5667 function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) { | 5667 function _rootHandleUncaughtError(self, parent, zone, error, stackTrace) { |
5668 _schedulePriorityAsyncCallback(dart.fn(() => { | 5668 _schedulePriorityAsyncCallback(dart.fn(() => { |
5669 throw new _UncaughtAsyncError(error, stackTrace); | 5669 throw new _UncaughtAsyncError(error, stackTrace); |
5670 })); | 5670 })); |
5671 } | 5671 } |
5672 dart.fn(_rootHandleUncaughtError, dart.void, [Zone, ZoneDelegate, Zone, core.O
bject, core.StackTrace]); | 5672 dart.fn(_rootHandleUncaughtError, dart.void, [Zone, ZoneDelegate, Zone, dart.d
ynamic, core.StackTrace]); |
5673 function _rootRun(self, parent, zone, f) { | 5673 function _rootRun(self, parent, zone, f) { |
5674 if (dart.equals(Zone._current, zone)) | 5674 if (dart.equals(Zone._current, zone)) |
5675 return f(); | 5675 return f(); |
5676 let old = Zone._enter(zone); | 5676 let old = Zone._enter(zone); |
5677 try { | 5677 try { |
5678 return f(); | 5678 return f(); |
5679 } finally { | 5679 } finally { |
5680 Zone._leave(old); | 5680 Zone._leave(old); |
5681 } | 5681 } |
5682 } | 5682 } |
5683 dart.fn(_rootRun, core.Object, [Zone, ZoneDelegate, Zone, dart.functionType(co
re.Object, [])]); | 5683 dart.fn(_rootRun, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionType(d
art.dynamic, [])]); |
5684 function _rootRunUnary(self, parent, zone, f, arg) { | 5684 function _rootRunUnary(self, parent, zone, f, arg) { |
5685 if (dart.equals(Zone._current, zone)) | 5685 if (dart.equals(Zone._current, zone)) |
5686 return dart.dcall(f, arg); | 5686 return dart.dcall(f, arg); |
5687 let old = Zone._enter(zone); | 5687 let old = Zone._enter(zone); |
5688 try { | 5688 try { |
5689 return dart.dcall(f, arg); | 5689 return dart.dcall(f, arg); |
5690 } finally { | 5690 } finally { |
5691 Zone._leave(old); | 5691 Zone._leave(old); |
5692 } | 5692 } |
5693 } | 5693 } |
5694 dart.fn(_rootRunUnary, core.Object, [Zone, ZoneDelegate, Zone, dart.functionTy
pe(core.Object, [dart.bottom]), core.Object]); | 5694 dart.fn(_rootRunUnary, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.functionT
ype(dart.dynamic, [dart.dynamic]), dart.dynamic]); |
5695 function _rootRunBinary(self, parent, zone, f, arg1, arg2) { | 5695 function _rootRunBinary(self, parent, zone, f, arg1, arg2) { |
5696 if (dart.equals(Zone._current, zone)) | 5696 if (dart.equals(Zone._current, zone)) |
5697 return dart.dcall(f, arg1, arg2); | 5697 return dart.dcall(f, arg1, arg2); |
5698 let old = Zone._enter(zone); | 5698 let old = Zone._enter(zone); |
5699 try { | 5699 try { |
5700 return dart.dcall(f, arg1, arg2); | 5700 return dart.dcall(f, arg1, arg2); |
5701 } finally { | 5701 } finally { |
5702 Zone._leave(old); | 5702 Zone._leave(old); |
5703 } | 5703 } |
5704 } | 5704 } |
5705 dart.fn(_rootRunBinary, core.Object, [Zone, ZoneDelegate, Zone, dart.functionT
ype(core.Object, [dart.bottom, dart.bottom]), core.Object, core.Object]); | 5705 dart.fn(_rootRunBinary, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.function
Type(dart.dynamic, [dart.dynamic, dart.dynamic]), dart.dynamic, dart.dynamic]); |
5706 function _rootRegisterCallback(self, parent, zone, f) { | 5706 function _rootRegisterCallback(self, parent, zone, f) { |
5707 return f; | 5707 return f; |
5708 } | 5708 } |
5709 dart.fn(_rootRegisterCallback, ZoneCallback, [Zone, ZoneDelegate, Zone, dart.f
unctionType(core.Object, [])]); | 5709 dart.fn(_rootRegisterCallback, ZoneCallback, [Zone, ZoneDelegate, Zone, dart.f
unctionType(dart.dynamic, [])]); |
5710 function _rootRegisterUnaryCallback(self, parent, zone, f) { | 5710 function _rootRegisterUnaryCallback(self, parent, zone, f) { |
5711 return f; | 5711 return f; |
5712 } | 5712 } |
5713 dart.fn(_rootRegisterUnaryCallback, ZoneUnaryCallback, [Zone, ZoneDelegate, Zo
ne, dart.functionType(core.Object, [dart.bottom])]); | 5713 dart.fn(_rootRegisterUnaryCallback, ZoneUnaryCallback, [Zone, ZoneDelegate, Zo
ne, dart.functionType(dart.dynamic, [dart.dynamic])]); |
5714 function _rootRegisterBinaryCallback(self, parent, zone, f) { | 5714 function _rootRegisterBinaryCallback(self, parent, zone, f) { |
5715 return f; | 5715 return f; |
5716 } | 5716 } |
5717 dart.fn(_rootRegisterBinaryCallback, ZoneBinaryCallback, [Zone, ZoneDelegate,
Zone, dart.functionType(core.Object, [dart.bottom, dart.bottom])]); | 5717 dart.fn(_rootRegisterBinaryCallback, ZoneBinaryCallback, [Zone, ZoneDelegate,
Zone, dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic])]); |
5718 function _rootErrorCallback(self, parent, zone, error, stackTrace) { | 5718 function _rootErrorCallback(self, parent, zone, error, stackTrace) { |
5719 return null; | 5719 return null; |
5720 } | 5720 } |
5721 dart.fn(_rootErrorCallback, AsyncError, [Zone, ZoneDelegate, Zone, core.Object
, core.StackTrace]); | 5721 dart.fn(_rootErrorCallback, AsyncError, [Zone, ZoneDelegate, Zone, core.Object
, core.StackTrace]); |
5722 function _rootScheduleMicrotask(self, parent, zone, f) { | 5722 function _rootScheduleMicrotask(self, parent, zone, f) { |
5723 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { | 5723 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { |
5724 let hasErrorHandler = !dart.notNull(_ROOT_ZONE.inSameErrorZone(zone)); | 5724 let hasErrorHandler = !dart.notNull(_ROOT_ZONE.inSameErrorZone(zone)); |
5725 f = zone.bindCallback(f, {runGuarded: hasErrorHandler}); | 5725 f = zone.bindCallback(f, {runGuarded: hasErrorHandler}); |
5726 } | 5726 } |
5727 _scheduleAsyncCallback(f); | 5727 _scheduleAsyncCallback(f); |
5728 } | 5728 } |
5729 dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(core.Object, [])]); | 5729 dart.fn(_rootScheduleMicrotask, dart.void, [Zone, ZoneDelegate, Zone, dart.fun
ctionType(dart.dynamic, [])]); |
5730 function _rootCreateTimer(self, parent, zone, duration, callback) { | 5730 function _rootCreateTimer(self, parent, zone, duration, callback) { |
5731 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { | 5731 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { |
5732 callback = zone.bindCallback(callback); | 5732 callback = zone.bindCallback(callback); |
5733 } | 5733 } |
5734 return Timer._createTimer(duration, callback); | 5734 return Timer._createTimer(duration, callback); |
5735 } | 5735 } |
5736 dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dar
t.functionType(dart.void, [])]); | 5736 dart.fn(_rootCreateTimer, Timer, [Zone, ZoneDelegate, Zone, core.Duration, dar
t.functionType(dart.void, [])]); |
5737 function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) { | 5737 function _rootCreatePeriodicTimer(self, parent, zone, duration, callback) { |
5738 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { | 5738 if (!dart.notNull(core.identical(_ROOT_ZONE, zone))) { |
5739 callback = dart.as(zone.bindUnaryCallback(callback), __CastType36); | 5739 callback = dart.as(zone.bindUnaryCallback(callback), __CastType36); |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5832 return self.parent.runUnary(dart.as(onError, __CastType38), error); | 5832 return self.parent.runUnary(dart.as(onError, __CastType38), error); |
5833 } catch (e) { | 5833 } catch (e) { |
5834 let s = dart.stackTrace(e); | 5834 let s = dart.stackTrace(e); |
5835 if (dart.notNull(core.identical(e, error))) { | 5835 if (dart.notNull(core.identical(e, error))) { |
5836 return parent.handleUncaughtError(zone, error, stackTrace); | 5836 return parent.handleUncaughtError(zone, error, stackTrace); |
5837 } else { | 5837 } else { |
5838 return parent.handleUncaughtError(zone, e, s); | 5838 return parent.handleUncaughtError(zone, e, s); |
5839 } | 5839 } |
5840 } | 5840 } |
5841 | 5841 |
5842 }, core.Object, [Zone, ZoneDelegate, Zone, core.Object, core.StackTrace]); | 5842 }, dart.dynamic, [Zone, ZoneDelegate, Zone, dart.dynamic, core.StackTrace]
); |
5843 } | 5843 } |
5844 if (zoneSpecification == null) { | 5844 if (zoneSpecification == null) { |
5845 zoneSpecification = ZoneSpecification.new({handleUncaughtError: errorHandl
er}); | 5845 zoneSpecification = ZoneSpecification.new({handleUncaughtError: errorHandl
er}); |
5846 } else if (errorHandler != null) { | 5846 } else if (errorHandler != null) { |
5847 zoneSpecification = ZoneSpecification.from(zoneSpecification, {handleUncau
ghtError: errorHandler}); | 5847 zoneSpecification = ZoneSpecification.from(zoneSpecification, {handleUncau
ghtError: errorHandler}); |
5848 } | 5848 } |
5849 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); | 5849 let zone = Zone.current.fork({specification: zoneSpecification, zoneValues:
zoneValues}); |
5850 if (onError != null) { | 5850 if (onError != null) { |
5851 return zone.runGuarded(body); | 5851 return zone.runGuarded(body); |
5852 } else { | 5852 } else { |
5853 return zone.run(body); | 5853 return zone.run(body); |
5854 } | 5854 } |
5855 } | 5855 } |
5856 dart.fn(runZoned, core.Object, [dart.functionType(core.Object, [])], {zoneValu
es: core.Map, zoneSpecification: ZoneSpecification, onError: core.Function}); | 5856 dart.fn(runZoned, dart.dynamic, [dart.functionType(dart.dynamic, [])], {zoneVa
lues: core.Map, zoneSpecification: ZoneSpecification, onError: core.Function}); |
5857 let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.v
oid, [Timer])); | 5857 let __CastType36 = dart.typedef('__CastType36', () => dart.functionType(dart.v
oid, [Timer])); |
5858 let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(core.O
bject, [dart.bottom])); | 5858 let __CastType38 = dart.typedef('__CastType38', () => dart.functionType(dart.d
ynamic, [dart.dynamic])); |
5859 dart.copyProperties(exports, { | 5859 dart.copyProperties(exports, { |
5860 get _hasDocument() { | 5860 get _hasDocument() { |
5861 return typeof document == 'object'; | 5861 return typeof document == 'object'; |
5862 } | 5862 } |
5863 }); | 5863 }); |
5864 // Exports: | 5864 // Exports: |
5865 exports.AsyncError = AsyncError; | 5865 exports.AsyncError = AsyncError; |
5866 exports.Stream$ = Stream$; | 5866 exports.Stream$ = Stream$; |
5867 exports.Stream = Stream; | 5867 exports.Stream = Stream; |
5868 exports.DeferredLibrary = DeferredLibrary; | 5868 exports.DeferredLibrary = DeferredLibrary; |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5904 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5904 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5905 exports.CreateTimerHandler = CreateTimerHandler; | 5905 exports.CreateTimerHandler = CreateTimerHandler; |
5906 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5906 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5907 exports.PrintHandler = PrintHandler; | 5907 exports.PrintHandler = PrintHandler; |
5908 exports.ForkHandler = ForkHandler; | 5908 exports.ForkHandler = ForkHandler; |
5909 exports.ZoneSpecification = ZoneSpecification; | 5909 exports.ZoneSpecification = ZoneSpecification; |
5910 exports.ZoneDelegate = ZoneDelegate; | 5910 exports.ZoneDelegate = ZoneDelegate; |
5911 exports.Zone = Zone; | 5911 exports.Zone = Zone; |
5912 exports.runZoned = runZoned; | 5912 exports.runZoned = runZoned; |
5913 }); | 5913 }); |
OLD | NEW |