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

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

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

Powered by Google App Engine
This is Rietveld 408576698