| OLD | NEW |
| 1 var async; | 1 var async; |
| 2 (function(async) { | 2 (function(async) { |
| 3 'use strict'; | 3 'use strict'; |
| 4 dart.copyProperties(async, { | 4 dart.copyProperties(async, { |
| 5 get _hasDocument() { | 5 get _hasDocument() { |
| 6 return dart.equals(dart.dinvokef(/* Unimplemented unknown name */JS, 'Stri
ng', 'typeof document'), 'object'); | 6 return dart.equals(dart.dinvokef(/* Unimplemented unknown name */JS, 'Stri
ng', 'typeof document'), 'object'); |
| 7 } | 7 } |
| 8 }); | 8 }); |
| 9 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic | 9 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic |
| 10 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 10 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
| (...skipping 1308 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1319 // Function scheduleMicrotask: (() → void) → void | 1319 // Function scheduleMicrotask: (() → void) → void |
| 1320 function scheduleMicrotask(callback) { | 1320 function scheduleMicrotask(callback) { |
| 1321 if (core.identical(_ROOT_ZONE, Zone.current)) { | 1321 if (core.identical(_ROOT_ZONE, Zone.current)) { |
| 1322 _rootScheduleMicrotask(null, null, dart.as(_ROOT_ZONE, Zone), callback); | 1322 _rootScheduleMicrotask(null, null, dart.as(_ROOT_ZONE, Zone), callback); |
| 1323 return; | 1323 return; |
| 1324 } | 1324 } |
| 1325 Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuard
ed: true})); | 1325 Zone.current.scheduleMicrotask(Zone.current.bindCallback(callback, {runGuard
ed: true})); |
| 1326 } | 1326 } |
| 1327 class _AsyncRun extends dart.Object { | 1327 class _AsyncRun extends dart.Object { |
| 1328 static _scheduleImmediate(callback) { | 1328 static _scheduleImmediate(callback) { |
| 1329 dart.dinvokef(/* Unimplemented unknown name */scheduleImmediateClosure, ca
llback); | 1329 dart.dinvokef(scheduleImmediateClosure, callback); |
| 1330 } |
| 1331 static _initializeScheduleImmediate() { |
| 1332 dart.dinvokef(/* Unimplemented unknown name */requiresPreamble); |
| 1333 if (dart.dinvokef(/* Unimplemented unknown name */JS, '', 'self.scheduleIm
mediate') !== null) { |
| 1334 return _scheduleImmediateJsOverride; |
| 1335 } |
| 1336 if (dart.notNull(dart.dinvokef(/* Unimplemented unknown name */JS, '', 'se
lf.MutationObserver') !== null) && dart.notNull(dart.dinvokef(/* Unimplemented u
nknown name */JS, '', 'self.document') !== null)) { |
| 1337 let div = dart.dinvokef(/* Unimplemented unknown name */JS, '', 'self.do
cument.createElement("div")'); |
| 1338 let span = dart.dinvokef(/* Unimplemented unknown name */JS, '', 'self.d
ocument.createElement("span")'); |
| 1339 let storedCallback = null; |
| 1340 // Function internalCallback: (dynamic) → dynamic |
| 1341 function internalCallback(_) { |
| 1342 dart.dinvokef(/* Unimplemented unknown name */leaveJsAsync); |
| 1343 let f = storedCallback; |
| 1344 storedCallback = null; |
| 1345 dart.dinvokef(f); |
| 1346 } |
| 1347 ; |
| 1348 let observer = dart.dinvokef(/* Unimplemented unknown name */JS, '', 'ne
w self.MutationObserver(#)', dart.dinvokef(/* Unimplemented unknown name */conve
rtDartClosureToJS, internalCallback, 1)); |
| 1349 dart.dinvokef(/* Unimplemented unknown name */JS, '', '#.observe(#, { ch
ildList: true })', observer, div); |
| 1350 return (callback) => { |
| 1351 dart.assert(storedCallback === null); |
| 1352 dart.dinvokef(/* Unimplemented unknown name */enterJsAsync); |
| 1353 storedCallback = callback; |
| 1354 dart.dinvokef(/* Unimplemented unknown name */JS, '', '#.firstChild ?
#.removeChild(#): #.appendChild(#)', div, div, span, div, span); |
| 1355 }; |
| 1356 } else if (dart.dinvokef(/* Unimplemented unknown name */JS, '', 'self.set
Immediate') !== null) { |
| 1357 return _scheduleImmediateWithSetImmediate; |
| 1358 } |
| 1359 return _scheduleImmediateWithTimer; |
| 1360 } |
| 1361 static _scheduleImmediateJsOverride(callback) { |
| 1362 // Function internalCallback: () → dynamic |
| 1363 function internalCallback() { |
| 1364 dart.dinvokef(/* Unimplemented unknown name */leaveJsAsync); |
| 1365 callback(); |
| 1366 } |
| 1367 ; |
| 1368 dart.dinvokef(/* Unimplemented unknown name */enterJsAsync); |
| 1369 dart.dinvokef(/* Unimplemented unknown name */JS, 'void', 'self.scheduleIm
mediate(#)', dart.dinvokef(/* Unimplemented unknown name */convertDartClosureToJ
S, internalCallback, 0)); |
| 1370 } |
| 1371 static _scheduleImmediateWithSetImmediate(callback) { |
| 1372 // Function internalCallback: () → dynamic |
| 1373 function internalCallback() { |
| 1374 dart.dinvokef(/* Unimplemented unknown name */leaveJsAsync); |
| 1375 callback(); |
| 1376 } |
| 1377 ; |
| 1378 dart.dinvokef(/* Unimplemented unknown name */enterJsAsync); |
| 1379 dart.dinvokef(/* Unimplemented unknown name */JS, 'void', 'self.setImmedia
te(#)', dart.dinvokef(/* Unimplemented unknown name */convertDartClosureToJS, in
ternalCallback, 0)); |
| 1380 } |
| 1381 static _scheduleImmediateWithTimer(callback) { |
| 1382 Timer._createTimer(core.Duration.ZERO, callback); |
| 1330 } | 1383 } |
| 1331 } | 1384 } |
| 1385 dart.defineLazyProperties(_AsyncRun, { |
| 1386 get scheduleImmediateClosure() { |
| 1387 return _initializeScheduleImmediate(); |
| 1388 } |
| 1389 }); |
| 1332 let Stream$ = dart.generic(function(T) { | 1390 let Stream$ = dart.generic(function(T) { |
| 1333 class Stream extends dart.Object { | 1391 class Stream extends dart.Object { |
| 1334 Stream() { | 1392 Stream() { |
| 1335 } | 1393 } |
| 1336 Stream$fromFuture(future) { | 1394 Stream$fromFuture(future) { |
| 1337 let controller = dart.as(new StreamController({sync: true}), _StreamCont
roller$(T)); | 1395 let controller = dart.as(new StreamController({sync: true}), _StreamCont
roller$(T)); |
| 1338 future.then(((value) => { | 1396 future.then(((value) => { |
| 1339 controller._add(dart.as(value, T)); | 1397 controller._add(dart.as(value, T)); |
| 1340 controller._closeUnchecked(); | 1398 controller._closeUnchecked(); |
| 1341 }).bind(this), {onError: ((error, stackTrace) => { | 1399 }).bind(this), {onError: ((error, stackTrace) => { |
| (...skipping 3381 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4723 async.StreamIterator$ = StreamIterator$; | 4781 async.StreamIterator$ = StreamIterator$; |
| 4724 async.StreamController = StreamController; | 4782 async.StreamController = StreamController; |
| 4725 async.StreamController$ = StreamController$; | 4783 async.StreamController$ = StreamController$; |
| 4726 async.Timer = Timer; | 4784 async.Timer = Timer; |
| 4727 async.AsyncError = AsyncError; | 4785 async.AsyncError = AsyncError; |
| 4728 async.ZoneSpecification = ZoneSpecification; | 4786 async.ZoneSpecification = ZoneSpecification; |
| 4729 async.ZoneDelegate = ZoneDelegate; | 4787 async.ZoneDelegate = ZoneDelegate; |
| 4730 async.Zone = Zone; | 4788 async.Zone = Zone; |
| 4731 async.runZoned = runZoned; | 4789 async.runZoned = runZoned; |
| 4732 })(async || (async = {})); | 4790 })(async || (async = {})); |
| OLD | NEW |