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

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

Issue 1047203002: compute interfaces lazily (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 8 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
« no previous file with comments | « lib/runtime/dart/_native_typed_data.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 }
11 } 11 }
12 // Function _registerErrorHandler: (Function, Zone) → Function 12 // Function _registerErrorHandler: (Function, Zone) → Function
13 function _registerErrorHandler(errorHandler, zone) { 13 function _registerErrorHandler(errorHandler, zone) {
14 if (dart.is(errorHandler, ZoneBinaryCallback)) { 14 if (dart.is(errorHandler, ZoneBinaryCallback)) {
15 return zone.registerBinaryCallback(errorHandler); 15 return zone.registerBinaryCallback(errorHandler);
16 } else { 16 } else {
17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.throw_("Unimp lemented type (dynamic) → dynamic"))); 17 return zone.registerUnaryCallback(dart.as(errorHandler, dart.throw_("Unimp lemented type (dynamic) → dynamic")));
18 } 18 }
19 } 19 }
20 let _getBestStackTrace = Symbol('_getBestStackTrace'); 20 let _getBestStackTrace = Symbol('_getBestStackTrace');
21 class AsyncError extends core.Object { 21 class AsyncError extends core.Object {
22 AsyncError(error, stackTrace) { 22 AsyncError(error, stackTrace) {
23 this.error = error; 23 this.error = error;
24 this.stackTrace = stackTrace; 24 this.stackTrace = stackTrace;
25 } 25 }
26 toString() { 26 toString() {
27 return dart.as(dart.dinvoke(this.error, 'toString'), core.String); 27 return dart.as(dart.dinvoke(this.error, 'toString'), core.String);
28 } 28 }
29 } 29 }
30 AsyncError[dart.implements] = [core.Error]; 30 AsyncError[dart.implements] = () => [core.Error];
31 class _UncaughtAsyncError extends AsyncError { 31 class _UncaughtAsyncError extends AsyncError {
32 _UncaughtAsyncError(error, stackTrace) { 32 _UncaughtAsyncError(error, stackTrace) {
33 super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, sta ckTrace)); 33 super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, sta ckTrace));
34 } 34 }
35 static [_getBestStackTrace](error, stackTrace) { 35 static [_getBestStackTrace](error, stackTrace) {
36 if (stackTrace != null) 36 if (stackTrace != null)
37 return stackTrace; 37 return stackTrace;
38 if (dart.is(error, core.Error)) { 38 if (dart.is(error, core.Error)) {
39 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); 39 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace);
40 } 40 }
(...skipping 1030 matching lines...) Expand 10 before | Expand all | Expand 10 after
1071 this[_onResume](); 1071 this[_onResume]();
1072 } 1072 }
1073 this[_state] = ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CA LLBACK]); 1073 this[_state] = ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CA LLBACK]);
1074 wasInputPaused = isInputPaused; 1074 wasInputPaused = isInputPaused;
1075 } 1075 }
1076 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) { 1076 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) {
1077 this[_pending].schedule(this); 1077 this[_pending].schedule(this);
1078 } 1078 }
1079 } 1079 }
1080 } 1080 }
1081 _BufferingStreamSubscription[dart.implements] = [StreamSubscription$(T), _Ev entSink$(T), _EventDispatch$(T)]; 1081 _BufferingStreamSubscription[dart.implements] = () => [StreamSubscription$(T ), _EventSink$(T), _EventDispatch$(T)];
1082 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; 1082 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1;
1083 _BufferingStreamSubscription._STATE_CLOSED = 2; 1083 _BufferingStreamSubscription._STATE_CLOSED = 2;
1084 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; 1084 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4;
1085 _BufferingStreamSubscription._STATE_CANCELED = 8; 1085 _BufferingStreamSubscription._STATE_CANCELED = 8;
1086 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; 1086 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16;
1087 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; 1087 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32;
1088 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; 1088 _BufferingStreamSubscription._STATE_HAS_PENDING = 64;
1089 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; 1089 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128;
1090 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; 1090 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7;
1091 return _BufferingStreamSubscription; 1091 return _BufferingStreamSubscription;
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
1134 [_setRemoveAfterFiring]() { 1134 [_setRemoveAfterFiring]() {
1135 dart.assert(this[_isFiring]); 1135 dart.assert(this[_isFiring]);
1136 this[_eventState] = _BroadcastSubscription[_STATE_REMOVE_AFTER_FIRING]; 1136 this[_eventState] = _BroadcastSubscription[_STATE_REMOVE_AFTER_FIRING];
1137 } 1137 }
1138 get [_removeAfterFiring]() { 1138 get [_removeAfterFiring]() {
1139 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri ption[_STATE_REMOVE_AFTER_FIRING])) != 0; 1139 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri ption[_STATE_REMOVE_AFTER_FIRING])) != 0;
1140 } 1140 }
1141 [_onPause]() {} 1141 [_onPause]() {}
1142 [_onResume]() {} 1142 [_onResume]() {}
1143 } 1143 }
1144 _BroadcastSubscription[dart.implements] = [_BroadcastSubscriptionLink]; 1144 _BroadcastSubscription[dart.implements] = () => [_BroadcastSubscriptionLink] ;
1145 _BroadcastSubscription._STATE_EVENT_ID = 1; 1145 _BroadcastSubscription._STATE_EVENT_ID = 1;
1146 _BroadcastSubscription._STATE_FIRING = 2; 1146 _BroadcastSubscription._STATE_FIRING = 2;
1147 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; 1147 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4;
1148 return _BroadcastSubscription; 1148 return _BroadcastSubscription;
1149 }); 1149 });
1150 let _BroadcastSubscription = _BroadcastSubscription$(dart.dynamic); 1150 let _BroadcastSubscription = _BroadcastSubscription$(dart.dynamic);
1151 let _STATE_INITIAL = Symbol('_STATE_INITIAL'); 1151 let _STATE_INITIAL = Symbol('_STATE_INITIAL');
1152 let _addStreamState = Symbol('_addStreamState'); 1152 let _addStreamState = Symbol('_addStreamState');
1153 let _doneFuture = Symbol('_doneFuture'); 1153 let _doneFuture = Symbol('_doneFuture');
1154 let _isEmpty = Symbol('_isEmpty'); 1154 let _isEmpty = Symbol('_isEmpty');
(...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after
1353 } 1353 }
1354 } 1354 }
1355 [_callOnCancel]() { 1355 [_callOnCancel]() {
1356 dart.assert(this[_isEmpty]); 1356 dart.assert(this[_isEmpty]);
1357 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo mplete])) { 1357 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo mplete])) {
1358 this[_doneFuture]._asyncComplete(null); 1358 this[_doneFuture]._asyncComplete(null);
1359 } 1359 }
1360 _runGuarded(this[_onCancel]); 1360 _runGuarded(this[_onCancel]);
1361 } 1361 }
1362 } 1362 }
1363 _BroadcastStreamController[dart.implements] = [StreamController$(T), _Stream ControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _EventDispa tch$(T)]; 1363 _BroadcastStreamController[dart.implements] = () => [StreamController$(T), _ StreamControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _Even tDispatch$(T)];
1364 _BroadcastStreamController._STATE_INITIAL = 0; 1364 _BroadcastStreamController._STATE_INITIAL = 0;
1365 _BroadcastStreamController._STATE_EVENT_ID = 1; 1365 _BroadcastStreamController._STATE_EVENT_ID = 1;
1366 _BroadcastStreamController._STATE_FIRING = 2; 1366 _BroadcastStreamController._STATE_FIRING = 2;
1367 _BroadcastStreamController._STATE_CLOSED = 4; 1367 _BroadcastStreamController._STATE_CLOSED = 4;
1368 _BroadcastStreamController._STATE_ADDSTREAM = 8; 1368 _BroadcastStreamController._STATE_ADDSTREAM = 8;
1369 return _BroadcastStreamController; 1369 return _BroadcastStreamController;
1370 }); 1370 });
1371 let _BroadcastStreamController = _BroadcastStreamController$(dart.dynamic); 1371 let _BroadcastStreamController = _BroadcastStreamController$(dart.dynamic);
1372 let _SyncBroadcastStreamController$ = dart.generic(function(T) { 1372 let _SyncBroadcastStreamController$ = dart.generic(function(T) {
1373 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T) { 1373 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T) {
(...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after
1497 return result; 1497 return result;
1498 } 1498 }
1499 [_callOnCancel]() { 1499 [_callOnCancel]() {
1500 if (this[_hasPending]) { 1500 if (this[_hasPending]) {
1501 this[_pending].clear(); 1501 this[_pending].clear();
1502 this[_pending] = null; 1502 this[_pending] = null;
1503 } 1503 }
1504 super._callOnCancel(); 1504 super._callOnCancel();
1505 } 1505 }
1506 } 1506 }
1507 _AsBroadcastStreamController[dart.implements] = [_EventDispatch$(T)]; 1507 _AsBroadcastStreamController[dart.implements] = () => [_EventDispatch$(T)];
1508 return _AsBroadcastStreamController; 1508 return _AsBroadcastStreamController;
1509 }); 1509 });
1510 let _AsBroadcastStreamController = _AsBroadcastStreamController$(dart.dynamic) ; 1510 let _AsBroadcastStreamController = _AsBroadcastStreamController$(dart.dynamic) ;
1511 let _pauseCount = Symbol('_pauseCount'); 1511 let _pauseCount = Symbol('_pauseCount');
1512 let _resume = Symbol('_resume'); 1512 let _resume = Symbol('_resume');
1513 let _DoneSubscription$ = dart.generic(function(T) { 1513 let _DoneSubscription$ = dart.generic(function(T) {
1514 class _DoneSubscription extends core.Object { 1514 class _DoneSubscription extends core.Object {
1515 _DoneSubscription() { 1515 _DoneSubscription() {
1516 this[_pauseCount] = 0; 1516 this[_pauseCount] = 0;
1517 } 1517 }
(...skipping 19 matching lines...) Expand all
1537 } 1537 }
1538 get isPaused() { 1538 get isPaused() {
1539 return dart.notNull(this[_pauseCount]) > 0; 1539 return dart.notNull(this[_pauseCount]) > 0;
1540 } 1540 }
1541 asFuture(value) { 1541 asFuture(value) {
1542 if (value === void 0) 1542 if (value === void 0)
1543 value = null; 1543 value = null;
1544 return new _Future(); 1544 return new _Future();
1545 } 1545 }
1546 } 1546 }
1547 _DoneSubscription[dart.implements] = [StreamSubscription$(T)]; 1547 _DoneSubscription[dart.implements] = () => [StreamSubscription$(T)];
1548 return _DoneSubscription; 1548 return _DoneSubscription;
1549 }); 1549 });
1550 let _DoneSubscription = _DoneSubscription$(dart.dynamic); 1550 let _DoneSubscription = _DoneSubscription$(dart.dynamic);
1551 class DeferredLibrary extends core.Object { 1551 class DeferredLibrary extends core.Object {
1552 DeferredLibrary(libraryName, opts) { 1552 DeferredLibrary(libraryName, opts) {
1553 let uri = opts && 'uri' in opts ? opts.uri : null; 1553 let uri = opts && 'uri' in opts ? opts.uri : null;
1554 this.libraryName = libraryName; 1554 this.libraryName = libraryName;
1555 this.uri = uri; 1555 this.uri = uri;
1556 } 1556 }
1557 load() { 1557 load() {
1558 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar t" deferred as lib` syntax.'; 1558 throw 'DeferredLibrary not supported. ' + 'please use the `import "lib.dar t" deferred as lib` syntax.';
1559 } 1559 }
1560 } 1560 }
1561 let _s = Symbol('_s'); 1561 let _s = Symbol('_s');
1562 class DeferredLoadException extends core.Object { 1562 class DeferredLoadException extends core.Object {
1563 DeferredLoadException(s$) { 1563 DeferredLoadException(s$) {
1564 this[_s] = s$; 1564 this[_s] = s$;
1565 } 1565 }
1566 toString() { 1566 toString() {
1567 return `DeferredLoadException: '${this[_s]}'`; 1567 return `DeferredLoadException: '${this[_s]}'`;
1568 } 1568 }
1569 } 1569 }
1570 DeferredLoadException[dart.implements] = [core.Exception]; 1570 DeferredLoadException[dart.implements] = () => [core.Exception];
1571 let Future$ = dart.generic(function(T) { 1571 let Future$ = dart.generic(function(T) {
1572 class Future extends core.Object { 1572 class Future extends core.Object {
1573 Future(computation) { 1573 Future(computation) {
1574 let result = new _Future(); 1574 let result = new _Future();
1575 Timer.run((() => { 1575 Timer.run((() => {
1576 try { 1576 try {
1577 result._complete(computation()); 1577 result._complete(computation());
1578 } catch (e) { 1578 } catch (e) {
1579 let s = dart.stackTrace(e); 1579 let s = dart.stackTrace(e);
1580 _completeWithErrorCallback(result, e, s); 1580 _completeWithErrorCallback(result, e, s);
(...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after
1742 } 1742 }
1743 toString() { 1743 toString() {
1744 let result = "TimeoutException"; 1744 let result = "TimeoutException";
1745 if (this.duration != null) 1745 if (this.duration != null)
1746 result = `TimeoutException after ${this.duration}`; 1746 result = `TimeoutException after ${this.duration}`;
1747 if (this.message != null) 1747 if (this.message != null)
1748 result = `${result}: ${this.message}`; 1748 result = `${result}: ${this.message}`;
1749 return result; 1749 return result;
1750 } 1750 }
1751 } 1751 }
1752 TimeoutException[dart.implements] = [core.Exception]; 1752 TimeoutException[dart.implements] = () => [core.Exception];
1753 let Completer$ = dart.generic(function(T) { 1753 let Completer$ = dart.generic(function(T) {
1754 class Completer extends core.Object { 1754 class Completer extends core.Object {
1755 Completer() { 1755 Completer() {
1756 return new _AsyncCompleter(); 1756 return new _AsyncCompleter();
1757 } 1757 }
1758 sync() { 1758 sync() {
1759 return new _SyncCompleter(); 1759 return new _SyncCompleter();
1760 } 1760 }
1761 } 1761 }
1762 dart.defineNamedConstructor(Completer, 'sync'); 1762 dart.defineNamedConstructor(Completer, 'sync');
(...skipping 28 matching lines...) Expand all
1791 if (replacement != null) { 1791 if (replacement != null) {
1792 error = _nonNullError(replacement.error); 1792 error = _nonNullError(replacement.error);
1793 stackTrace = replacement.stackTrace; 1793 stackTrace = replacement.stackTrace;
1794 } 1794 }
1795 this[_completeError](error, stackTrace); 1795 this[_completeError](error, stackTrace);
1796 } 1796 }
1797 get isCompleted() { 1797 get isCompleted() {
1798 return !dart.notNull(this.future[_mayComplete]); 1798 return !dart.notNull(this.future[_mayComplete]);
1799 } 1799 }
1800 } 1800 }
1801 _Completer[dart.implements] = [Completer$(T)]; 1801 _Completer[dart.implements] = () => [Completer$(T)];
1802 return _Completer; 1802 return _Completer;
1803 }); 1803 });
1804 let _Completer = _Completer$(dart.dynamic); 1804 let _Completer = _Completer$(dart.dynamic);
1805 let _AsyncCompleter$ = dart.generic(function(T) { 1805 let _AsyncCompleter$ = dart.generic(function(T) {
1806 class _AsyncCompleter extends _Completer$(T) { 1806 class _AsyncCompleter extends _Completer$(T) {
1807 complete(value) { 1807 complete(value) {
1808 if (value === void 0) 1808 if (value === void 0)
1809 value = null; 1809 value = null;
1810 if (!dart.notNull(this.future[_mayComplete])) 1810 if (!dart.notNull(this.future[_mayComplete]))
1811 throw new core.StateError("Future already completed"); 1811 throw new core.StateError("Future already completed");
(...skipping 530 matching lines...) Expand 10 before | Expand all | Expand 10 after
2342 } 2342 }
2343 }).bind(this), {onError: ((e, s) => { 2343 }).bind(this), {onError: ((e, s) => {
2344 if (timer.isActive) { 2344 if (timer.isActive) {
2345 timer.cancel(); 2345 timer.cancel();
2346 result._completeError(e, dart.as(s, core.StackTrace)); 2346 result._completeError(e, dart.as(s, core.StackTrace));
2347 } 2347 }
2348 }).bind(this)}); 2348 }).bind(this)});
2349 return result; 2349 return result;
2350 } 2350 }
2351 } 2351 }
2352 _Future[dart.implements] = [Future$(T)]; 2352 _Future[dart.implements] = () => [Future$(T)];
2353 dart.defineNamedConstructor(_Future, 'immediate'); 2353 dart.defineNamedConstructor(_Future, 'immediate');
2354 dart.defineNamedConstructor(_Future, 'immediateError'); 2354 dart.defineNamedConstructor(_Future, 'immediateError');
2355 _Future._INCOMPLETE = 0; 2355 _Future._INCOMPLETE = 0;
2356 _Future._PENDING_COMPLETE = 1; 2356 _Future._PENDING_COMPLETE = 1;
2357 _Future._CHAINED = 2; 2357 _Future._CHAINED = 2;
2358 _Future._VALUE = 4; 2358 _Future._VALUE = 4;
2359 _Future._ERROR = 8; 2359 _Future._ERROR = 8;
2360 return _Future; 2360 return _Future;
2361 }); 2361 });
2362 let _Future = _Future$(dart.dynamic); 2362 let _Future = _Future$(dart.dynamic);
(...skipping 139 matching lines...) Expand 10 before | Expand all | Expand 10 after
2502 }); 2502 });
2503 let StreamSubscription$ = dart.generic(function(T) { 2503 let StreamSubscription$ = dart.generic(function(T) {
2504 class StreamSubscription extends core.Object { 2504 class StreamSubscription extends core.Object {
2505 } 2505 }
2506 return StreamSubscription; 2506 return StreamSubscription;
2507 }); 2507 });
2508 let StreamSubscription = StreamSubscription$(dart.dynamic); 2508 let StreamSubscription = StreamSubscription$(dart.dynamic);
2509 let EventSink$ = dart.generic(function(T) { 2509 let EventSink$ = dart.generic(function(T) {
2510 class EventSink extends core.Object { 2510 class EventSink extends core.Object {
2511 } 2511 }
2512 EventSink[dart.implements] = [core.Sink$(T)]; 2512 EventSink[dart.implements] = () => [core.Sink$(T)];
2513 return EventSink; 2513 return EventSink;
2514 }); 2514 });
2515 let EventSink = EventSink$(dart.dynamic); 2515 let EventSink = EventSink$(dart.dynamic);
2516 let _stream = Symbol('_stream'); 2516 let _stream = Symbol('_stream');
2517 let StreamView$ = dart.generic(function(T) { 2517 let StreamView$ = dart.generic(function(T) {
2518 class StreamView extends Stream$(T) { 2518 class StreamView extends Stream$(T) {
2519 StreamView(stream$) { 2519 StreamView(stream$) {
2520 this[_stream] = stream$; 2520 this[_stream] = stream$;
2521 super.Stream(); 2521 super.Stream();
2522 } 2522 }
(...skipping 17 matching lines...) Expand all
2540 let StreamView = StreamView$(dart.dynamic); 2540 let StreamView = StreamView$(dart.dynamic);
2541 let StreamConsumer$ = dart.generic(function(S) { 2541 let StreamConsumer$ = dart.generic(function(S) {
2542 class StreamConsumer extends core.Object { 2542 class StreamConsumer extends core.Object {
2543 } 2543 }
2544 return StreamConsumer; 2544 return StreamConsumer;
2545 }); 2545 });
2546 let StreamConsumer = StreamConsumer$(dart.dynamic); 2546 let StreamConsumer = StreamConsumer$(dart.dynamic);
2547 let StreamSink$ = dart.generic(function(S) { 2547 let StreamSink$ = dart.generic(function(S) {
2548 class StreamSink extends core.Object { 2548 class StreamSink extends core.Object {
2549 } 2549 }
2550 StreamSink[dart.implements] = [StreamConsumer$(S), EventSink$(S)]; 2550 StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)];
2551 return StreamSink; 2551 return StreamSink;
2552 }); 2552 });
2553 let StreamSink = StreamSink$(dart.dynamic); 2553 let StreamSink = StreamSink$(dart.dynamic);
2554 let StreamTransformer$ = dart.generic(function(S, T) { 2554 let StreamTransformer$ = dart.generic(function(S, T) {
2555 class StreamTransformer extends core.Object { 2555 class StreamTransformer extends core.Object {
2556 StreamTransformer(transformer) { 2556 StreamTransformer(transformer) {
2557 return new _StreamSubscriptionTransformer(transformer); 2557 return new _StreamSubscriptionTransformer(transformer);
2558 } 2558 }
2559 fromHandlers(opts) { 2559 fromHandlers(opts) {
2560 return new _StreamHandlerTransformer(opts); 2560 return new _StreamHandlerTransformer(opts);
(...skipping 22 matching lines...) Expand all
2583 } 2583 }
2584 addError(error, stackTrace) { 2584 addError(error, stackTrace) {
2585 if (stackTrace === void 0) 2585 if (stackTrace === void 0)
2586 stackTrace = null; 2586 stackTrace = null;
2587 this[_sink].addError(error, stackTrace); 2587 this[_sink].addError(error, stackTrace);
2588 } 2588 }
2589 close() { 2589 close() {
2590 this[_sink].close(); 2590 this[_sink].close();
2591 } 2591 }
2592 } 2592 }
2593 _ControllerEventSinkWrapper[dart.implements] = [EventSink$(T)]; 2593 _ControllerEventSinkWrapper[dart.implements] = () => [EventSink$(T)];
2594 return _ControllerEventSinkWrapper; 2594 return _ControllerEventSinkWrapper;
2595 }); 2595 });
2596 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic); 2596 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic);
2597 let StreamController$ = dart.generic(function(T) { 2597 let StreamController$ = dart.generic(function(T) {
2598 class StreamController extends core.Object { 2598 class StreamController extends core.Object {
2599 StreamController(opts) { 2599 StreamController(opts) {
2600 let onListen = opts && 'onListen' in opts ? opts.onListen : null; 2600 let onListen = opts && 'onListen' in opts ? opts.onListen : null;
2601 let onPause = opts && 'onPause' in opts ? opts.onPause : null; 2601 let onPause = opts && 'onPause' in opts ? opts.onPause : null;
2602 let onResume = opts && 'onResume' in opts ? opts.onResume : null; 2602 let onResume = opts && 'onResume' in opts ? opts.onResume : null;
2603 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; 2603 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
2604 let sync = opts && 'sync' in opts ? opts.sync : false; 2604 let sync = opts && 'sync' in opts ? opts.sync : false;
2605 if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && d art.notNull(onResume == null) && dart.notNull(onCancel == null)) { 2605 if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && d art.notNull(onResume == null) && dart.notNull(onCancel == null)) {
2606 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC allbackAsyncStreamController(), StreamController$(T)); 2606 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC allbackAsyncStreamController(), StreamController$(T));
2607 } 2607 }
2608 return sync ? new _SyncStreamController(onListen, onPause, onResume, onC ancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel); 2608 return sync ? new _SyncStreamController(onListen, onPause, onResume, onC ancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel);
2609 } 2609 }
2610 broadcast(opts) { 2610 broadcast(opts) {
2611 let onListen = opts && 'onListen' in opts ? opts.onListen : null; 2611 let onListen = opts && 'onListen' in opts ? opts.onListen : null;
2612 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; 2612 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
2613 let sync = opts && 'sync' in opts ? opts.sync : false; 2613 let sync = opts && 'sync' in opts ? opts.sync : false;
2614 return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : n ew _AsyncBroadcastStreamController(onListen, onCancel); 2614 return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : n ew _AsyncBroadcastStreamController(onListen, onCancel);
2615 } 2615 }
2616 } 2616 }
2617 StreamController[dart.implements] = [StreamSink$(T)]; 2617 StreamController[dart.implements] = () => [StreamSink$(T)];
2618 dart.defineNamedConstructor(StreamController, 'broadcast'); 2618 dart.defineNamedConstructor(StreamController, 'broadcast');
2619 return StreamController; 2619 return StreamController;
2620 }); 2620 });
2621 let StreamController = StreamController$(dart.dynamic); 2621 let StreamController = StreamController$(dart.dynamic);
2622 let _StreamControllerLifecycle$ = dart.generic(function(T) { 2622 let _StreamControllerLifecycle$ = dart.generic(function(T) {
2623 class _StreamControllerLifecycle extends core.Object { 2623 class _StreamControllerLifecycle extends core.Object {
2624 [_recordPause](subscription) {} 2624 [_recordPause](subscription) {}
2625 [_recordResume](subscription) {} 2625 [_recordResume](subscription) {}
2626 [_recordCancel](subscription) { 2626 [_recordCancel](subscription) {
2627 return null; 2627 return null;
(...skipping 222 matching lines...) Expand 10 before | Expand all | Expand 10 after
2850 _runGuarded(this[_onPause]); 2850 _runGuarded(this[_onPause]);
2851 } 2851 }
2852 [_recordResume](subscription) { 2852 [_recordResume](subscription) {
2853 if (this[_isAddingStream]) { 2853 if (this[_isAddingStream]) {
2854 let addState = dart.as(this[_varData], _StreamControllerAddStreamState ); 2854 let addState = dart.as(this[_varData], _StreamControllerAddStreamState );
2855 addState.resume(); 2855 addState.resume();
2856 } 2856 }
2857 _runGuarded(this[_onResume]); 2857 _runGuarded(this[_onResume]);
2858 } 2858 }
2859 } 2859 }
2860 _StreamController[dart.implements] = [StreamController$(T), _StreamControlle rLifecycle$(T), _EventSink$(T), _EventDispatch$(T)]; 2860 _StreamController[dart.implements] = () => [StreamController$(T), _StreamCon trollerLifecycle$(T), _EventSink$(T), _EventDispatch$(T)];
2861 _StreamController._STATE_INITIAL = 0; 2861 _StreamController._STATE_INITIAL = 0;
2862 _StreamController._STATE_SUBSCRIBED = 1; 2862 _StreamController._STATE_SUBSCRIBED = 1;
2863 _StreamController._STATE_CANCELED = 2; 2863 _StreamController._STATE_CANCELED = 2;
2864 _StreamController._STATE_SUBSCRIPTION_MASK = 3; 2864 _StreamController._STATE_SUBSCRIPTION_MASK = 3;
2865 _StreamController._STATE_CLOSED = 4; 2865 _StreamController._STATE_CLOSED = 4;
2866 _StreamController._STATE_ADDSTREAM = 8; 2866 _StreamController._STATE_ADDSTREAM = 8;
2867 return _StreamController; 2867 return _StreamController;
2868 }); 2868 });
2869 let _StreamController = _StreamController$(dart.dynamic); 2869 let _StreamController = _StreamController$(dart.dynamic);
2870 let _SyncStreamControllerDispatch$ = dart.generic(function(T) { 2870 let _SyncStreamControllerDispatch$ = dart.generic(function(T) {
2871 class _SyncStreamControllerDispatch extends core.Object { 2871 class _SyncStreamControllerDispatch extends core.Object {
2872 [_sendData](data) { 2872 [_sendData](data) {
2873 this[_subscription]._add(data); 2873 this[_subscription]._add(data);
2874 } 2874 }
2875 [_sendError](error, stackTrace) { 2875 [_sendError](error, stackTrace) {
2876 this[_subscription]._addError(error, stackTrace); 2876 this[_subscription]._addError(error, stackTrace);
2877 } 2877 }
2878 [_sendDone]() { 2878 [_sendDone]() {
2879 this[_subscription]._close(); 2879 this[_subscription]._close();
2880 } 2880 }
2881 } 2881 }
2882 _SyncStreamControllerDispatch[dart.implements] = [_StreamController$(T)]; 2882 _SyncStreamControllerDispatch[dart.implements] = () => [_StreamController$(T )];
2883 return _SyncStreamControllerDispatch; 2883 return _SyncStreamControllerDispatch;
2884 }); 2884 });
2885 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(dart.dynami c); 2885 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(dart.dynami c);
2886 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) { 2886 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) {
2887 class _AsyncStreamControllerDispatch extends core.Object { 2887 class _AsyncStreamControllerDispatch extends core.Object {
2888 [_sendData](data) { 2888 [_sendData](data) {
2889 this[_subscription]._addPending(new _DelayedData(data)); 2889 this[_subscription]._addPending(new _DelayedData(data));
2890 } 2890 }
2891 [_sendError](error, stackTrace) { 2891 [_sendError](error, stackTrace) {
2892 this[_subscription]._addPending(new _DelayedError(error, stackTrace)); 2892 this[_subscription]._addPending(new _DelayedError(error, stackTrace));
2893 } 2893 }
2894 [_sendDone]() { 2894 [_sendDone]() {
2895 this[_subscription]._addPending(new _DelayedDone()); 2895 this[_subscription]._addPending(new _DelayedDone());
2896 } 2896 }
2897 } 2897 }
2898 _AsyncStreamControllerDispatch[dart.implements] = [_StreamController$(T)]; 2898 _AsyncStreamControllerDispatch[dart.implements] = () => [_StreamController$( T)];
2899 return _AsyncStreamControllerDispatch; 2899 return _AsyncStreamControllerDispatch;
2900 }); 2900 });
2901 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(dart.dyna mic); 2901 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(dart.dyna mic);
2902 let _AsyncStreamController$ = dart.generic(function(T) { 2902 let _AsyncStreamController$ = dart.generic(function(T) {
2903 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) { 2903 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) {
2904 _AsyncStreamController(onListen$, onPause$, onResume$, onCancel$) { 2904 _AsyncStreamController(onListen$, onPause$, onResume$, onCancel$) {
2905 this[_onListen] = onListen$; 2905 this[_onListen] = onListen$;
2906 this[_onPause] = onPause$; 2906 this[_onPause] = onPause$;
2907 this[_onResume] = onResume$; 2907 this[_onResume] = onResume$;
2908 this[_onCancel] = onCancel$; 2908 this[_onCancel] = onCancel$;
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after
2976 return this[_target].close(); 2976 return this[_target].close();
2977 } 2977 }
2978 addStream(source, opts) { 2978 addStream(source, opts) {
2979 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true; 2979 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
2980 return this[_target].addStream(source, {cancelOnError: cancelOnError}); 2980 return this[_target].addStream(source, {cancelOnError: cancelOnError});
2981 } 2981 }
2982 get done() { 2982 get done() {
2983 return this[_target].done; 2983 return this[_target].done;
2984 } 2984 }
2985 } 2985 }
2986 _StreamSinkWrapper[dart.implements] = [StreamSink$(T)]; 2986 _StreamSinkWrapper[dart.implements] = () => [StreamSink$(T)];
2987 return _StreamSinkWrapper; 2987 return _StreamSinkWrapper;
2988 }); 2988 });
2989 let _StreamSinkWrapper = _StreamSinkWrapper$(dart.dynamic); 2989 let _StreamSinkWrapper = _StreamSinkWrapper$(dart.dynamic);
2990 let _AddStreamState$ = dart.generic(function(T) { 2990 let _AddStreamState$ = dart.generic(function(T) {
2991 class _AddStreamState extends core.Object { 2991 class _AddStreamState extends core.Object {
2992 _AddStreamState(controller, source, cancelOnError) { 2992 _AddStreamState(controller, source, cancelOnError) {
2993 this.addStreamFuture = new _Future(); 2993 this.addStreamFuture = new _Future();
2994 this.addSubscription = source.listen(controller[_add], {onError: dart.as (cancelOnError ? _AddStreamState.makeErrorHandler(controller) : controller[_addE rror], core.Function), onDone: controller[_close], cancelOnError: cancelOnError} ); 2994 this.addSubscription = source.listen(controller[_add], {onError: dart.as (cancelOnError ? _AddStreamState.makeErrorHandler(controller) : controller[_addE rror], core.Function), onDone: controller[_close], cancelOnError: cancelOnError} );
2995 } 2995 }
2996 static makeErrorHandler(controller) { 2996 static makeErrorHandler(controller) {
(...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after
3193 perform(dispatch) { 3193 perform(dispatch) {
3194 dispatch._sendDone(); 3194 dispatch._sendDone();
3195 } 3195 }
3196 get next() { 3196 get next() {
3197 return null; 3197 return null;
3198 } 3198 }
3199 set next(_) { 3199 set next(_) {
3200 throw new core.StateError("No events after a done."); 3200 throw new core.StateError("No events after a done.");
3201 } 3201 }
3202 } 3202 }
3203 _DelayedDone[dart.implements] = [_DelayedEvent]; 3203 _DelayedDone[dart.implements] = () => [_DelayedEvent];
3204 class _StreamImplEvents extends _PendingEvents { 3204 class _StreamImplEvents extends _PendingEvents {
3205 _StreamImplEvents() { 3205 _StreamImplEvents() {
3206 this.firstPendingEvent = null; 3206 this.firstPendingEvent = null;
3207 this.lastPendingEvent = null; 3207 this.lastPendingEvent = null;
3208 super._PendingEvents(); 3208 super._PendingEvents();
3209 } 3209 }
3210 get isEmpty() { 3210 get isEmpty() {
3211 return this.lastPendingEvent == null; 3211 return this.lastPendingEvent == null;
3212 } 3212 }
3213 add(event) { 3213 add(event) {
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after
3315 } 3315 }
3316 [_sendDone]() { 3316 [_sendDone]() {
3317 this[_state] = ~dart.notNull(_DoneStreamSubscription[_SCHEDULED]); 3317 this[_state] = ~dart.notNull(_DoneStreamSubscription[_SCHEDULED]);
3318 if (this.isPaused) 3318 if (this.isPaused)
3319 return; 3319 return;
3320 this[_state] = _DoneStreamSubscription[_DONE_SENT]; 3320 this[_state] = _DoneStreamSubscription[_DONE_SENT];
3321 if (this[_onDone] != null) 3321 if (this[_onDone] != null)
3322 this[_zone].runGuarded(this[_onDone]); 3322 this[_zone].runGuarded(this[_onDone]);
3323 } 3323 }
3324 } 3324 }
3325 _DoneStreamSubscription[dart.implements] = [StreamSubscription$(T)]; 3325 _DoneStreamSubscription[dart.implements] = () => [StreamSubscription$(T)];
3326 _DoneStreamSubscription._DONE_SENT = 1; 3326 _DoneStreamSubscription._DONE_SENT = 1;
3327 _DoneStreamSubscription._SCHEDULED = 2; 3327 _DoneStreamSubscription._SCHEDULED = 2;
3328 _DoneStreamSubscription._PAUSED = 4; 3328 _DoneStreamSubscription._PAUSED = 4;
3329 return _DoneStreamSubscription; 3329 return _DoneStreamSubscription;
3330 }); 3330 });
3331 let _DoneStreamSubscription = _DoneStreamSubscription$(dart.dynamic); 3331 let _DoneStreamSubscription = _DoneStreamSubscription$(dart.dynamic);
3332 let _source = Symbol('_source'); 3332 let _source = Symbol('_source');
3333 let _onListenHandler = Symbol('_onListenHandler'); 3333 let _onListenHandler = Symbol('_onListenHandler');
3334 let _onCancelHandler = Symbol('_onCancelHandler'); 3334 let _onCancelHandler = Symbol('_onCancelHandler');
3335 let _cancelSubscription = Symbol('_cancelSubscription'); 3335 let _cancelSubscription = Symbol('_cancelSubscription');
(...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after
3436 } 3436 }
3437 get isPaused() { 3437 get isPaused() {
3438 return this[_stream][_isSubscriptionPaused]; 3438 return this[_stream][_isSubscriptionPaused];
3439 } 3439 }
3440 asFuture(futureValue) { 3440 asFuture(futureValue) {
3441 if (futureValue === void 0) 3441 if (futureValue === void 0)
3442 futureValue = null; 3442 futureValue = null;
3443 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt ream source subscription."); 3443 throw new core.UnsupportedError("Cannot change handlers of asBroadcastSt ream source subscription.");
3444 } 3444 }
3445 } 3445 }
3446 _BroadcastSubscriptionWrapper[dart.implements] = [StreamSubscription$(T)]; 3446 _BroadcastSubscriptionWrapper[dart.implements] = () => [StreamSubscription$( T)];
3447 return _BroadcastSubscriptionWrapper; 3447 return _BroadcastSubscriptionWrapper;
3448 }); 3448 });
3449 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(dart.dynami c); 3449 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(dart.dynami c);
3450 let _current = Symbol('_current'); 3450 let _current = Symbol('_current');
3451 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); 3451 let _futureOrPrefetch = Symbol('_futureOrPrefetch');
3452 let _STATE_FOUND = Symbol('_STATE_FOUND'); 3452 let _STATE_FOUND = Symbol('_STATE_FOUND');
3453 let _STATE_DONE = Symbol('_STATE_DONE'); 3453 let _STATE_DONE = Symbol('_STATE_DONE');
3454 let _STATE_MOVING = Symbol('_STATE_MOVING'); 3454 let _STATE_MOVING = Symbol('_STATE_MOVING');
3455 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); 3455 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA');
3456 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR'); 3456 let _STATE_EXTRA_ERROR = Symbol('_STATE_EXTRA_ERROR');
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after
3555 let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool)); 3555 let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
3556 this[_clear](); 3556 this[_clear]();
3557 hasNext._complete(false); 3557 hasNext._complete(false);
3558 return; 3558 return;
3559 } 3559 }
3560 this[_subscription].pause(); 3560 this[_subscription].pause();
3561 this[_futureOrPrefetch] = null; 3561 this[_futureOrPrefetch] = null;
3562 this[_state] = _StreamIteratorImpl[_STATE_EXTRA_DONE]; 3562 this[_state] = _StreamIteratorImpl[_STATE_EXTRA_DONE];
3563 } 3563 }
3564 } 3564 }
3565 _StreamIteratorImpl[dart.implements] = [StreamIterator$(T)]; 3565 _StreamIteratorImpl[dart.implements] = () => [StreamIterator$(T)];
3566 _StreamIteratorImpl._STATE_FOUND = 0; 3566 _StreamIteratorImpl._STATE_FOUND = 0;
3567 _StreamIteratorImpl._STATE_DONE = 1; 3567 _StreamIteratorImpl._STATE_DONE = 1;
3568 _StreamIteratorImpl._STATE_MOVING = 2; 3568 _StreamIteratorImpl._STATE_MOVING = 2;
3569 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; 3569 _StreamIteratorImpl._STATE_EXTRA_DATA = 3;
3570 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; 3570 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
3571 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; 3571 _StreamIteratorImpl._STATE_EXTRA_DONE = 5;
3572 return _StreamIteratorImpl; 3572 return _StreamIteratorImpl;
3573 }); 3573 });
3574 let _StreamIteratorImpl = _StreamIteratorImpl$(dart.dynamic); 3574 let _StreamIteratorImpl = _StreamIteratorImpl$(dart.dynamic);
3575 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT race) → dynamic) → dynamic 3575 // Function _runUserCode: (() → dynamic, (dynamic) → dynamic, (dynamic, StackT race) → dynamic) → dynamic
(...skipping 401 matching lines...) Expand 10 before | Expand all | Expand 10 after
3977 } 3977 }
3978 addError(error, stackTrace) { 3978 addError(error, stackTrace) {
3979 if (stackTrace === void 0) 3979 if (stackTrace === void 0)
3980 stackTrace = null; 3980 stackTrace = null;
3981 this[_sink]._addError(error, stackTrace); 3981 this[_sink]._addError(error, stackTrace);
3982 } 3982 }
3983 close() { 3983 close() {
3984 this[_sink]._close(); 3984 this[_sink]._close();
3985 } 3985 }
3986 } 3986 }
3987 _EventSinkWrapper[dart.implements] = [EventSink$(T)]; 3987 _EventSinkWrapper[dart.implements] = () => [EventSink$(T)];
3988 return _EventSinkWrapper; 3988 return _EventSinkWrapper;
3989 }); 3989 });
3990 let _EventSinkWrapper = _EventSinkWrapper$(dart.dynamic); 3990 let _EventSinkWrapper = _EventSinkWrapper$(dart.dynamic);
3991 let _transformerSink = Symbol('_transformerSink'); 3991 let _transformerSink = Symbol('_transformerSink');
3992 let _isSubscribed = Symbol('_isSubscribed'); 3992 let _isSubscribed = Symbol('_isSubscribed');
3993 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { 3993 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) {
3994 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio n$(T) { 3994 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio n$(T) {
3995 _SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone , cancelOnError) { 3995 _SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone , cancelOnError) {
3996 this[_transformerSink] = null; 3996 this[_transformerSink] = null;
3997 this[_subscription] = null; 3997 this[_subscription] = null;
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after
4078 let _sinkMapper = Symbol('_sinkMapper'); 4078 let _sinkMapper = Symbol('_sinkMapper');
4079 let _StreamSinkTransformer$ = dart.generic(function(S, T) { 4079 let _StreamSinkTransformer$ = dart.generic(function(S, T) {
4080 class _StreamSinkTransformer extends core.Object { 4080 class _StreamSinkTransformer extends core.Object {
4081 _StreamSinkTransformer(sinkMapper) { 4081 _StreamSinkTransformer(sinkMapper) {
4082 this[_sinkMapper] = sinkMapper; 4082 this[_sinkMapper] = sinkMapper;
4083 } 4083 }
4084 bind(stream) { 4084 bind(stream) {
4085 return new _BoundSinkStream(stream, this[_sinkMapper]); 4085 return new _BoundSinkStream(stream, this[_sinkMapper]);
4086 } 4086 }
4087 } 4087 }
4088 _StreamSinkTransformer[dart.implements] = [StreamTransformer$(S, T)]; 4088 _StreamSinkTransformer[dart.implements] = () => [StreamTransformer$(S, T)];
4089 return _StreamSinkTransformer; 4089 return _StreamSinkTransformer;
4090 }); 4090 });
4091 let _StreamSinkTransformer = _StreamSinkTransformer$(dart.dynamic, dart.dynami c); 4091 let _StreamSinkTransformer = _StreamSinkTransformer$(dart.dynamic, dart.dynami c);
4092 let _BoundSinkStream$ = dart.generic(function(S, T) { 4092 let _BoundSinkStream$ = dart.generic(function(S, T) {
4093 class _BoundSinkStream extends Stream$(T) { 4093 class _BoundSinkStream extends Stream$(T) {
4094 get isBroadcast() { 4094 get isBroadcast() {
4095 return this[_stream].isBroadcast; 4095 return this[_stream].isBroadcast;
4096 } 4096 }
4097 _BoundSinkStream(stream$, sinkMapper) { 4097 _BoundSinkStream(stream$, sinkMapper) {
4098 this[_stream] = stream$; 4098 this[_stream] = stream$;
(...skipping 25 matching lines...) Expand all
4124 } 4124 }
4125 addError(error, stackTrace) { 4125 addError(error, stackTrace) {
4126 if (stackTrace === void 0) 4126 if (stackTrace === void 0)
4127 stackTrace = null; 4127 stackTrace = null;
4128 return this[_handleError](error, stackTrace, this[_sink]); 4128 return this[_handleError](error, stackTrace, this[_sink]);
4129 } 4129 }
4130 close() { 4130 close() {
4131 return this[_handleDone](this[_sink]); 4131 return this[_handleDone](this[_sink]);
4132 } 4132 }
4133 } 4133 }
4134 _HandlerEventSink[dart.implements] = [EventSink$(S)]; 4134 _HandlerEventSink[dart.implements] = () => [EventSink$(S)];
4135 return _HandlerEventSink; 4135 return _HandlerEventSink;
4136 }); 4136 });
4137 let _HandlerEventSink = _HandlerEventSink$(dart.dynamic, dart.dynamic); 4137 let _HandlerEventSink = _HandlerEventSink$(dart.dynamic, dart.dynamic);
4138 let _defaultHandleData = Symbol('_defaultHandleData'); 4138 let _defaultHandleData = Symbol('_defaultHandleData');
4139 let _defaultHandleError = Symbol('_defaultHandleError'); 4139 let _defaultHandleError = Symbol('_defaultHandleError');
4140 let _defaultHandleDone = Symbol('_defaultHandleDone'); 4140 let _defaultHandleDone = Symbol('_defaultHandleDone');
4141 let _StreamHandlerTransformer$ = dart.generic(function(S, T) { 4141 let _StreamHandlerTransformer$ = dart.generic(function(S, T) {
4142 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { 4142 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) {
4143 _StreamHandlerTransformer(opts) { 4143 _StreamHandlerTransformer(opts) {
4144 let handleData = opts && 'handleData' in opts ? opts.handleData : null; 4144 let handleData = opts && 'handleData' in opts ? opts.handleData : null;
(...skipping 28 matching lines...) Expand all
4173 let _transformer = Symbol('_transformer'); 4173 let _transformer = Symbol('_transformer');
4174 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { 4174 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) {
4175 class _StreamSubscriptionTransformer extends core.Object { 4175 class _StreamSubscriptionTransformer extends core.Object {
4176 _StreamSubscriptionTransformer(transformer$) { 4176 _StreamSubscriptionTransformer(transformer$) {
4177 this[_transformer] = transformer$; 4177 this[_transformer] = transformer$;
4178 } 4178 }
4179 bind(stream) { 4179 bind(stream) {
4180 return new _BoundSubscriptionStream(stream, this[_transformer]); 4180 return new _BoundSubscriptionStream(stream, this[_transformer]);
4181 } 4181 }
4182 } 4182 }
4183 _StreamSubscriptionTransformer[dart.implements] = [StreamTransformer$(S, T)] ; 4183 _StreamSubscriptionTransformer[dart.implements] = () => [StreamTransformer$( S, T)];
4184 return _StreamSubscriptionTransformer; 4184 return _StreamSubscriptionTransformer;
4185 }); 4185 });
4186 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dart.dyna mic, dart.dynamic); 4186 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dart.dyna mic, dart.dynamic);
4187 let _BoundSubscriptionStream$ = dart.generic(function(S, T) { 4187 let _BoundSubscriptionStream$ = dart.generic(function(S, T) {
4188 class _BoundSubscriptionStream extends Stream$(T) { 4188 class _BoundSubscriptionStream extends Stream$(T) {
4189 _BoundSubscriptionStream(stream$, transformer$) { 4189 _BoundSubscriptionStream(stream$, transformer$) {
4190 this[_stream] = stream$; 4190 this[_stream] = stream$;
4191 this[_transformer] = transformer$; 4191 this[_transformer] = transformer$;
4192 super.Stream(); 4192 super.Stream();
4193 } 4193 }
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
4289 this.registerUnaryCallback = registerUnaryCallback; 4289 this.registerUnaryCallback = registerUnaryCallback;
4290 this.registerBinaryCallback = registerBinaryCallback; 4290 this.registerBinaryCallback = registerBinaryCallback;
4291 this.errorCallback = errorCallback; 4291 this.errorCallback = errorCallback;
4292 this.scheduleMicrotask = scheduleMicrotask; 4292 this.scheduleMicrotask = scheduleMicrotask;
4293 this.createTimer = createTimer; 4293 this.createTimer = createTimer;
4294 this.createPeriodicTimer = createPeriodicTimer; 4294 this.createPeriodicTimer = createPeriodicTimer;
4295 this.print = print; 4295 this.print = print;
4296 this.fork = fork; 4296 this.fork = fork;
4297 } 4297 }
4298 } 4298 }
4299 _ZoneSpecification[dart.implements] = [ZoneSpecification]; 4299 _ZoneSpecification[dart.implements] = () => [ZoneSpecification];
4300 class ZoneDelegate extends core.Object { 4300 class ZoneDelegate extends core.Object {
4301 } 4301 }
4302 let _$ = Symbol('_'); 4302 let _$ = Symbol('_');
4303 let _enter = Symbol('_enter'); 4303 let _enter = Symbol('_enter');
4304 let _leave = Symbol('_leave'); 4304 let _leave = Symbol('_leave');
4305 class Zone extends core.Object { 4305 class Zone extends core.Object {
4306 [_$]() { 4306 [_$]() {
4307 } 4307 }
4308 static get current() { 4308 static get current() {
4309 return Zone[_current]; 4309 return Zone[_current];
(...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after
4407 let implementation = this[_delegationTarget][_print]; 4407 let implementation = this[_delegationTarget][_print];
4408 let implZone = implementation.zone; 4408 let implZone = implementation.zone;
4409 dart.dinvokef(implementation.function, implZone, _parentDelegate(implZone) , zone, line); 4409 dart.dinvokef(implementation.function, implZone, _parentDelegate(implZone) , zone, line);
4410 } 4410 }
4411 fork(zone, specification, zoneValues) { 4411 fork(zone, specification, zoneValues) {
4412 let implementation = this[_delegationTarget][_fork]; 4412 let implementation = this[_delegationTarget][_fork];
4413 let implZone = implementation.zone; 4413 let implZone = implementation.zone;
4414 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel egate(implZone), zone, specification, zoneValues), Zone); 4414 return dart.as(dart.dinvokef(implementation.function, implZone, _parentDel egate(implZone), zone, specification, zoneValues), Zone);
4415 } 4415 }
4416 } 4416 }
4417 _ZoneDelegate[dart.implements] = [ZoneDelegate]; 4417 _ZoneDelegate[dart.implements] = () => [ZoneDelegate];
4418 class _Zone extends core.Object { 4418 class _Zone extends core.Object {
4419 _Zone() { 4419 _Zone() {
4420 } 4420 }
4421 inSameErrorZone(otherZone) { 4421 inSameErrorZone(otherZone) {
4422 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone)); 4422 return dart.notNull(core.identical(this, otherZone)) || dart.notNull(core. identical(this.errorZone, otherZone.errorZone));
4423 } 4423 }
4424 } 4424 }
4425 _Zone[dart.implements] = [Zone]; 4425 _Zone[dart.implements] = () => [Zone];
4426 let _delegateCache = Symbol('_delegateCache'); 4426 let _delegateCache = Symbol('_delegateCache');
4427 let _map = Symbol('_map'); 4427 let _map = Symbol('_map');
4428 class _CustomZone extends _Zone { 4428 class _CustomZone extends _Zone {
4429 get [_delegate]() { 4429 get [_delegate]() {
4430 if (this[_delegateCache] != null) 4430 if (this[_delegateCache] != null)
4431 return this[_delegateCache]; 4431 return this[_delegateCache];
4432 this[_delegateCache] = new _ZoneDelegate(this); 4432 this[_delegateCache] = new _ZoneDelegate(this);
4433 return this[_delegateCache]; 4433 return this[_delegateCache];
4434 } 4434 }
4435 _CustomZone(parent, specification, map) { 4435 _CustomZone(parent, specification, map) {
(...skipping 322 matching lines...) Expand 10 before | Expand all | Expand 10 after
4758 get createPeriodicTimer() { 4758 get createPeriodicTimer() {
4759 return _rootCreatePeriodicTimer; 4759 return _rootCreatePeriodicTimer;
4760 } 4760 }
4761 get print() { 4761 get print() {
4762 return _rootPrint; 4762 return _rootPrint;
4763 } 4763 }
4764 get fork() { 4764 get fork() {
4765 return _rootFork; 4765 return _rootFork;
4766 } 4766 }
4767 } 4767 }
4768 _RootZoneSpecification[dart.implements] = [ZoneSpecification]; 4768 _RootZoneSpecification[dart.implements] = () => [ZoneSpecification];
4769 let _rootMap = Symbol('_rootMap'); 4769 let _rootMap = Symbol('_rootMap');
4770 let _rootDelegate = Symbol('_rootDelegate'); 4770 let _rootDelegate = Symbol('_rootDelegate');
4771 class _RootZone extends _Zone { 4771 class _RootZone extends _Zone {
4772 _RootZone() { 4772 _RootZone() {
4773 super._Zone(); 4773 super._Zone();
4774 } 4774 }
4775 get [_run]() { 4775 get [_run]() {
4776 return new _ZoneFunction(_ROOT_ZONE, _rootRun); 4776 return new _ZoneFunction(_ROOT_ZONE, _rootRun);
4777 } 4777 }
4778 get [_runUnary]() { 4778 get [_runUnary]() {
(...skipping 233 matching lines...) Expand 10 before | Expand all | Expand 10 after
5012 exports.StreamIterator = StreamIterator; 5012 exports.StreamIterator = StreamIterator;
5013 exports.StreamIterator$ = StreamIterator$; 5013 exports.StreamIterator$ = StreamIterator$;
5014 exports.StreamController = StreamController; 5014 exports.StreamController = StreamController;
5015 exports.StreamController$ = StreamController$; 5015 exports.StreamController$ = StreamController$;
5016 exports.Timer = Timer; 5016 exports.Timer = Timer;
5017 exports.ZoneSpecification = ZoneSpecification; 5017 exports.ZoneSpecification = ZoneSpecification;
5018 exports.ZoneDelegate = ZoneDelegate; 5018 exports.ZoneDelegate = ZoneDelegate;
5019 exports.Zone = Zone; 5019 exports.Zone = Zone;
5020 exports.runZoned = runZoned; 5020 exports.runZoned = runZoned;
5021 })(async || (async = {})); 5021 })(async || (async = {}));
OLDNEW
« no previous file with comments | « lib/runtime/dart/_native_typed_data.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698