| 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 800 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 811 } | 811 } |
| 812 dart.defineNamedConstructor(Stream, 'fromFuture'); | 812 dart.defineNamedConstructor(Stream, 'fromFuture'); |
| 813 dart.defineNamedConstructor(Stream, 'fromIterable'); | 813 dart.defineNamedConstructor(Stream, 'fromIterable'); |
| 814 dart.defineNamedConstructor(Stream, 'periodic'); | 814 dart.defineNamedConstructor(Stream, 'periodic'); |
| 815 dart.defineNamedConstructor(Stream, 'eventTransformed'); | 815 dart.defineNamedConstructor(Stream, 'eventTransformed'); |
| 816 return Stream; | 816 return Stream; |
| 817 }); | 817 }); |
| 818 let Stream = Stream$(); | 818 let Stream = Stream$(); |
| 819 let _StreamImpl$ = dart.generic(function(T) { | 819 let _StreamImpl$ = dart.generic(function(T) { |
| 820 class _StreamImpl extends Stream$(T) { | 820 class _StreamImpl extends Stream$(T) { |
| 821 _StreamImpl() { |
| 822 super.Stream(); |
| 823 } |
| 821 listen(onData, opts) { | 824 listen(onData, opts) { |
| 822 dart.as(onData, dart.functionType(dart.void, [T])); | 825 dart.as(onData, dart.functionType(dart.void, [T])); |
| 823 let onError = opts && 'onError' in opts ? opts.onError : null; | 826 let onError = opts && 'onError' in opts ? opts.onError : null; |
| 824 let onDone = opts && 'onDone' in opts ? opts.onDone : null; | 827 let onDone = opts && 'onDone' in opts ? opts.onDone : null; |
| 825 dart.as(onDone, dart.functionType(dart.void, [])); | 828 dart.as(onDone, dart.functionType(dart.void, [])); |
| 826 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 829 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
| 827 cancelOnError = core.identical(true, cancelOnError); | 830 cancelOnError = core.identical(true, cancelOnError); |
| 828 let subscription = this[_createSubscription](onData, onError, onDone, ca
ncelOnError); | 831 let subscription = this[_createSubscription](onData, onError, onDone, ca
ncelOnError); |
| 829 this[_onListen](subscription); | 832 this[_onListen](subscription); |
| 830 return dart.as(subscription, StreamSubscription$(T)); | 833 return dart.as(subscription, StreamSubscription$(T)); |
| (...skipping 1151 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1982 return !dart.notNull(this.future[_mayComplete]); | 1985 return !dart.notNull(this.future[_mayComplete]); |
| 1983 } | 1986 } |
| 1984 } | 1987 } |
| 1985 _Completer[dart.implements] = () => [Completer$(T)]; | 1988 _Completer[dart.implements] = () => [Completer$(T)]; |
| 1986 return _Completer; | 1989 return _Completer; |
| 1987 }); | 1990 }); |
| 1988 let _Completer = _Completer$(); | 1991 let _Completer = _Completer$(); |
| 1989 let _asyncCompleteError = Symbol('_asyncCompleteError'); | 1992 let _asyncCompleteError = Symbol('_asyncCompleteError'); |
| 1990 let _AsyncCompleter$ = dart.generic(function(T) { | 1993 let _AsyncCompleter$ = dart.generic(function(T) { |
| 1991 class _AsyncCompleter extends _Completer$(T) { | 1994 class _AsyncCompleter extends _Completer$(T) { |
| 1995 _AsyncCompleter() { |
| 1996 super._Completer(); |
| 1997 } |
| 1992 complete(value) { | 1998 complete(value) { |
| 1993 if (value === void 0) | 1999 if (value === void 0) |
| 1994 value = null; | 2000 value = null; |
| 1995 if (!dart.notNull(this.future[_mayComplete])) | 2001 if (!dart.notNull(this.future[_mayComplete])) |
| 1996 throw new core.StateError("Future already completed"); | 2002 throw new core.StateError("Future already completed"); |
| 1997 this.future[_asyncComplete](value); | 2003 this.future[_asyncComplete](value); |
| 1998 } | 2004 } |
| 1999 [_completeError](error, stackTrace) { | 2005 [_completeError](error, stackTrace) { |
| 2000 this.future[_asyncCompleteError](error, stackTrace); | 2006 this.future[_asyncCompleteError](error, stackTrace); |
| 2001 } | 2007 } |
| 2002 } | 2008 } |
| 2003 return _AsyncCompleter; | 2009 return _AsyncCompleter; |
| 2004 }); | 2010 }); |
| 2005 let _AsyncCompleter = _AsyncCompleter$(); | 2011 let _AsyncCompleter = _AsyncCompleter$(); |
| 2006 let _SyncCompleter$ = dart.generic(function(T) { | 2012 let _SyncCompleter$ = dart.generic(function(T) { |
| 2007 class _SyncCompleter extends _Completer$(T) { | 2013 class _SyncCompleter extends _Completer$(T) { |
| 2014 _SyncCompleter() { |
| 2015 super._Completer(); |
| 2016 } |
| 2008 complete(value) { | 2017 complete(value) { |
| 2009 if (value === void 0) | 2018 if (value === void 0) |
| 2010 value = null; | 2019 value = null; |
| 2011 if (!dart.notNull(this.future[_mayComplete])) | 2020 if (!dart.notNull(this.future[_mayComplete])) |
| 2012 throw new core.StateError("Future already completed"); | 2021 throw new core.StateError("Future already completed"); |
| 2013 this.future[_complete](value); | 2022 this.future[_complete](value); |
| 2014 } | 2023 } |
| 2015 [_completeError](error, stackTrace) { | 2024 [_completeError](error, stackTrace) { |
| 2016 this.future[_completeError](error, stackTrace); | 2025 this.future[_completeError](error, stackTrace); |
| 2017 } | 2026 } |
| (...skipping 3341 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5359 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5368 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
| 5360 exports.CreateTimerHandler = CreateTimerHandler; | 5369 exports.CreateTimerHandler = CreateTimerHandler; |
| 5361 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5370 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
| 5362 exports.PrintHandler = PrintHandler; | 5371 exports.PrintHandler = PrintHandler; |
| 5363 exports.ForkHandler = ForkHandler; | 5372 exports.ForkHandler = ForkHandler; |
| 5364 exports.ZoneSpecification = ZoneSpecification; | 5373 exports.ZoneSpecification = ZoneSpecification; |
| 5365 exports.ZoneDelegate = ZoneDelegate; | 5374 exports.ZoneDelegate = ZoneDelegate; |
| 5366 exports.Zone = Zone; | 5375 exports.Zone = Zone; |
| 5367 exports.runZoned = runZoned; | 5376 exports.runZoned = runZoned; |
| 5368 })(async || (async = {})); | 5377 })(async || (async = {})); |
| OLD | NEW |