| OLD | NEW |
| 1 var async; | 1 var async; |
| 2 (function(exports) { | 2 (function(exports) { |
| 3 'use strict'; | 3 'use strict'; |
| 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic | 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic |
| 5 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 5 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
| 6 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 6 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
| 7 return dart.dcall(errorHandler, error, stackTrace); | 7 return dart.dcall(errorHandler, error, stackTrace); |
| 8 } else { | 8 } else { |
| 9 return dart.dcall(errorHandler, error); | 9 return dart.dcall(errorHandler, error); |
| 10 } | 10 } |
| (...skipping 426 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 437 }, { | 437 }, { |
| 438 onError: future[_completeError], | 438 onError: future[_completeError], |
| 439 onDone: () => { | 439 onDone: () => { |
| 440 future[_complete](true); | 440 future[_complete](true); |
| 441 }, | 441 }, |
| 442 cancelOnError: true | 442 cancelOnError: true |
| 443 }); | 443 }); |
| 444 return future; | 444 return future; |
| 445 } | 445 } |
| 446 toList() { | 446 toList() { |
| 447 let result = new core.List$(T).from([]); | 447 let result = dart.setType([], core.List$(T)); |
| 448 let future = new (_Future$(core.List$(T)))(); | 448 let future = new (_Future$(core.List$(T)))(); |
| 449 this.listen(data => { | 449 this.listen(data => { |
| 450 result[core.$add](data); | 450 result[core.$add](data); |
| 451 }, { | 451 }, { |
| 452 onError: future[_completeError], | 452 onError: future[_completeError], |
| 453 onDone: () => { | 453 onDone: () => { |
| 454 future[_complete](result); | 454 future[_complete](result); |
| 455 }, | 455 }, |
| 456 cancelOnError: true | 456 cancelOnError: true |
| 457 }); | 457 }); |
| (...skipping 1338 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1796 dart.dcall(cleanUp, value); | 1796 dart.dcall(cleanUp, value); |
| 1797 }); | 1797 }); |
| 1798 } | 1798 } |
| 1799 if (remaining == 0 && !dart.notNull(eagerError)) { | 1799 if (remaining == 0 && !dart.notNull(eagerError)) { |
| 1800 result[_completeError](error, stackTrace); | 1800 result[_completeError](error, stackTrace); |
| 1801 } | 1801 } |
| 1802 } | 1802 } |
| 1803 }, {onError: handleError}); | 1803 }, {onError: handleError}); |
| 1804 } | 1804 } |
| 1805 if (remaining == 0) { | 1805 if (remaining == 0) { |
| 1806 return new Future$(core.List).value(/* Unimplemented const */new core.
List.from([])); | 1806 return new Future$(core.List).value(/* Unimplemented const */[]); |
| 1807 } | 1807 } |
| 1808 values = new core.List(remaining); | 1808 values = new core.List(remaining); |
| 1809 return result; | 1809 return result; |
| 1810 } | 1810 } |
| 1811 static forEach(input, f) { | 1811 static forEach(input, f) { |
| 1812 let iterator = input[core.$iterator]; | 1812 let iterator = input[core.$iterator]; |
| 1813 return Future.doWhile(() => { | 1813 return Future.doWhile(() => { |
| 1814 if (!dart.notNull(iterator.moveNext())) | 1814 if (!dart.notNull(iterator.moveNext())) |
| 1815 return false; | 1815 return false; |
| 1816 return new Future.sync(() => dart.dcall(f, iterator.current)).then(_ =
> true); | 1816 return new Future.sync(() => dart.dcall(f, iterator.current)).then(_ =
> true); |
| (...skipping 3433 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5250 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5250 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
| 5251 exports.CreateTimerHandler = CreateTimerHandler; | 5251 exports.CreateTimerHandler = CreateTimerHandler; |
| 5252 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5252 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
| 5253 exports.PrintHandler = PrintHandler; | 5253 exports.PrintHandler = PrintHandler; |
| 5254 exports.ForkHandler = ForkHandler; | 5254 exports.ForkHandler = ForkHandler; |
| 5255 exports.ZoneSpecification = ZoneSpecification; | 5255 exports.ZoneSpecification = ZoneSpecification; |
| 5256 exports.ZoneDelegate = ZoneDelegate; | 5256 exports.ZoneDelegate = ZoneDelegate; |
| 5257 exports.Zone = Zone; | 5257 exports.Zone = Zone; |
| 5258 exports.runZoned = runZoned; | 5258 exports.runZoned = runZoned; |
| 5259 })(async || (async = {})); | 5259 })(async || (async = {})); |
| OLD | NEW |