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

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

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

Powered by Google App Engine
This is Rietveld 408576698