| 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.dinvokef(errorHandler, error, stackTrace); | 7 return dart.dinvokef(errorHandler, error, stackTrace); |
| 8 } else { | 8 } else { |
| 9 return dart.dinvokef(errorHandler, error); | 9 return dart.dinvokef(errorHandler, error); |
| 10 } | 10 } |
| (...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 117 }).bind(this)}); | 117 }).bind(this)}); |
| 118 return controller.stream; | 118 return controller.stream; |
| 119 } | 119 } |
| 120 Stream$eventTransformed(source, mapSink) { | 120 Stream$eventTransformed(source, mapSink) { |
| 121 return dart.as(new _BoundSinkStream(source, dart.closureWrap(mapSink, "(
EventSink<dynamic>) → EventSink")), Stream$(T)); | 121 return dart.as(new _BoundSinkStream(source, dart.closureWrap(mapSink, "(
EventSink<dynamic>) → EventSink")), Stream$(T)); |
| 122 } | 122 } |
| 123 get isBroadcast() { | 123 get isBroadcast() { |
| 124 return false; | 124 return false; |
| 125 } | 125 } |
| 126 asBroadcastStream(opt$) { | 126 asBroadcastStream(opt$) { |
| 127 let onListen = opt$.onListen === void 0 ? null : opt$.onListen; | 127 let onListen = opt$ && 'onListen' in opt$ ? opt$.onListen : null; |
| 128 let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel; | 128 let onCancel = opt$ && 'onCancel' in opt$ ? opt$.onCancel : null; |
| 129 return new _AsBroadcastStream(this, dart.closureWrap(onListen, "(StreamS
ubscription<dynamic>) → void"), dart.closureWrap(onCancel, "(StreamSubscription<
dynamic>) → void")); | 129 return new _AsBroadcastStream(this, dart.closureWrap(onListen, "(StreamS
ubscription<dynamic>) → void"), dart.closureWrap(onCancel, "(StreamSubscription<
dynamic>) → void")); |
| 130 } | 130 } |
| 131 where(test) { | 131 where(test) { |
| 132 return new _WhereStream(this, test); | 132 return new _WhereStream(this, test); |
| 133 } | 133 } |
| 134 map(convert) { | 134 map(convert) { |
| 135 return new _MapStream(this, convert); | 135 return new _MapStream(this, convert); |
| 136 } | 136 } |
| 137 asyncMap(convert) { | 137 asyncMap(convert) { |
| 138 let controller = null; | 138 let controller = null; |
| (...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 208 subscription.pause(); | 208 subscription.pause(); |
| 209 }).bind(this), onResume: (() => { | 209 }).bind(this), onResume: (() => { |
| 210 subscription.resume(); | 210 subscription.resume(); |
| 211 }).bind(this), onCancel: (() => { | 211 }).bind(this), onCancel: (() => { |
| 212 subscription.cancel(); | 212 subscription.cancel(); |
| 213 }).bind(this), sync: true}); | 213 }).bind(this), sync: true}); |
| 214 } | 214 } |
| 215 return controller.stream; | 215 return controller.stream; |
| 216 } | 216 } |
| 217 handleError(onError, opt$) { | 217 handleError(onError, opt$) { |
| 218 let test = opt$.test === void 0 ? null : opt$.test; | 218 let test = opt$ && 'test' in opt$ ? opt$.test : null; |
| 219 return new _HandleErrorStream(this, onError, test); | 219 return new _HandleErrorStream(this, onError, test); |
| 220 } | 220 } |
| 221 expand(convert) { | 221 expand(convert) { |
| 222 return new _ExpandStream(this, convert); | 222 return new _ExpandStream(this, convert); |
| 223 } | 223 } |
| 224 pipe(streamConsumer) { | 224 pipe(streamConsumer) { |
| 225 return streamConsumer.addStream(this).then(((_) => streamConsumer.close(
)).bind(this)); | 225 return streamConsumer.addStream(this).then(((_) => streamConsumer.close(
)).bind(this)); |
| 226 } | 226 } |
| 227 transform(streamTransformer) { | 227 transform(streamTransformer) { |
| 228 return streamTransformer.bind(this); | 228 return streamTransformer.bind(this); |
| (...skipping 253 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 482 throw _internal.IterableElementError.noElement(); | 482 throw _internal.IterableElementError.noElement(); |
| 483 } catch (e) { | 483 } catch (e) { |
| 484 let s = dart.stackTrace(e); | 484 let s = dart.stackTrace(e); |
| 485 _completeWithErrorCallback(future, e, s); | 485 _completeWithErrorCallback(future, e, s); |
| 486 } | 486 } |
| 487 | 487 |
| 488 }).bind(this), cancelOnError: true}); | 488 }).bind(this), cancelOnError: true}); |
| 489 return future; | 489 return future; |
| 490 } | 490 } |
| 491 firstWhere(test, opt$) { | 491 firstWhere(test, opt$) { |
| 492 let defaultValue = opt$.defaultValue === void 0 ? null : opt$.defaultVal
ue; | 492 let defaultValue = opt$ && 'defaultValue' in opt$ ? opt$.defaultValue :
null; |
| 493 let future = new _Future(); | 493 let future = new _Future(); |
| 494 let subscription = null; | 494 let subscription = null; |
| 495 subscription = this.listen((value) => { | 495 subscription = this.listen((value) => { |
| 496 _runUserCode(() => test(value), (isMatch) => { | 496 _runUserCode(() => test(value), (isMatch) => { |
| 497 if (isMatch) { | 497 if (isMatch) { |
| 498 _cancelAndValue(subscription, future, value); | 498 _cancelAndValue(subscription, future, value); |
| 499 } | 499 } |
| 500 }, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("
Unimplemented type (dynamic, StackTrace) → dynamic"))); | 500 }, dart.as(_cancelAndErrorClosure(subscription, future), dart.throw_("
Unimplemented type (dynamic, StackTrace) → dynamic"))); |
| 501 }, {onError: future[_completeError], onDone: (() => { | 501 }, {onError: future[_completeError], onDone: (() => { |
| 502 if (defaultValue !== null) { | 502 if (defaultValue !== null) { |
| 503 _runUserCode(defaultValue, future[_complete], future[_completeErro
r]); | 503 _runUserCode(defaultValue, future[_complete], future[_completeErro
r]); |
| 504 return; | 504 return; |
| 505 } | 505 } |
| 506 try { | 506 try { |
| 507 throw _internal.IterableElementError.noElement(); | 507 throw _internal.IterableElementError.noElement(); |
| 508 } catch (e) { | 508 } catch (e) { |
| 509 let s = dart.stackTrace(e); | 509 let s = dart.stackTrace(e); |
| 510 _completeWithErrorCallback(future, e, s); | 510 _completeWithErrorCallback(future, e, s); |
| 511 } | 511 } |
| 512 | 512 |
| 513 }).bind(this), cancelOnError: true}); | 513 }).bind(this), cancelOnError: true}); |
| 514 return future; | 514 return future; |
| 515 } | 515 } |
| 516 lastWhere(test, opt$) { | 516 lastWhere(test, opt$) { |
| 517 let defaultValue = opt$.defaultValue === void 0 ? null : opt$.defaultVal
ue; | 517 let defaultValue = opt$ && 'defaultValue' in opt$ ? opt$.defaultValue :
null; |
| 518 let future = new _Future(); | 518 let future = new _Future(); |
| 519 let result = null; | 519 let result = null; |
| 520 let foundResult = false; | 520 let foundResult = false; |
| 521 let subscription = null; | 521 let subscription = null; |
| 522 subscription = this.listen((value) => { | 522 subscription = this.listen((value) => { |
| 523 _runUserCode(() => true === test(value), (isMatch) => { | 523 _runUserCode(() => true === test(value), (isMatch) => { |
| 524 if (isMatch) { | 524 if (isMatch) { |
| 525 foundResult = true; | 525 foundResult = true; |
| 526 result = value; | 526 result = value; |
| 527 } | 527 } |
| (...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 593 _cancelAndValue(subscription, future, value); | 593 _cancelAndValue(subscription, future, value); |
| 594 return; | 594 return; |
| 595 } | 595 } |
| 596 elementIndex = 1; | 596 elementIndex = 1; |
| 597 }, {onError: future[_completeError], onDone: (() => { | 597 }, {onError: future[_completeError], onDone: (() => { |
| 598 future._completeError(new core.RangeError.index(index, this, "index"
, null, elementIndex)); | 598 future._completeError(new core.RangeError.index(index, this, "index"
, null, elementIndex)); |
| 599 }).bind(this), cancelOnError: true}); | 599 }).bind(this), cancelOnError: true}); |
| 600 return future; | 600 return future; |
| 601 } | 601 } |
| 602 timeout(timeLimit, opt$) { | 602 timeout(timeLimit, opt$) { |
| 603 let onTimeout = opt$.onTimeout === void 0 ? null : opt$.onTimeout; | 603 let onTimeout = opt$ && 'onTimeout' in opt$ ? opt$.onTimeout : null; |
| 604 let controller = null; | 604 let controller = null; |
| 605 let subscription = null; | 605 let subscription = null; |
| 606 let timer = null; | 606 let timer = null; |
| 607 let zone = null; | 607 let zone = null; |
| 608 let timeout = null; | 608 let timeout = null; |
| 609 // Function onData: (T) → void | 609 // Function onData: (T) → void |
| 610 function onData(event) { | 610 function onData(event) { |
| 611 timer.cancel(); | 611 timer.cancel(); |
| 612 controller.add(event); | 612 controller.add(event); |
| 613 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.throw_("Unim
plemented type () → void"))); | 613 timer = zone.createTimer(timeLimit, dart.as(timeout, dart.throw_("Unim
plemented type () → void"))); |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 664 dart.defineNamedConstructor(Stream, 'fromFuture'); | 664 dart.defineNamedConstructor(Stream, 'fromFuture'); |
| 665 dart.defineNamedConstructor(Stream, 'fromIterable'); | 665 dart.defineNamedConstructor(Stream, 'fromIterable'); |
| 666 dart.defineNamedConstructor(Stream, 'periodic'); | 666 dart.defineNamedConstructor(Stream, 'periodic'); |
| 667 dart.defineNamedConstructor(Stream, 'eventTransformed'); | 667 dart.defineNamedConstructor(Stream, 'eventTransformed'); |
| 668 return Stream; | 668 return Stream; |
| 669 }); | 669 }); |
| 670 let Stream = Stream$(dart.dynamic); | 670 let Stream = Stream$(dart.dynamic); |
| 671 let _StreamImpl$ = dart.generic(function(T) { | 671 let _StreamImpl$ = dart.generic(function(T) { |
| 672 class _StreamImpl extends Stream$(T) { | 672 class _StreamImpl extends Stream$(T) { |
| 673 listen(onData, opt$) { | 673 listen(onData, opt$) { |
| 674 let onError = opt$.onError === void 0 ? null : opt$.onError; | 674 let onError = opt$ && 'onError' in opt$ ? opt$.onError : null; |
| 675 let onDone = opt$.onDone === void 0 ? null : opt$.onDone; | 675 let onDone = opt$ && 'onDone' in opt$ ? opt$.onDone : null; |
| 676 let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOn
Error; | 676 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: null; |
| 677 cancelOnError = core.identical(true, cancelOnError); | 677 cancelOnError = core.identical(true, cancelOnError); |
| 678 let subscription = this[_createSubscription](onData, onError, onDone, ca
ncelOnError); | 678 let subscription = this[_createSubscription](onData, onError, onDone, ca
ncelOnError); |
| 679 this[_onListen](subscription); | 679 this[_onListen](subscription); |
| 680 return dart.as(subscription, StreamSubscription$(T)); | 680 return dart.as(subscription, StreamSubscription$(T)); |
| 681 } | 681 } |
| 682 [_createSubscription](onData, onError, onDone, cancelOnError) { | 682 [_createSubscription](onData, onError, onDone, cancelOnError) { |
| 683 return new _BufferingStreamSubscription(onData, onError, onDone, cancelO
nError); | 683 return new _BufferingStreamSubscription(onData, onError, onDone, cancelO
nError); |
| 684 } | 684 } |
| 685 [_onListen](subscription) {} | 685 [_onListen](subscription) {} |
| 686 } | 686 } |
| (...skipping 594 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1281 throw this[_addEventError](); | 1281 throw this[_addEventError](); |
| 1282 this[_state] = _BroadcastStreamController._STATE_CLOSED; | 1282 this[_state] = _BroadcastStreamController._STATE_CLOSED; |
| 1283 let doneFuture = this[_ensureDoneFuture](); | 1283 let doneFuture = this[_ensureDoneFuture](); |
| 1284 this[_sendDone](); | 1284 this[_sendDone](); |
| 1285 return doneFuture; | 1285 return doneFuture; |
| 1286 } | 1286 } |
| 1287 get done() { | 1287 get done() { |
| 1288 return this[_ensureDoneFuture](); | 1288 return this[_ensureDoneFuture](); |
| 1289 } | 1289 } |
| 1290 addStream(stream, opt$) { | 1290 addStream(stream, opt$) { |
| 1291 let cancelOnError = opt$.cancelOnError === void 0 ? true : opt$.cancelOn
Error; | 1291 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: true; |
| 1292 if (!dart.notNull(this[_mayAddEvent])) | 1292 if (!dart.notNull(this[_mayAddEvent])) |
| 1293 throw this[_addEventError](); | 1293 throw this[_addEventError](); |
| 1294 this[_state] = _BroadcastStreamController._STATE_ADDSTREAM; | 1294 this[_state] = _BroadcastStreamController._STATE_ADDSTREAM; |
| 1295 this[_addStreamState] = dart.as(new _AddStreamState(this, stream, cancel
OnError), _AddStreamState$(T)); | 1295 this[_addStreamState] = dart.as(new _AddStreamState(this, stream, cancel
OnError), _AddStreamState$(T)); |
| 1296 return this[_addStreamState].addStreamFuture; | 1296 return this[_addStreamState].addStreamFuture; |
| 1297 } | 1297 } |
| 1298 [_add](data) { | 1298 [_add](data) { |
| 1299 this[_sendData](data); | 1299 this[_sendData](data); |
| 1300 } | 1300 } |
| 1301 [_addError](error, stackTrace) { | 1301 [_addError](error, stackTrace) { |
| (...skipping 224 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1526 if (value === void 0) | 1526 if (value === void 0) |
| 1527 value = null; | 1527 value = null; |
| 1528 return new _Future(); | 1528 return new _Future(); |
| 1529 } | 1529 } |
| 1530 } | 1530 } |
| 1531 return _DoneSubscription; | 1531 return _DoneSubscription; |
| 1532 }); | 1532 }); |
| 1533 let _DoneSubscription = _DoneSubscription$(dart.dynamic); | 1533 let _DoneSubscription = _DoneSubscription$(dart.dynamic); |
| 1534 class DeferredLibrary extends core.Object { | 1534 class DeferredLibrary extends core.Object { |
| 1535 DeferredLibrary(libraryName, opt$) { | 1535 DeferredLibrary(libraryName, opt$) { |
| 1536 let uri = opt$.uri === void 0 ? null : opt$.uri; | 1536 let uri = opt$ && 'uri' in opt$ ? opt$.uri : null; |
| 1537 this.libraryName = libraryName; | 1537 this.libraryName = libraryName; |
| 1538 this.uri = uri; | 1538 this.uri = uri; |
| 1539 } | 1539 } |
| 1540 load() { | 1540 load() { |
| 1541 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; | 1541 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar
t" deferred as lib` syntax.'; |
| 1542 } | 1542 } |
| 1543 } | 1543 } |
| 1544 let _s = Symbol('_s'); | 1544 let _s = Symbol('_s'); |
| 1545 class DeferredLoadException extends core.Object { | 1545 class DeferredLoadException extends core.Object { |
| 1546 DeferredLoadException($_s) { | 1546 DeferredLoadException($_s) { |
| (...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1615 result._complete(computation === null ? null : computation()); | 1615 result._complete(computation === null ? null : computation()); |
| 1616 } catch (e) { | 1616 } catch (e) { |
| 1617 let s = dart.stackTrace(e); | 1617 let s = dart.stackTrace(e); |
| 1618 _completeWithErrorCallback(result, e, s); | 1618 _completeWithErrorCallback(result, e, s); |
| 1619 } | 1619 } |
| 1620 | 1620 |
| 1621 }).bind(this)); | 1621 }).bind(this)); |
| 1622 return dart.as(result, Future$(T)); | 1622 return dart.as(result, Future$(T)); |
| 1623 } | 1623 } |
| 1624 static wait(futures, opt$) { | 1624 static wait(futures, opt$) { |
| 1625 let eagerError = opt$.eagerError === void 0 ? false : opt$.eagerError; | 1625 let eagerError = opt$ && 'eagerError' in opt$ ? opt$.eagerError : false; |
| 1626 let cleanUp = opt$.cleanUp === void 0 ? null : opt$.cleanUp; | 1626 let cleanUp = opt$ && 'cleanUp' in opt$ ? opt$.cleanUp : null; |
| 1627 let result = new _Future(); | 1627 let result = new _Future(); |
| 1628 let values = null; | 1628 let values = null; |
| 1629 let remaining = 0; | 1629 let remaining = 0; |
| 1630 let error = null; | 1630 let error = null; |
| 1631 let stackTrace = null; | 1631 let stackTrace = null; |
| 1632 // Function handleError: (dynamic, dynamic) → void | 1632 // Function handleError: (dynamic, dynamic) → void |
| 1633 function handleError(theError, theStackTrace) { | 1633 function handleError(theError, theStackTrace) { |
| 1634 remaining = dart.notNull(remaining) - 1; | 1634 remaining = dart.notNull(remaining) - 1; |
| 1635 if (values !== null) { | 1635 if (values !== null) { |
| 1636 if (cleanUp !== null) { | 1636 if (cleanUp !== null) { |
| (...skipping 312 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1949 set [_isChained](value) { | 1949 set [_isChained](value) { |
| 1950 if (value) { | 1950 if (value) { |
| 1951 dart.assert(!dart.notNull(this[_isComplete])); | 1951 dart.assert(!dart.notNull(this[_isComplete])); |
| 1952 this[_state] = _Future._CHAINED; | 1952 this[_state] = _Future._CHAINED; |
| 1953 } else { | 1953 } else { |
| 1954 dart.assert(this[_isChained]); | 1954 dart.assert(this[_isChained]); |
| 1955 this[_state] = _Future._INCOMPLETE; | 1955 this[_state] = _Future._INCOMPLETE; |
| 1956 } | 1956 } |
| 1957 } | 1957 } |
| 1958 then(f, opt$) { | 1958 then(f, opt$) { |
| 1959 let onError = opt$.onError === void 0 ? null : opt$.onError; | 1959 let onError = opt$ && 'onError' in opt$ ? opt$.onError : null; |
| 1960 let result = new _Future(); | 1960 let result = new _Future(); |
| 1961 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 1961 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
| 1962 f = dart.closureWrap(result[_zone].registerUnaryCallback(f), "(T) → dy
namic"); | 1962 f = dart.closureWrap(result[_zone].registerUnaryCallback(f), "(T) → dy
namic"); |
| 1963 if (onError !== null) { | 1963 if (onError !== null) { |
| 1964 onError = _registerErrorHandler(onError, result[_zone]); | 1964 onError = _registerErrorHandler(onError, result[_zone]); |
| 1965 } | 1965 } |
| 1966 } | 1966 } |
| 1967 this[_addListener](new _FutureListener.then(result, f, onError)); | 1967 this[_addListener](new _FutureListener.then(result, f, onError)); |
| 1968 return result; | 1968 return result; |
| 1969 } | 1969 } |
| 1970 catchError(onError, opt$) { | 1970 catchError(onError, opt$) { |
| 1971 let test = opt$.test === void 0 ? null : opt$.test; | 1971 let test = opt$ && 'test' in opt$ ? opt$.test : null; |
| 1972 let result = new _Future(); | 1972 let result = new _Future(); |
| 1973 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { | 1973 if (!dart.notNull(core.identical(result[_zone], _ROOT_ZONE))) { |
| 1974 onError = _registerErrorHandler(onError, result[_zone]); | 1974 onError = _registerErrorHandler(onError, result[_zone]); |
| 1975 if (test !== null) | 1975 if (test !== null) |
| 1976 test = dart.closureWrap(result[_zone].registerUnaryCallback(test), "
(dynamic) → bool"); | 1976 test = dart.closureWrap(result[_zone].registerUnaryCallback(test), "
(dynamic) → bool"); |
| 1977 } | 1977 } |
| 1978 this[_addListener](new _FutureListener.catchError(result, onError, test)
); | 1978 this[_addListener](new _FutureListener.catchError(result, onError, test)
); |
| 1979 return result; | 1979 return result; |
| 1980 } | 1980 } |
| 1981 whenComplete(action) { | 1981 whenComplete(action) { |
| (...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2281 if (listenerHasValue) { | 2281 if (listenerHasValue) { |
| 2282 result._setValue(listenerValueOrError); | 2282 result._setValue(listenerValueOrError); |
| 2283 } else { | 2283 } else { |
| 2284 let asyncError = dart.as(listenerValueOrError, AsyncError); | 2284 let asyncError = dart.as(listenerValueOrError, AsyncError); |
| 2285 result._setErrorObject(asyncError); | 2285 result._setErrorObject(asyncError); |
| 2286 } | 2286 } |
| 2287 source = result; | 2287 source = result; |
| 2288 } | 2288 } |
| 2289 } | 2289 } |
| 2290 timeout(timeLimit, opt$) { | 2290 timeout(timeLimit, opt$) { |
| 2291 let onTimeout = opt$.onTimeout === void 0 ? null : opt$.onTimeout; | 2291 let onTimeout = opt$ && 'onTimeout' in opt$ ? opt$.onTimeout : null; |
| 2292 if (this[_isComplete]) | 2292 if (this[_isComplete]) |
| 2293 return new _Future.immediate(this); | 2293 return new _Future.immediate(this); |
| 2294 let result = new _Future(); | 2294 let result = new _Future(); |
| 2295 let timer = null; | 2295 let timer = null; |
| 2296 if (onTimeout === null) { | 2296 if (onTimeout === null) { |
| 2297 timer = new Timer(timeLimit, (() => { | 2297 timer = new Timer(timeLimit, (() => { |
| 2298 result._completeError(new TimeoutException("Future not completed", t
imeLimit)); | 2298 result._completeError(new TimeoutException("Future not completed", t
imeLimit)); |
| 2299 }).bind(this)); | 2299 }).bind(this)); |
| 2300 } else { | 2300 } else { |
| 2301 let zone = Zone.current; | 2301 let zone = Zone.current; |
| (...skipping 188 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2490 let StreamView$ = dart.generic(function(T) { | 2490 let StreamView$ = dart.generic(function(T) { |
| 2491 class StreamView extends Stream$(T) { | 2491 class StreamView extends Stream$(T) { |
| 2492 StreamView($_stream) { | 2492 StreamView($_stream) { |
| 2493 this[_stream] = $_stream; | 2493 this[_stream] = $_stream; |
| 2494 super.Stream(); | 2494 super.Stream(); |
| 2495 } | 2495 } |
| 2496 get isBroadcast() { | 2496 get isBroadcast() { |
| 2497 return this[_stream].isBroadcast; | 2497 return this[_stream].isBroadcast; |
| 2498 } | 2498 } |
| 2499 asBroadcastStream(opt$) { | 2499 asBroadcastStream(opt$) { |
| 2500 let onListen = opt$.onListen === void 0 ? null : opt$.onListen; | 2500 let onListen = opt$ && 'onListen' in opt$ ? opt$.onListen : null; |
| 2501 let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel; | 2501 let onCancel = opt$ && 'onCancel' in opt$ ? opt$.onCancel : null; |
| 2502 return this[_stream].asBroadcastStream({onListen: onListen, onCancel: on
Cancel}); | 2502 return this[_stream].asBroadcastStream({onListen: onListen, onCancel: on
Cancel}); |
| 2503 } | 2503 } |
| 2504 listen(onData, opt$) { | 2504 listen(onData, opt$) { |
| 2505 let onError = opt$.onError === void 0 ? null : opt$.onError; | 2505 let onError = opt$ && 'onError' in opt$ ? opt$.onError : null; |
| 2506 let onDone = opt$.onDone === void 0 ? null : opt$.onDone; | 2506 let onDone = opt$ && 'onDone' in opt$ ? opt$.onDone : null; |
| 2507 let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOn
Error; | 2507 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: null; |
| 2508 return this[_stream].listen(onData, {onError: onError, onDone: onDone, c
ancelOnError: cancelOnError}); | 2508 return this[_stream].listen(onData, {onError: onError, onDone: onDone, c
ancelOnError: cancelOnError}); |
| 2509 } | 2509 } |
| 2510 } | 2510 } |
| 2511 return StreamView; | 2511 return StreamView; |
| 2512 }); | 2512 }); |
| 2513 let StreamView = StreamView$(dart.dynamic); | 2513 let StreamView = StreamView$(dart.dynamic); |
| 2514 let StreamConsumer$ = dart.generic(function(S) { | 2514 let StreamConsumer$ = dart.generic(function(S) { |
| 2515 class StreamConsumer extends core.Object { | 2515 class StreamConsumer extends core.Object { |
| 2516 } | 2516 } |
| 2517 return StreamConsumer; | 2517 return StreamConsumer; |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2561 close() { | 2561 close() { |
| 2562 this[_sink].close(); | 2562 this[_sink].close(); |
| 2563 } | 2563 } |
| 2564 } | 2564 } |
| 2565 return _ControllerEventSinkWrapper; | 2565 return _ControllerEventSinkWrapper; |
| 2566 }); | 2566 }); |
| 2567 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic); | 2567 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic); |
| 2568 let StreamController$ = dart.generic(function(T) { | 2568 let StreamController$ = dart.generic(function(T) { |
| 2569 class StreamController extends core.Object { | 2569 class StreamController extends core.Object { |
| 2570 StreamController(opt$) { | 2570 StreamController(opt$) { |
| 2571 let onListen = opt$.onListen === void 0 ? null : opt$.onListen; | 2571 let onListen = opt$ && 'onListen' in opt$ ? opt$.onListen : null; |
| 2572 let onPause = opt$.onPause === void 0 ? null : opt$.onPause; | 2572 let onPause = opt$ && 'onPause' in opt$ ? opt$.onPause : null; |
| 2573 let onResume = opt$.onResume === void 0 ? null : opt$.onResume; | 2573 let onResume = opt$ && 'onResume' in opt$ ? opt$.onResume : null; |
| 2574 let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel; | 2574 let onCancel = opt$ && 'onCancel' in opt$ ? opt$.onCancel : null; |
| 2575 let sync = opt$.sync === void 0 ? false : opt$.sync; | 2575 let sync = opt$ && 'sync' in opt$ ? opt$.sync : false; |
| 2576 if (dart.notNull(onListen === null) && dart.notNull(onPause === null) &&
dart.notNull(onResume === null) && dart.notNull(onCancel === null)) { | 2576 if (dart.notNull(onListen === null) && dart.notNull(onPause === null) &&
dart.notNull(onResume === null) && dart.notNull(onCancel === null)) { |
| 2577 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC
allbackAsyncStreamController(), StreamController$(T)); | 2577 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC
allbackAsyncStreamController(), StreamController$(T)); |
| 2578 } | 2578 } |
| 2579 return sync ? new _SyncStreamController(onListen, onPause, onResume, onC
ancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel); | 2579 return sync ? new _SyncStreamController(onListen, onPause, onResume, onC
ancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel); |
| 2580 } | 2580 } |
| 2581 StreamController$broadcast(opt$) { | 2581 StreamController$broadcast(opt$) { |
| 2582 let onListen = opt$.onListen === void 0 ? null : opt$.onListen; | 2582 let onListen = opt$ && 'onListen' in opt$ ? opt$.onListen : null; |
| 2583 let onCancel = opt$.onCancel === void 0 ? null : opt$.onCancel; | 2583 let onCancel = opt$ && 'onCancel' in opt$ ? opt$.onCancel : null; |
| 2584 let sync = opt$.sync === void 0 ? false : opt$.sync; | 2584 let sync = opt$ && 'sync' in opt$ ? opt$.sync : false; |
| 2585 return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : n
ew _AsyncBroadcastStreamController(onListen, onCancel); | 2585 return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : n
ew _AsyncBroadcastStreamController(onListen, onCancel); |
| 2586 } | 2586 } |
| 2587 } | 2587 } |
| 2588 dart.defineNamedConstructor(StreamController, 'broadcast'); | 2588 dart.defineNamedConstructor(StreamController, 'broadcast'); |
| 2589 return StreamController; | 2589 return StreamController; |
| 2590 }); | 2590 }); |
| 2591 let StreamController = StreamController$(dart.dynamic); | 2591 let StreamController = StreamController$(dart.dynamic); |
| 2592 let _StreamControllerLifecycle$ = dart.generic(function(T) { | 2592 let _StreamControllerLifecycle$ = dart.generic(function(T) { |
| 2593 class _StreamControllerLifecycle extends core.Object { | 2593 class _StreamControllerLifecycle extends core.Object { |
| 2594 [_recordPause](subscription) {} | 2594 [_recordPause](subscription) {} |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2671 return dart.as(this[_varData], _ControllerSubscription); | 2671 return dart.as(this[_varData], _ControllerSubscription); |
| 2672 } | 2672 } |
| 2673 [_badEventState]() { | 2673 [_badEventState]() { |
| 2674 if (this.isClosed) { | 2674 if (this.isClosed) { |
| 2675 return new core.StateError("Cannot add event after closing"); | 2675 return new core.StateError("Cannot add event after closing"); |
| 2676 } | 2676 } |
| 2677 dart.assert(this[_isAddingStream]); | 2677 dart.assert(this[_isAddingStream]); |
| 2678 return new core.StateError("Cannot add event while adding a stream"); | 2678 return new core.StateError("Cannot add event while adding a stream"); |
| 2679 } | 2679 } |
| 2680 addStream(source, opt$) { | 2680 addStream(source, opt$) { |
| 2681 let cancelOnError = opt$.cancelOnError === void 0 ? true : opt$.cancelOn
Error; | 2681 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: true; |
| 2682 if (!dart.notNull(this[_mayAddEvent])) | 2682 if (!dart.notNull(this[_mayAddEvent])) |
| 2683 throw this[_badEventState](); | 2683 throw this[_badEventState](); |
| 2684 if (this[_isCanceled]) | 2684 if (this[_isCanceled]) |
| 2685 return new _Future.immediate(null); | 2685 return new _Future.immediate(null); |
| 2686 let addState = new _StreamControllerAddStreamState(this, this[_varData],
source, cancelOnError); | 2686 let addState = new _StreamControllerAddStreamState(this, this[_varData],
source, cancelOnError); |
| 2687 this[_varData] = addState; | 2687 this[_varData] = addState; |
| 2688 this[_state] = _StreamController._STATE_ADDSTREAM; | 2688 this[_state] = _StreamController._STATE_ADDSTREAM; |
| 2689 return addState.addStreamFuture; | 2689 return addState.addStreamFuture; |
| 2690 } | 2690 } |
| 2691 get done() { | 2691 get done() { |
| (...skipping 242 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2934 } | 2934 } |
| 2935 addError(error, stackTrace) { | 2935 addError(error, stackTrace) { |
| 2936 if (stackTrace === void 0) | 2936 if (stackTrace === void 0) |
| 2937 stackTrace = null; | 2937 stackTrace = null; |
| 2938 this[_target].addError(error, stackTrace); | 2938 this[_target].addError(error, stackTrace); |
| 2939 } | 2939 } |
| 2940 close() { | 2940 close() { |
| 2941 return this[_target].close(); | 2941 return this[_target].close(); |
| 2942 } | 2942 } |
| 2943 addStream(source, opt$) { | 2943 addStream(source, opt$) { |
| 2944 let cancelOnError = opt$.cancelOnError === void 0 ? true : opt$.cancelOn
Error; | 2944 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: true; |
| 2945 return this[_target].addStream(source, {cancelOnError: cancelOnError}); | 2945 return this[_target].addStream(source, {cancelOnError: cancelOnError}); |
| 2946 } | 2946 } |
| 2947 get done() { | 2947 get done() { |
| 2948 return this[_target].done; | 2948 return this[_target].done; |
| 2949 } | 2949 } |
| 2950 } | 2950 } |
| 2951 return _StreamSinkWrapper; | 2951 return _StreamSinkWrapper; |
| 2952 }); | 2952 }); |
| 2953 let _StreamSinkWrapper = _StreamSinkWrapper$(dart.dynamic); | 2953 let _StreamSinkWrapper = _StreamSinkWrapper$(dart.dynamic); |
| 2954 let _AddStreamState$ = dart.generic(function(T) { | 2954 let _AddStreamState$ = dart.generic(function(T) { |
| (...skipping 347 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3302 this[_zone] = Zone.current; | 3302 this[_zone] = Zone.current; |
| 3303 this[_controller] = null; | 3303 this[_controller] = null; |
| 3304 this[_subscription] = null; | 3304 this[_subscription] = null; |
| 3305 super.Stream(); | 3305 super.Stream(); |
| 3306 this[_controller] = new _AsBroadcastStreamController(this[_onListen], th
is[_onCancel]); | 3306 this[_controller] = new _AsBroadcastStreamController(this[_onListen], th
is[_onCancel]); |
| 3307 } | 3307 } |
| 3308 get isBroadcast() { | 3308 get isBroadcast() { |
| 3309 return true; | 3309 return true; |
| 3310 } | 3310 } |
| 3311 listen(onData, opt$) { | 3311 listen(onData, opt$) { |
| 3312 let onError = opt$.onError === void 0 ? null : opt$.onError; | 3312 let onError = opt$ && 'onError' in opt$ ? opt$.onError : null; |
| 3313 let onDone = opt$.onDone === void 0 ? null : opt$.onDone; | 3313 let onDone = opt$ && 'onDone' in opt$ ? opt$.onDone : null; |
| 3314 let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOn
Error; | 3314 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: null; |
| 3315 if (dart.notNull(this[_controller] === null) || dart.notNull(this[_contr
oller].isClosed)) { | 3315 if (dart.notNull(this[_controller] === null) || dart.notNull(this[_contr
oller].isClosed)) { |
| 3316 return new _DoneStreamSubscription(onDone); | 3316 return new _DoneStreamSubscription(onDone); |
| 3317 } | 3317 } |
| 3318 if (this[_subscription] === null) { | 3318 if (this[_subscription] === null) { |
| 3319 this[_subscription] = this[_source].listen(this[_controller].add, {onE
rror: this[_controller].addError, onDone: this[_controller].close}); | 3319 this[_subscription] = this[_source].listen(this[_controller].add, {onE
rror: this[_controller].addError, onDone: this[_controller].close}); |
| 3320 } | 3320 } |
| 3321 cancelOnError = core.identical(true, cancelOnError); | 3321 cancelOnError = core.identical(true, cancelOnError); |
| 3322 return this[_controller]._subscribe(onData, onError, onDone, cancelOnErr
or); | 3322 return this[_controller]._subscribe(onData, onError, onDone, cancelOnErr
or); |
| 3323 } | 3323 } |
| 3324 [_onCancel]() { | 3324 [_onCancel]() { |
| (...skipping 244 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3569 let _ForwardingStream$ = dart.generic(function(S, T) { | 3569 let _ForwardingStream$ = dart.generic(function(S, T) { |
| 3570 class _ForwardingStream extends Stream$(T) { | 3570 class _ForwardingStream extends Stream$(T) { |
| 3571 _ForwardingStream($_source) { | 3571 _ForwardingStream($_source) { |
| 3572 this[_source] = $_source; | 3572 this[_source] = $_source; |
| 3573 super.Stream(); | 3573 super.Stream(); |
| 3574 } | 3574 } |
| 3575 get isBroadcast() { | 3575 get isBroadcast() { |
| 3576 return this[_source].isBroadcast; | 3576 return this[_source].isBroadcast; |
| 3577 } | 3577 } |
| 3578 listen(onData, opt$) { | 3578 listen(onData, opt$) { |
| 3579 let onError = opt$.onError === void 0 ? null : opt$.onError; | 3579 let onError = opt$ && 'onError' in opt$ ? opt$.onError : null; |
| 3580 let onDone = opt$.onDone === void 0 ? null : opt$.onDone; | 3580 let onDone = opt$ && 'onDone' in opt$ ? opt$.onDone : null; |
| 3581 let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOn
Error; | 3581 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: null; |
| 3582 cancelOnError = core.identical(true, cancelOnError); | 3582 cancelOnError = core.identical(true, cancelOnError); |
| 3583 return this[_createSubscription](onData, onError, onDone, cancelOnError)
; | 3583 return this[_createSubscription](onData, onError, onDone, cancelOnError)
; |
| 3584 } | 3584 } |
| 3585 [_createSubscription](onData, onError, onDone, cancelOnError) { | 3585 [_createSubscription](onData, onError, onDone, cancelOnError) { |
| 3586 return new _ForwardingStreamSubscription(this, onData, onError, onDone,
cancelOnError); | 3586 return new _ForwardingStreamSubscription(this, onData, onError, onDone,
cancelOnError); |
| 3587 } | 3587 } |
| 3588 [_handleData](data, sink) { | 3588 [_handleData](data, sink) { |
| 3589 let outputData = data; | 3589 let outputData = data; |
| 3590 sink._add(outputData); | 3590 sink._add(outputData); |
| 3591 } | 3591 } |
| (...skipping 441 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4033 class _BoundSinkStream extends Stream$(T) { | 4033 class _BoundSinkStream extends Stream$(T) { |
| 4034 get isBroadcast() { | 4034 get isBroadcast() { |
| 4035 return this[_stream].isBroadcast; | 4035 return this[_stream].isBroadcast; |
| 4036 } | 4036 } |
| 4037 _BoundSinkStream($_stream, $_sinkMapper) { | 4037 _BoundSinkStream($_stream, $_sinkMapper) { |
| 4038 this[_stream] = $_stream; | 4038 this[_stream] = $_stream; |
| 4039 this[_sinkMapper] = $_sinkMapper; | 4039 this[_sinkMapper] = $_sinkMapper; |
| 4040 super.Stream(); | 4040 super.Stream(); |
| 4041 } | 4041 } |
| 4042 listen(onData, opt$) { | 4042 listen(onData, opt$) { |
| 4043 let onError = opt$.onError === void 0 ? null : opt$.onError; | 4043 let onError = opt$ && 'onError' in opt$ ? opt$.onError : null; |
| 4044 let onDone = opt$.onDone === void 0 ? null : opt$.onDone; | 4044 let onDone = opt$ && 'onDone' in opt$ ? opt$.onDone : null; |
| 4045 let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOn
Error; | 4045 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: null; |
| 4046 cancelOnError = core.identical(true, cancelOnError); | 4046 cancelOnError = core.identical(true, cancelOnError); |
| 4047 let subscription = dart.as(new _SinkTransformerStreamSubscription(this[_
stream], dart.closureWrap(this[_sinkMapper], "(EventSink<dynamic>) → EventSink")
, onData, onError, onDone, cancelOnError), StreamSubscription$(T)); | 4047 let subscription = dart.as(new _SinkTransformerStreamSubscription(this[_
stream], dart.closureWrap(this[_sinkMapper], "(EventSink<dynamic>) → EventSink")
, onData, onError, onDone, cancelOnError), StreamSubscription$(T)); |
| 4048 return subscription; | 4048 return subscription; |
| 4049 } | 4049 } |
| 4050 } | 4050 } |
| 4051 return _BoundSinkStream; | 4051 return _BoundSinkStream; |
| 4052 }); | 4052 }); |
| 4053 let _BoundSinkStream = _BoundSinkStream$(dart.dynamic, dart.dynamic); | 4053 let _BoundSinkStream = _BoundSinkStream$(dart.dynamic, dart.dynamic); |
| 4054 let _HandlerEventSink$ = dart.generic(function(S, T) { | 4054 let _HandlerEventSink$ = dart.generic(function(S, T) { |
| 4055 class _HandlerEventSink extends core.Object { | 4055 class _HandlerEventSink extends core.Object { |
| (...skipping 17 matching lines...) Expand all Loading... |
| 4073 } | 4073 } |
| 4074 return _HandlerEventSink; | 4074 return _HandlerEventSink; |
| 4075 }); | 4075 }); |
| 4076 let _HandlerEventSink = _HandlerEventSink$(dart.dynamic, dart.dynamic); | 4076 let _HandlerEventSink = _HandlerEventSink$(dart.dynamic, dart.dynamic); |
| 4077 let _defaultHandleData = Symbol('_defaultHandleData'); | 4077 let _defaultHandleData = Symbol('_defaultHandleData'); |
| 4078 let _defaultHandleError = Symbol('_defaultHandleError'); | 4078 let _defaultHandleError = Symbol('_defaultHandleError'); |
| 4079 let _defaultHandleDone = Symbol('_defaultHandleDone'); | 4079 let _defaultHandleDone = Symbol('_defaultHandleDone'); |
| 4080 let _StreamHandlerTransformer$ = dart.generic(function(S, T) { | 4080 let _StreamHandlerTransformer$ = dart.generic(function(S, T) { |
| 4081 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { | 4081 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { |
| 4082 _StreamHandlerTransformer(opt$) { | 4082 _StreamHandlerTransformer(opt$) { |
| 4083 let handleData = opt$.handleData === void 0 ? null : opt$.handleData; | 4083 let handleData = opt$ && 'handleData' in opt$ ? opt$.handleData : null; |
| 4084 let handleError = opt$.handleError === void 0 ? null : opt$.handleError; | 4084 let handleError = opt$ && 'handleError' in opt$ ? opt$.handleError : nul
l; |
| 4085 let handleDone = opt$.handleDone === void 0 ? null : opt$.handleDone; | 4085 let handleDone = opt$ && 'handleDone' in opt$ ? opt$.handleDone : null; |
| 4086 super._StreamSinkTransformer(dart.closureWrap((outputSink) => { | 4086 super._StreamSinkTransformer(dart.closureWrap((outputSink) => { |
| 4087 if (handleData === null) | 4087 if (handleData === null) |
| 4088 handleData = dart.closureWrap(_defaultHandleData, "(S, EventSink<T>)
→ void"); | 4088 handleData = dart.closureWrap(_defaultHandleData, "(S, EventSink<T>)
→ void"); |
| 4089 if (handleError === null) | 4089 if (handleError === null) |
| 4090 handleError = dart.closureWrap(_defaultHandleError, "(Object, StackT
race, EventSink<T>) → void"); | 4090 handleError = dart.closureWrap(_defaultHandleError, "(Object, StackT
race, EventSink<T>) → void"); |
| 4091 if (handleDone === null) | 4091 if (handleDone === null) |
| 4092 handleDone = _defaultHandleDone; | 4092 handleDone = _defaultHandleDone; |
| 4093 return new _HandlerEventSink(handleData, handleError, handleDone, outp
utSink); | 4093 return new _HandlerEventSink(handleData, handleError, handleDone, outp
utSink); |
| 4094 }, "(EventSink<T>) → EventSink<S>")); | 4094 }, "(EventSink<T>) → EventSink<S>")); |
| 4095 } | 4095 } |
| (...skipping 27 matching lines...) Expand all Loading... |
| 4123 }); | 4123 }); |
| 4124 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dart.dyna
mic, dart.dynamic); | 4124 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dart.dyna
mic, dart.dynamic); |
| 4125 let _BoundSubscriptionStream$ = dart.generic(function(S, T) { | 4125 let _BoundSubscriptionStream$ = dart.generic(function(S, T) { |
| 4126 class _BoundSubscriptionStream extends Stream$(T) { | 4126 class _BoundSubscriptionStream extends Stream$(T) { |
| 4127 _BoundSubscriptionStream($_stream, $_transformer) { | 4127 _BoundSubscriptionStream($_stream, $_transformer) { |
| 4128 this[_stream] = $_stream; | 4128 this[_stream] = $_stream; |
| 4129 this[_transformer] = $_transformer; | 4129 this[_transformer] = $_transformer; |
| 4130 super.Stream(); | 4130 super.Stream(); |
| 4131 } | 4131 } |
| 4132 listen(onData, opt$) { | 4132 listen(onData, opt$) { |
| 4133 let onError = opt$.onError === void 0 ? null : opt$.onError; | 4133 let onError = opt$ && 'onError' in opt$ ? opt$.onError : null; |
| 4134 let onDone = opt$.onDone === void 0 ? null : opt$.onDone; | 4134 let onDone = opt$ && 'onDone' in opt$ ? opt$.onDone : null; |
| 4135 let cancelOnError = opt$.cancelOnError === void 0 ? null : opt$.cancelOn
Error; | 4135 let cancelOnError = opt$ && 'cancelOnError' in opt$ ? opt$.cancelOnError
: null; |
| 4136 cancelOnError = core.identical(true, cancelOnError); | 4136 cancelOnError = core.identical(true, cancelOnError); |
| 4137 let result = this[_transformer](this[_stream], cancelOnError); | 4137 let result = this[_transformer](this[_stream], cancelOnError); |
| 4138 result.onData(onData); | 4138 result.onData(onData); |
| 4139 result.onError(onError); | 4139 result.onError(onError); |
| 4140 result.onDone(onDone); | 4140 result.onDone(onDone); |
| 4141 return result; | 4141 return result; |
| 4142 } | 4142 } |
| 4143 } | 4143 } |
| 4144 return _BoundSubscriptionStream; | 4144 return _BoundSubscriptionStream; |
| 4145 }); | 4145 }); |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4180 _ZoneFunction(zone, function) { | 4180 _ZoneFunction(zone, function) { |
| 4181 this.zone = zone; | 4181 this.zone = zone; |
| 4182 this['function'] = function; | 4182 this['function'] = function; |
| 4183 } | 4183 } |
| 4184 } | 4184 } |
| 4185 class ZoneSpecification extends core.Object { | 4185 class ZoneSpecification extends core.Object { |
| 4186 ZoneSpecification(opt$) { | 4186 ZoneSpecification(opt$) { |
| 4187 return new _ZoneSpecification(opt$); | 4187 return new _ZoneSpecification(opt$); |
| 4188 } | 4188 } |
| 4189 ZoneSpecification$from(other, opt$) { | 4189 ZoneSpecification$from(other, opt$) { |
| 4190 let handleUncaughtError = opt$.handleUncaughtError === void 0 ? null : opt
$.handleUncaughtError; | 4190 let handleUncaughtError = opt$ && 'handleUncaughtError' in opt$ ? opt$.han
dleUncaughtError : null; |
| 4191 let run = opt$.run === void 0 ? null : opt$.run; | 4191 let run = opt$ && 'run' in opt$ ? opt$.run : null; |
| 4192 let runUnary = opt$.runUnary === void 0 ? null : opt$.runUnary; | 4192 let runUnary = opt$ && 'runUnary' in opt$ ? opt$.runUnary : null; |
| 4193 let runBinary = opt$.runBinary === void 0 ? null : opt$.runBinary; | 4193 let runBinary = opt$ && 'runBinary' in opt$ ? opt$.runBinary : null; |
| 4194 let registerCallback = opt$.registerCallback === void 0 ? null : opt$.regi
sterCallback; | 4194 let registerCallback = opt$ && 'registerCallback' in opt$ ? opt$.registerC
allback : null; |
| 4195 let registerUnaryCallback = opt$.registerUnaryCallback === void 0 ? null :
opt$.registerUnaryCallback; | 4195 let registerUnaryCallback = opt$ && 'registerUnaryCallback' in opt$ ? opt$
.registerUnaryCallback : null; |
| 4196 let registerBinaryCallback = opt$.registerBinaryCallback === void 0 ? null
: opt$.registerBinaryCallback; | 4196 let registerBinaryCallback = opt$ && 'registerBinaryCallback' in opt$ ? op
t$.registerBinaryCallback : null; |
| 4197 let errorCallback = opt$.errorCallback === void 0 ? null : opt$.errorCallb
ack; | 4197 let errorCallback = opt$ && 'errorCallback' in opt$ ? opt$.errorCallback :
null; |
| 4198 let scheduleMicrotask = opt$.scheduleMicrotask === void 0 ? null : opt$.sc
heduleMicrotask; | 4198 let scheduleMicrotask = opt$ && 'scheduleMicrotask' in opt$ ? opt$.schedul
eMicrotask : null; |
| 4199 let createTimer = opt$.createTimer === void 0 ? null : opt$.createTimer; | 4199 let createTimer = opt$ && 'createTimer' in opt$ ? opt$.createTimer : null; |
| 4200 let createPeriodicTimer = opt$.createPeriodicTimer === void 0 ? null : opt
$.createPeriodicTimer; | 4200 let createPeriodicTimer = opt$ && 'createPeriodicTimer' in opt$ ? opt$.cre
atePeriodicTimer : null; |
| 4201 let print = opt$.print === void 0 ? null : opt$.print; | 4201 let print = opt$ && 'print' in opt$ ? opt$.print : null; |
| 4202 let fork = opt$.fork === void 0 ? null : opt$.fork; | 4202 let fork = opt$ && 'fork' in opt$ ? opt$.fork : null; |
| 4203 return new ZoneSpecification({handleUncaughtError: dart.as(handleUncaughtE
rror !== null ? handleUncaughtError : other.handleUncaughtError, dart.throw_("Un
implemented type (Zone, ZoneDelegate, Zone, dynamic, StackTrace) → dynamic")), r
un: dart.as(run !== null ? run : other.run, dart.throw_("Unimplemented type (Zon
e, ZoneDelegate, Zone, () → dynamic) → dynamic")), runUnary: dart.as(runUnary !=
= null ? runUnary : other.runUnary, dart.throw_("Unimplemented type (Zone, ZoneD
elegate, Zone, (dynamic) → dynamic, dynamic) → dynamic")), runBinary: dart.as(ru
nBinary !== null ? runBinary : other.runBinary, dart.throw_("Unimplemented type
(Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic, dynamic, dynamic) → dyn
amic")), registerCallback: dart.as(registerCallback !== null ? registerCallback
: other.registerCallback, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Z
one, () → dynamic) → ZoneCallback")), registerUnaryCallback: dart.as(registerUna
ryCallback !== null ? registerUnaryCallback : other.registerUnaryCallback, dart.
throw_("Unimplemented type (Zone, ZoneDelegate, Zone, (dynamic) → dynamic) → Zon
eUnaryCallback")), registerBinaryCallback: dart.as(registerBinaryCallback !== nu
ll ? registerBinaryCallback : other.registerBinaryCallback, dart.throw_("Unimple
mented type (Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic) → ZoneBinar
yCallback")), errorCallback: dart.as(errorCallback !== null ? errorCallback : ot
her.errorCallback, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, Ob
ject, StackTrace) → AsyncError")), scheduleMicrotask: dart.as(scheduleMicrotask
!== null ? scheduleMicrotask : other.scheduleMicrotask, dart.throw_("Unimplement
ed type (Zone, ZoneDelegate, Zone, () → dynamic) → void")), createTimer: dart.as
(createTimer !== null ? createTimer : other.createTimer, dart.throw_("Unimplemen
ted type (Zone, ZoneDelegate, Zone, Duration, () → void) → Timer")), createPerio
dicTimer: dart.as(createPeriodicTimer !== null ? createPeriodicTimer : other.cre
atePeriodicTimer, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, Dur
ation, (Timer) → void) → Timer")), print: dart.as(print !== null ? print : other
.print, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, String) → voi
d")), fork: dart.as(fork !== null ? fork : other.fork, dart.throw_("Unimplemente
d type (Zone, ZoneDelegate, Zone, ZoneSpecification, Map<dynamic, dynamic>) → Zo
ne"))}); | 4203 return new ZoneSpecification({handleUncaughtError: dart.as(handleUncaughtE
rror !== null ? handleUncaughtError : other.handleUncaughtError, dart.throw_("Un
implemented type (Zone, ZoneDelegate, Zone, dynamic, StackTrace) → dynamic")), r
un: dart.as(run !== null ? run : other.run, dart.throw_("Unimplemented type (Zon
e, ZoneDelegate, Zone, () → dynamic) → dynamic")), runUnary: dart.as(runUnary !=
= null ? runUnary : other.runUnary, dart.throw_("Unimplemented type (Zone, ZoneD
elegate, Zone, (dynamic) → dynamic, dynamic) → dynamic")), runBinary: dart.as(ru
nBinary !== null ? runBinary : other.runBinary, dart.throw_("Unimplemented type
(Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic, dynamic, dynamic) → dyn
amic")), registerCallback: dart.as(registerCallback !== null ? registerCallback
: other.registerCallback, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Z
one, () → dynamic) → ZoneCallback")), registerUnaryCallback: dart.as(registerUna
ryCallback !== null ? registerUnaryCallback : other.registerUnaryCallback, dart.
throw_("Unimplemented type (Zone, ZoneDelegate, Zone, (dynamic) → dynamic) → Zon
eUnaryCallback")), registerBinaryCallback: dart.as(registerBinaryCallback !== nu
ll ? registerBinaryCallback : other.registerBinaryCallback, dart.throw_("Unimple
mented type (Zone, ZoneDelegate, Zone, (dynamic, dynamic) → dynamic) → ZoneBinar
yCallback")), errorCallback: dart.as(errorCallback !== null ? errorCallback : ot
her.errorCallback, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, Ob
ject, StackTrace) → AsyncError")), scheduleMicrotask: dart.as(scheduleMicrotask
!== null ? scheduleMicrotask : other.scheduleMicrotask, dart.throw_("Unimplement
ed type (Zone, ZoneDelegate, Zone, () → dynamic) → void")), createTimer: dart.as
(createTimer !== null ? createTimer : other.createTimer, dart.throw_("Unimplemen
ted type (Zone, ZoneDelegate, Zone, Duration, () → void) → Timer")), createPerio
dicTimer: dart.as(createPeriodicTimer !== null ? createPeriodicTimer : other.cre
atePeriodicTimer, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, Dur
ation, (Timer) → void) → Timer")), print: dart.as(print !== null ? print : other
.print, dart.throw_("Unimplemented type (Zone, ZoneDelegate, Zone, String) → voi
d")), fork: dart.as(fork !== null ? fork : other.fork, dart.throw_("Unimplemente
d type (Zone, ZoneDelegate, Zone, ZoneSpecification, Map<dynamic, dynamic>) → Zo
ne"))}); |
| 4204 } | 4204 } |
| 4205 } | 4205 } |
| 4206 dart.defineNamedConstructor(ZoneSpecification, 'from'); | 4206 dart.defineNamedConstructor(ZoneSpecification, 'from'); |
| 4207 class _ZoneSpecification extends core.Object { | 4207 class _ZoneSpecification extends core.Object { |
| 4208 _ZoneSpecification(opt$) { | 4208 _ZoneSpecification(opt$) { |
| 4209 let handleUncaughtError = opt$.handleUncaughtError === void 0 ? null : opt
$.handleUncaughtError; | 4209 let handleUncaughtError = opt$ && 'handleUncaughtError' in opt$ ? opt$.han
dleUncaughtError : null; |
| 4210 let run = opt$.run === void 0 ? null : opt$.run; | 4210 let run = opt$ && 'run' in opt$ ? opt$.run : null; |
| 4211 let runUnary = opt$.runUnary === void 0 ? null : opt$.runUnary; | 4211 let runUnary = opt$ && 'runUnary' in opt$ ? opt$.runUnary : null; |
| 4212 let runBinary = opt$.runBinary === void 0 ? null : opt$.runBinary; | 4212 let runBinary = opt$ && 'runBinary' in opt$ ? opt$.runBinary : null; |
| 4213 let registerCallback = opt$.registerCallback === void 0 ? null : opt$.regi
sterCallback; | 4213 let registerCallback = opt$ && 'registerCallback' in opt$ ? opt$.registerC
allback : null; |
| 4214 let registerUnaryCallback = opt$.registerUnaryCallback === void 0 ? null :
opt$.registerUnaryCallback; | 4214 let registerUnaryCallback = opt$ && 'registerUnaryCallback' in opt$ ? opt$
.registerUnaryCallback : null; |
| 4215 let registerBinaryCallback = opt$.registerBinaryCallback === void 0 ? null
: opt$.registerBinaryCallback; | 4215 let registerBinaryCallback = opt$ && 'registerBinaryCallback' in opt$ ? op
t$.registerBinaryCallback : null; |
| 4216 let errorCallback = opt$.errorCallback === void 0 ? null : opt$.errorCallb
ack; | 4216 let errorCallback = opt$ && 'errorCallback' in opt$ ? opt$.errorCallback :
null; |
| 4217 let scheduleMicrotask = opt$.scheduleMicrotask === void 0 ? null : opt$.sc
heduleMicrotask; | 4217 let scheduleMicrotask = opt$ && 'scheduleMicrotask' in opt$ ? opt$.schedul
eMicrotask : null; |
| 4218 let createTimer = opt$.createTimer === void 0 ? null : opt$.createTimer; | 4218 let createTimer = opt$ && 'createTimer' in opt$ ? opt$.createTimer : null; |
| 4219 let createPeriodicTimer = opt$.createPeriodicTimer === void 0 ? null : opt
$.createPeriodicTimer; | 4219 let createPeriodicTimer = opt$ && 'createPeriodicTimer' in opt$ ? opt$.cre
atePeriodicTimer : null; |
| 4220 let print = opt$.print === void 0 ? null : opt$.print; | 4220 let print = opt$ && 'print' in opt$ ? opt$.print : null; |
| 4221 let fork = opt$.fork === void 0 ? null : opt$.fork; | 4221 let fork = opt$ && 'fork' in opt$ ? opt$.fork : null; |
| 4222 this.handleUncaughtError = handleUncaughtError; | 4222 this.handleUncaughtError = handleUncaughtError; |
| 4223 this.run = run; | 4223 this.run = run; |
| 4224 this.runUnary = runUnary; | 4224 this.runUnary = runUnary; |
| 4225 this.runBinary = runBinary; | 4225 this.runBinary = runBinary; |
| 4226 this.registerCallback = registerCallback; | 4226 this.registerCallback = registerCallback; |
| 4227 this.registerUnaryCallback = registerUnaryCallback; | 4227 this.registerUnaryCallback = registerUnaryCallback; |
| 4228 this.registerBinaryCallback = registerBinaryCallback; | 4228 this.registerBinaryCallback = registerBinaryCallback; |
| 4229 this.errorCallback = errorCallback; | 4229 this.errorCallback = errorCallback; |
| 4230 this.scheduleMicrotask = scheduleMicrotask; | 4230 this.scheduleMicrotask = scheduleMicrotask; |
| 4231 this.createTimer = createTimer; | 4231 this.createTimer = createTimer; |
| (...skipping 190 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4422 runBinaryGuarded(f, arg1, arg2) { | 4422 runBinaryGuarded(f, arg1, arg2) { |
| 4423 try { | 4423 try { |
| 4424 return this.runBinary(f, arg1, arg2); | 4424 return this.runBinary(f, arg1, arg2); |
| 4425 } catch (e) { | 4425 } catch (e) { |
| 4426 let s = dart.stackTrace(e); | 4426 let s = dart.stackTrace(e); |
| 4427 return this.handleUncaughtError(e, s); | 4427 return this.handleUncaughtError(e, s); |
| 4428 } | 4428 } |
| 4429 | 4429 |
| 4430 } | 4430 } |
| 4431 bindCallback(f, opt$) { | 4431 bindCallback(f, opt$) { |
| 4432 let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded; | 4432 let runGuarded = opt$ && 'runGuarded' in opt$ ? opt$.runGuarded : true; |
| 4433 let registered = this.registerCallback(f); | 4433 let registered = this.registerCallback(f); |
| 4434 if (runGuarded) { | 4434 if (runGuarded) { |
| 4435 return (() => this.runGuarded(registered)).bind(this); | 4435 return (() => this.runGuarded(registered)).bind(this); |
| 4436 } else { | 4436 } else { |
| 4437 return (() => this.run(registered)).bind(this); | 4437 return (() => this.run(registered)).bind(this); |
| 4438 } | 4438 } |
| 4439 } | 4439 } |
| 4440 bindUnaryCallback(f, opt$) { | 4440 bindUnaryCallback(f, opt$) { |
| 4441 let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded; | 4441 let runGuarded = opt$ && 'runGuarded' in opt$ ? opt$.runGuarded : true; |
| 4442 let registered = this.registerUnaryCallback(f); | 4442 let registered = this.registerUnaryCallback(f); |
| 4443 if (runGuarded) { | 4443 if (runGuarded) { |
| 4444 return ((arg) => this.runUnaryGuarded(registered, arg)).bind(this); | 4444 return ((arg) => this.runUnaryGuarded(registered, arg)).bind(this); |
| 4445 } else { | 4445 } else { |
| 4446 return ((arg) => this.runUnary(registered, arg)).bind(this); | 4446 return ((arg) => this.runUnary(registered, arg)).bind(this); |
| 4447 } | 4447 } |
| 4448 } | 4448 } |
| 4449 bindBinaryCallback(f, opt$) { | 4449 bindBinaryCallback(f, opt$) { |
| 4450 let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded; | 4450 let runGuarded = opt$ && 'runGuarded' in opt$ ? opt$.runGuarded : true; |
| 4451 let registered = this.registerBinaryCallback(f); | 4451 let registered = this.registerBinaryCallback(f); |
| 4452 if (runGuarded) { | 4452 if (runGuarded) { |
| 4453 return ((arg1, arg2) => this.runBinaryGuarded(registered, arg1, arg2)).b
ind(this); | 4453 return ((arg1, arg2) => this.runBinaryGuarded(registered, arg1, arg2)).b
ind(this); |
| 4454 } else { | 4454 } else { |
| 4455 return ((arg1, arg2) => this.runBinary(registered, arg1, arg2)).bind(thi
s); | 4455 return ((arg1, arg2) => this.runBinary(registered, arg1, arg2)).bind(thi
s); |
| 4456 } | 4456 } |
| 4457 } | 4457 } |
| 4458 get(key) { | 4458 get(key) { |
| 4459 let result = this[_map].get(key); | 4459 let result = this[_map].get(key); |
| 4460 if (dart.notNull(result !== null) || dart.notNull(this[_map].containsKey(k
ey))) | 4460 if (dart.notNull(result !== null) || dart.notNull(this[_map].containsKey(k
ey))) |
| 4461 return result; | 4461 return result; |
| 4462 if (this.parent !== null) { | 4462 if (this.parent !== null) { |
| 4463 let value = this.parent.get(key); | 4463 let value = this.parent.get(key); |
| 4464 if (value !== null) { | 4464 if (value !== null) { |
| 4465 this[_map].set(key, value); | 4465 this[_map].set(key, value); |
| 4466 } | 4466 } |
| 4467 return value; | 4467 return value; |
| 4468 } | 4468 } |
| 4469 dart.assert(dart.equals(this, _ROOT_ZONE)); | 4469 dart.assert(dart.equals(this, _ROOT_ZONE)); |
| 4470 return null; | 4470 return null; |
| 4471 } | 4471 } |
| 4472 handleUncaughtError(error, stackTrace) { | 4472 handleUncaughtError(error, stackTrace) { |
| 4473 let implementation = this[_handleUncaughtError]; | 4473 let implementation = this[_handleUncaughtError]; |
| 4474 dart.assert(implementation !== null); | 4474 dart.assert(implementation !== null); |
| 4475 let parentDelegate = _parentDelegate(implementation.zone); | 4475 let parentDelegate = _parentDelegate(implementation.zone); |
| 4476 return dart.dinvokef(implementation['function'], implementation.zone, pare
ntDelegate, this, error, stackTrace); | 4476 return dart.dinvokef(implementation['function'], implementation.zone, pare
ntDelegate, this, error, stackTrace); |
| 4477 } | 4477 } |
| 4478 fork(opt$) { | 4478 fork(opt$) { |
| 4479 let specification = opt$.specification === void 0 ? null : opt$.specificat
ion; | 4479 let specification = opt$ && 'specification' in opt$ ? opt$.specification :
null; |
| 4480 let zoneValues = opt$.zoneValues === void 0 ? null : opt$.zoneValues; | 4480 let zoneValues = opt$ && 'zoneValues' in opt$ ? opt$.zoneValues : null; |
| 4481 let implementation = this[_fork]; | 4481 let implementation = this[_fork]; |
| 4482 dart.assert(implementation !== null); | 4482 dart.assert(implementation !== null); |
| 4483 let parentDelegate = _parentDelegate(implementation.zone); | 4483 let parentDelegate = _parentDelegate(implementation.zone); |
| 4484 return dart.as(dart.dinvokef(implementation['function'], implementation.zo
ne, parentDelegate, this, specification, zoneValues), Zone); | 4484 return dart.as(dart.dinvokef(implementation['function'], implementation.zo
ne, parentDelegate, this, specification, zoneValues), Zone); |
| 4485 } | 4485 } |
| 4486 run(f) { | 4486 run(f) { |
| 4487 let implementation = this[_run]; | 4487 let implementation = this[_run]; |
| 4488 dart.assert(implementation !== null); | 4488 dart.assert(implementation !== null); |
| 4489 let parentDelegate = _parentDelegate(implementation.zone); | 4489 let parentDelegate = _parentDelegate(implementation.zone); |
| 4490 return dart.dinvokef(implementation['function'], implementation.zone, pare
ntDelegate, this, f); | 4490 return dart.dinvokef(implementation['function'], implementation.zone, pare
ntDelegate, this, f); |
| (...skipping 295 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4786 return dart.dinvokef(f, arg1, arg2); | 4786 return dart.dinvokef(f, arg1, arg2); |
| 4787 } | 4787 } |
| 4788 return _rootRunBinary(null, null, this, f, arg1, arg2); | 4788 return _rootRunBinary(null, null, this, f, arg1, arg2); |
| 4789 } catch (e) { | 4789 } catch (e) { |
| 4790 let s = dart.stackTrace(e); | 4790 let s = dart.stackTrace(e); |
| 4791 return this.handleUncaughtError(e, s); | 4791 return this.handleUncaughtError(e, s); |
| 4792 } | 4792 } |
| 4793 | 4793 |
| 4794 } | 4794 } |
| 4795 bindCallback(f, opt$) { | 4795 bindCallback(f, opt$) { |
| 4796 let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded; | 4796 let runGuarded = opt$ && 'runGuarded' in opt$ ? opt$.runGuarded : true; |
| 4797 if (runGuarded) { | 4797 if (runGuarded) { |
| 4798 return (() => this.runGuarded(f)).bind(this); | 4798 return (() => this.runGuarded(f)).bind(this); |
| 4799 } else { | 4799 } else { |
| 4800 return (() => this.run(f)).bind(this); | 4800 return (() => this.run(f)).bind(this); |
| 4801 } | 4801 } |
| 4802 } | 4802 } |
| 4803 bindUnaryCallback(f, opt$) { | 4803 bindUnaryCallback(f, opt$) { |
| 4804 let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded; | 4804 let runGuarded = opt$ && 'runGuarded' in opt$ ? opt$.runGuarded : true; |
| 4805 if (runGuarded) { | 4805 if (runGuarded) { |
| 4806 return ((arg) => this.runUnaryGuarded(f, arg)).bind(this); | 4806 return ((arg) => this.runUnaryGuarded(f, arg)).bind(this); |
| 4807 } else { | 4807 } else { |
| 4808 return ((arg) => this.runUnary(f, arg)).bind(this); | 4808 return ((arg) => this.runUnary(f, arg)).bind(this); |
| 4809 } | 4809 } |
| 4810 } | 4810 } |
| 4811 bindBinaryCallback(f, opt$) { | 4811 bindBinaryCallback(f, opt$) { |
| 4812 let runGuarded = opt$.runGuarded === void 0 ? true : opt$.runGuarded; | 4812 let runGuarded = opt$ && 'runGuarded' in opt$ ? opt$.runGuarded : true; |
| 4813 if (runGuarded) { | 4813 if (runGuarded) { |
| 4814 return ((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bind(this)
; | 4814 return ((arg1, arg2) => this.runBinaryGuarded(f, arg1, arg2)).bind(this)
; |
| 4815 } else { | 4815 } else { |
| 4816 return ((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this); | 4816 return ((arg1, arg2) => this.runBinary(f, arg1, arg2)).bind(this); |
| 4817 } | 4817 } |
| 4818 } | 4818 } |
| 4819 get(key) { | 4819 get(key) { |
| 4820 return null; | 4820 return null; |
| 4821 } | 4821 } |
| 4822 handleUncaughtError(error, stackTrace) { | 4822 handleUncaughtError(error, stackTrace) { |
| 4823 return _rootHandleUncaughtError(null, null, this, error, stackTrace); | 4823 return _rootHandleUncaughtError(null, null, this, error, stackTrace); |
| 4824 } | 4824 } |
| 4825 fork(opt$) { | 4825 fork(opt$) { |
| 4826 let specification = opt$.specification === void 0 ? null : opt$.specificat
ion; | 4826 let specification = opt$ && 'specification' in opt$ ? opt$.specification :
null; |
| 4827 let zoneValues = opt$.zoneValues === void 0 ? null : opt$.zoneValues; | 4827 let zoneValues = opt$ && 'zoneValues' in opt$ ? opt$.zoneValues : null; |
| 4828 return _rootFork(null, null, this, specification, zoneValues); | 4828 return _rootFork(null, null, this, specification, zoneValues); |
| 4829 } | 4829 } |
| 4830 run(f) { | 4830 run(f) { |
| 4831 if (core.identical(Zone[_current], _ROOT_ZONE)) | 4831 if (core.identical(Zone[_current], _ROOT_ZONE)) |
| 4832 return f(); | 4832 return f(); |
| 4833 return _rootRun(null, null, this, f); | 4833 return _rootRun(null, null, this, f); |
| 4834 } | 4834 } |
| 4835 runUnary(f, arg) { | 4835 runUnary(f, arg) { |
| 4836 if (core.identical(Zone[_current], _ROOT_ZONE)) | 4836 if (core.identical(Zone[_current], _ROOT_ZONE)) |
| 4837 return dart.dinvokef(f, arg); | 4837 return dart.dinvokef(f, arg); |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4870 _RootZone._rootDelegate = null; | 4870 _RootZone._rootDelegate = null; |
| 4871 dart.defineLazyProperties(_RootZone, { | 4871 dart.defineLazyProperties(_RootZone, { |
| 4872 get _rootMap() { | 4872 get _rootMap() { |
| 4873 return new collection.HashMap(); | 4873 return new collection.HashMap(); |
| 4874 }, | 4874 }, |
| 4875 set _rootMap(_) {} | 4875 set _rootMap(_) {} |
| 4876 }); | 4876 }); |
| 4877 let _ROOT_ZONE = new _RootZone(); | 4877 let _ROOT_ZONE = new _RootZone(); |
| 4878 // Function runZoned: (() → dynamic, {zoneValues: Map<dynamic, dynamic>, zoneS
pecification: ZoneSpecification, onError: Function}) → dynamic | 4878 // Function runZoned: (() → dynamic, {zoneValues: Map<dynamic, dynamic>, zoneS
pecification: ZoneSpecification, onError: Function}) → dynamic |
| 4879 function runZoned(body, opt$) { | 4879 function runZoned(body, opt$) { |
| 4880 let zoneValues = opt$.zoneValues === void 0 ? null : opt$.zoneValues; | 4880 let zoneValues = opt$ && 'zoneValues' in opt$ ? opt$.zoneValues : null; |
| 4881 let zoneSpecification = opt$.zoneSpecification === void 0 ? null : opt$.zone
Specification; | 4881 let zoneSpecification = opt$ && 'zoneSpecification' in opt$ ? opt$.zoneSpeci
fication : null; |
| 4882 let onError = opt$.onError === void 0 ? null : opt$.onError; | 4882 let onError = opt$ && 'onError' in opt$ ? opt$.onError : null; |
| 4883 let errorHandler = null; | 4883 let errorHandler = null; |
| 4884 if (onError !== null) { | 4884 if (onError !== null) { |
| 4885 errorHandler = (self, parent, zone, error, stackTrace) => { | 4885 errorHandler = (self, parent, zone, error, stackTrace) => { |
| 4886 try { | 4886 try { |
| 4887 if (dart.is(onError, ZoneBinaryCallback)) { | 4887 if (dart.is(onError, ZoneBinaryCallback)) { |
| 4888 return self.parent.runBinary(onError, error, stackTrace); | 4888 return self.parent.runBinary(onError, error, stackTrace); |
| 4889 } | 4889 } |
| 4890 return self.parent.runUnary(dart.as(onError, dart.throw_("Unimplemente
d type (dynamic) → dynamic")), error); | 4890 return self.parent.runUnary(dart.as(onError, dart.throw_("Unimplemente
d type (dynamic) → dynamic")), error); |
| 4891 } catch (e) { | 4891 } catch (e) { |
| 4892 let s = dart.stackTrace(e); | 4892 let s = dart.stackTrace(e); |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4943 exports.StreamIterator = StreamIterator; | 4943 exports.StreamIterator = StreamIterator; |
| 4944 exports.StreamIterator$ = StreamIterator$; | 4944 exports.StreamIterator$ = StreamIterator$; |
| 4945 exports.StreamController = StreamController; | 4945 exports.StreamController = StreamController; |
| 4946 exports.StreamController$ = StreamController$; | 4946 exports.StreamController$ = StreamController$; |
| 4947 exports.Timer = Timer; | 4947 exports.Timer = Timer; |
| 4948 exports.ZoneSpecification = ZoneSpecification; | 4948 exports.ZoneSpecification = ZoneSpecification; |
| 4949 exports.ZoneDelegate = ZoneDelegate; | 4949 exports.ZoneDelegate = ZoneDelegate; |
| 4950 exports.Zone = Zone; | 4950 exports.Zone = Zone; |
| 4951 exports.runZoned = runZoned; | 4951 exports.runZoned = runZoned; |
| 4952 })(async || (async = {})); | 4952 })(async || (async = {})); |
| OLD | NEW |