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

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

Issue 1043003002: keep mixin and interface implementation info at runtime (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 class _UncaughtAsyncError extends AsyncError { 31 class _UncaughtAsyncError extends AsyncError {
31 _UncaughtAsyncError(error, stackTrace) { 32 _UncaughtAsyncError(error, stackTrace) {
32 super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, sta ckTrace)); 33 super.AsyncError(error, _UncaughtAsyncError[_getBestStackTrace](error, sta ckTrace));
33 } 34 }
34 static [_getBestStackTrace](error, stackTrace) { 35 static [_getBestStackTrace](error, stackTrace) {
35 if (stackTrace !== null) 36 if (stackTrace !== null)
36 return stackTrace; 37 return stackTrace;
37 if (dart.is(error, core.Error)) { 38 if (dart.is(error, core.Error)) {
38 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace); 39 return dart.as(dart.dload(error, 'stackTrace'), core.StackTrace);
39 } 40 }
(...skipping 1030 matching lines...) Expand 10 before | Expand all | Expand 10 after
1070 this[_onResume](); 1071 this[_onResume]();
1071 } 1072 }
1072 this[_state] = ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CA LLBACK]); 1073 this[_state] = ~dart.notNull(_BufferingStreamSubscription[_STATE_IN_CA LLBACK]);
1073 wasInputPaused = isInputPaused; 1074 wasInputPaused = isInputPaused;
1074 } 1075 }
1075 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) { 1076 if (dart.notNull(this[_hasPending]) && !dart.notNull(this[_isPaused])) {
1076 this[_pending].schedule(this); 1077 this[_pending].schedule(this);
1077 } 1078 }
1078 } 1079 }
1079 } 1080 }
1081 _BufferingStreamSubscription[dart.implements] = [StreamSubscription$(T), _Ev entSink$(T), _EventDispatch$(T)];
1080 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1; 1082 _BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1;
1081 _BufferingStreamSubscription._STATE_CLOSED = 2; 1083 _BufferingStreamSubscription._STATE_CLOSED = 2;
1082 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4; 1084 _BufferingStreamSubscription._STATE_INPUT_PAUSED = 4;
1083 _BufferingStreamSubscription._STATE_CANCELED = 8; 1085 _BufferingStreamSubscription._STATE_CANCELED = 8;
1084 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16; 1086 _BufferingStreamSubscription._STATE_WAIT_FOR_CANCEL = 16;
1085 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32; 1087 _BufferingStreamSubscription._STATE_IN_CALLBACK = 32;
1086 _BufferingStreamSubscription._STATE_HAS_PENDING = 64; 1088 _BufferingStreamSubscription._STATE_HAS_PENDING = 64;
1087 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128; 1089 _BufferingStreamSubscription._STATE_PAUSE_COUNT = 128;
1088 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7; 1090 _BufferingStreamSubscription._STATE_PAUSE_COUNT_SHIFT = 7;
1089 return _BufferingStreamSubscription; 1091 return _BufferingStreamSubscription;
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
1132 [_setRemoveAfterFiring]() { 1134 [_setRemoveAfterFiring]() {
1133 dart.assert(this[_isFiring]); 1135 dart.assert(this[_isFiring]);
1134 this[_eventState] = _BroadcastSubscription[_STATE_REMOVE_AFTER_FIRING]; 1136 this[_eventState] = _BroadcastSubscription[_STATE_REMOVE_AFTER_FIRING];
1135 } 1137 }
1136 get [_removeAfterFiring]() { 1138 get [_removeAfterFiring]() {
1137 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;
1138 } 1140 }
1139 [_onPause]() {} 1141 [_onPause]() {}
1140 [_onResume]() {} 1142 [_onResume]() {}
1141 } 1143 }
1144 _BroadcastSubscription[dart.implements] = [_BroadcastSubscriptionLink];
1142 _BroadcastSubscription._STATE_EVENT_ID = 1; 1145 _BroadcastSubscription._STATE_EVENT_ID = 1;
1143 _BroadcastSubscription._STATE_FIRING = 2; 1146 _BroadcastSubscription._STATE_FIRING = 2;
1144 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4; 1147 _BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4;
1145 return _BroadcastSubscription; 1148 return _BroadcastSubscription;
1146 }); 1149 });
1147 let _BroadcastSubscription = _BroadcastSubscription$(dart.dynamic); 1150 let _BroadcastSubscription = _BroadcastSubscription$(dart.dynamic);
1148 let _STATE_INITIAL = Symbol('_STATE_INITIAL'); 1151 let _STATE_INITIAL = Symbol('_STATE_INITIAL');
1149 let _addStreamState = Symbol('_addStreamState'); 1152 let _addStreamState = Symbol('_addStreamState');
1150 let _doneFuture = Symbol('_doneFuture'); 1153 let _doneFuture = Symbol('_doneFuture');
1151 let _isEmpty = Symbol('_isEmpty'); 1154 let _isEmpty = Symbol('_isEmpty');
(...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after
1350 } 1353 }
1351 } 1354 }
1352 [_callOnCancel]() { 1355 [_callOnCancel]() {
1353 dart.assert(this[_isEmpty]); 1356 dart.assert(this[_isEmpty]);
1354 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo mplete])) { 1357 if (dart.notNull(this.isClosed) && dart.notNull(this[_doneFuture][_mayCo mplete])) {
1355 this[_doneFuture]._asyncComplete(null); 1358 this[_doneFuture]._asyncComplete(null);
1356 } 1359 }
1357 _runGuarded(this[_onCancel]); 1360 _runGuarded(this[_onCancel]);
1358 } 1361 }
1359 } 1362 }
1363 _BroadcastStreamController[dart.implements] = [StreamController$(T), _Stream ControllerLifecycle$(T), _BroadcastSubscriptionLink, _EventSink$(T), _EventDispa tch$(T)];
1360 _BroadcastStreamController._STATE_INITIAL = 0; 1364 _BroadcastStreamController._STATE_INITIAL = 0;
1361 _BroadcastStreamController._STATE_EVENT_ID = 1; 1365 _BroadcastStreamController._STATE_EVENT_ID = 1;
1362 _BroadcastStreamController._STATE_FIRING = 2; 1366 _BroadcastStreamController._STATE_FIRING = 2;
1363 _BroadcastStreamController._STATE_CLOSED = 4; 1367 _BroadcastStreamController._STATE_CLOSED = 4;
1364 _BroadcastStreamController._STATE_ADDSTREAM = 8; 1368 _BroadcastStreamController._STATE_ADDSTREAM = 8;
1365 return _BroadcastStreamController; 1369 return _BroadcastStreamController;
1366 }); 1370 });
1367 let _BroadcastStreamController = _BroadcastStreamController$(dart.dynamic); 1371 let _BroadcastStreamController = _BroadcastStreamController$(dart.dynamic);
1368 let _SyncBroadcastStreamController$ = dart.generic(function(T) { 1372 let _SyncBroadcastStreamController$ = dart.generic(function(T) {
1369 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T) { 1373 class _SyncBroadcastStreamController extends _BroadcastStreamController$(T) {
(...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after
1493 return result; 1497 return result;
1494 } 1498 }
1495 [_callOnCancel]() { 1499 [_callOnCancel]() {
1496 if (this[_hasPending]) { 1500 if (this[_hasPending]) {
1497 this[_pending].clear(); 1501 this[_pending].clear();
1498 this[_pending] = null; 1502 this[_pending] = null;
1499 } 1503 }
1500 super._callOnCancel(); 1504 super._callOnCancel();
1501 } 1505 }
1502 } 1506 }
1507 _AsBroadcastStreamController[dart.implements] = [_EventDispatch$(T)];
1503 return _AsBroadcastStreamController; 1508 return _AsBroadcastStreamController;
1504 }); 1509 });
1505 let _AsBroadcastStreamController = _AsBroadcastStreamController$(dart.dynamic) ; 1510 let _AsBroadcastStreamController = _AsBroadcastStreamController$(dart.dynamic) ;
1506 let _pauseCount = Symbol('_pauseCount'); 1511 let _pauseCount = Symbol('_pauseCount');
1507 let _resume = Symbol('_resume'); 1512 let _resume = Symbol('_resume');
1508 let _DoneSubscription$ = dart.generic(function(T) { 1513 let _DoneSubscription$ = dart.generic(function(T) {
1509 class _DoneSubscription extends core.Object { 1514 class _DoneSubscription extends core.Object {
1510 _DoneSubscription() { 1515 _DoneSubscription() {
1511 this[_pauseCount] = 0; 1516 this[_pauseCount] = 0;
1512 } 1517 }
(...skipping 19 matching lines...) Expand all
1532 } 1537 }
1533 get isPaused() { 1538 get isPaused() {
1534 return dart.notNull(this[_pauseCount]) > 0; 1539 return dart.notNull(this[_pauseCount]) > 0;
1535 } 1540 }
1536 asFuture(value) { 1541 asFuture(value) {
1537 if (value === void 0) 1542 if (value === void 0)
1538 value = null; 1543 value = null;
1539 return new _Future(); 1544 return new _Future();
1540 } 1545 }
1541 } 1546 }
1547 _DoneSubscription[dart.implements] = [StreamSubscription$(T)];
1542 return _DoneSubscription; 1548 return _DoneSubscription;
1543 }); 1549 });
1544 let _DoneSubscription = _DoneSubscription$(dart.dynamic); 1550 let _DoneSubscription = _DoneSubscription$(dart.dynamic);
1545 class DeferredLibrary extends core.Object { 1551 class DeferredLibrary extends core.Object {
1546 DeferredLibrary(libraryName, opts) { 1552 DeferredLibrary(libraryName, opts) {
1547 let uri = opts && 'uri' in opts ? opts.uri : null; 1553 let uri = opts && 'uri' in opts ? opts.uri : null;
1548 this.libraryName = libraryName; 1554 this.libraryName = libraryName;
1549 this.uri = uri; 1555 this.uri = uri;
1550 } 1556 }
1551 load() { 1557 load() {
1552 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.';
1553 } 1559 }
1554 } 1560 }
1555 let _s = Symbol('_s'); 1561 let _s = Symbol('_s');
1556 class DeferredLoadException extends core.Object { 1562 class DeferredLoadException extends core.Object {
1557 DeferredLoadException(s$) { 1563 DeferredLoadException(s$) {
1558 this[_s] = s$; 1564 this[_s] = s$;
1559 } 1565 }
1560 toString() { 1566 toString() {
1561 return `DeferredLoadException: '${this[_s]}'`; 1567 return `DeferredLoadException: '${this[_s]}'`;
1562 } 1568 }
1563 } 1569 }
1570 DeferredLoadException[dart.implements] = [core.Exception];
1564 let Future$ = dart.generic(function(T) { 1571 let Future$ = dart.generic(function(T) {
1565 class Future extends core.Object { 1572 class Future extends core.Object {
1566 Future(computation) { 1573 Future(computation) {
1567 let result = new _Future(); 1574 let result = new _Future();
1568 Timer.run((() => { 1575 Timer.run((() => {
1569 try { 1576 try {
1570 result._complete(computation()); 1577 result._complete(computation());
1571 } catch (e) { 1578 } catch (e) {
1572 let s = dart.stackTrace(e); 1579 let s = dart.stackTrace(e);
1573 _completeWithErrorCallback(result, e, s); 1580 _completeWithErrorCallback(result, e, s);
(...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after
1735 } 1742 }
1736 toString() { 1743 toString() {
1737 let result = "TimeoutException"; 1744 let result = "TimeoutException";
1738 if (this.duration !== null) 1745 if (this.duration !== null)
1739 result = `TimeoutException after ${this.duration}`; 1746 result = `TimeoutException after ${this.duration}`;
1740 if (this.message !== null) 1747 if (this.message !== null)
1741 result = `${result}: ${this.message}`; 1748 result = `${result}: ${this.message}`;
1742 return result; 1749 return result;
1743 } 1750 }
1744 } 1751 }
1752 TimeoutException[dart.implements] = [core.Exception];
1745 let Completer$ = dart.generic(function(T) { 1753 let Completer$ = dart.generic(function(T) {
1746 class Completer extends core.Object { 1754 class Completer extends core.Object {
1747 Completer() { 1755 Completer() {
1748 return new _AsyncCompleter(); 1756 return new _AsyncCompleter();
1749 } 1757 }
1750 sync() { 1758 sync() {
1751 return new _SyncCompleter(); 1759 return new _SyncCompleter();
1752 } 1760 }
1753 } 1761 }
1754 dart.defineNamedConstructor(Completer, 'sync'); 1762 dart.defineNamedConstructor(Completer, 'sync');
(...skipping 28 matching lines...) Expand all
1783 if (replacement !== null) { 1791 if (replacement !== null) {
1784 error = _nonNullError(replacement.error); 1792 error = _nonNullError(replacement.error);
1785 stackTrace = replacement.stackTrace; 1793 stackTrace = replacement.stackTrace;
1786 } 1794 }
1787 this[_completeError](error, stackTrace); 1795 this[_completeError](error, stackTrace);
1788 } 1796 }
1789 get isCompleted() { 1797 get isCompleted() {
1790 return !dart.notNull(this.future[_mayComplete]); 1798 return !dart.notNull(this.future[_mayComplete]);
1791 } 1799 }
1792 } 1800 }
1801 _Completer[dart.implements] = [Completer$(T)];
1793 return _Completer; 1802 return _Completer;
1794 }); 1803 });
1795 let _Completer = _Completer$(dart.dynamic); 1804 let _Completer = _Completer$(dart.dynamic);
1796 let _AsyncCompleter$ = dart.generic(function(T) { 1805 let _AsyncCompleter$ = dart.generic(function(T) {
1797 class _AsyncCompleter extends _Completer$(T) { 1806 class _AsyncCompleter extends _Completer$(T) {
1798 complete(value) { 1807 complete(value) {
1799 if (value === void 0) 1808 if (value === void 0)
1800 value = null; 1809 value = null;
1801 if (!dart.notNull(this.future[_mayComplete])) 1810 if (!dart.notNull(this.future[_mayComplete]))
1802 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
2333 } 2342 }
2334 }).bind(this), {onError: ((e, s) => { 2343 }).bind(this), {onError: ((e, s) => {
2335 if (timer.isActive) { 2344 if (timer.isActive) {
2336 timer.cancel(); 2345 timer.cancel();
2337 result._completeError(e, dart.as(s, core.StackTrace)); 2346 result._completeError(e, dart.as(s, core.StackTrace));
2338 } 2347 }
2339 }).bind(this)}); 2348 }).bind(this)});
2340 return result; 2349 return result;
2341 } 2350 }
2342 } 2351 }
2352 _Future[dart.implements] = [Future$(T)];
2343 dart.defineNamedConstructor(_Future, 'immediate'); 2353 dart.defineNamedConstructor(_Future, 'immediate');
2344 dart.defineNamedConstructor(_Future, 'immediateError'); 2354 dart.defineNamedConstructor(_Future, 'immediateError');
2345 _Future._INCOMPLETE = 0; 2355 _Future._INCOMPLETE = 0;
2346 _Future._PENDING_COMPLETE = 1; 2356 _Future._PENDING_COMPLETE = 1;
2347 _Future._CHAINED = 2; 2357 _Future._CHAINED = 2;
2348 _Future._VALUE = 4; 2358 _Future._VALUE = 4;
2349 _Future._ERROR = 8; 2359 _Future._ERROR = 8;
2350 return _Future; 2360 return _Future;
2351 }); 2361 });
2352 let _Future = _Future$(dart.dynamic); 2362 let _Future = _Future$(dart.dynamic);
(...skipping 139 matching lines...) Expand 10 before | Expand all | Expand 10 after
2492 }); 2502 });
2493 let StreamSubscription$ = dart.generic(function(T) { 2503 let StreamSubscription$ = dart.generic(function(T) {
2494 class StreamSubscription extends core.Object { 2504 class StreamSubscription extends core.Object {
2495 } 2505 }
2496 return StreamSubscription; 2506 return StreamSubscription;
2497 }); 2507 });
2498 let StreamSubscription = StreamSubscription$(dart.dynamic); 2508 let StreamSubscription = StreamSubscription$(dart.dynamic);
2499 let EventSink$ = dart.generic(function(T) { 2509 let EventSink$ = dart.generic(function(T) {
2500 class EventSink extends core.Object { 2510 class EventSink extends core.Object {
2501 } 2511 }
2512 EventSink[dart.implements] = [core.Sink$(T)];
2502 return EventSink; 2513 return EventSink;
2503 }); 2514 });
2504 let EventSink = EventSink$(dart.dynamic); 2515 let EventSink = EventSink$(dart.dynamic);
2505 let _stream = Symbol('_stream'); 2516 let _stream = Symbol('_stream');
2506 let StreamView$ = dart.generic(function(T) { 2517 let StreamView$ = dart.generic(function(T) {
2507 class StreamView extends Stream$(T) { 2518 class StreamView extends Stream$(T) {
2508 StreamView(stream$) { 2519 StreamView(stream$) {
2509 this[_stream] = stream$; 2520 this[_stream] = stream$;
2510 super.Stream(); 2521 super.Stream();
2511 } 2522 }
(...skipping 17 matching lines...) Expand all
2529 let StreamView = StreamView$(dart.dynamic); 2540 let StreamView = StreamView$(dart.dynamic);
2530 let StreamConsumer$ = dart.generic(function(S) { 2541 let StreamConsumer$ = dart.generic(function(S) {
2531 class StreamConsumer extends core.Object { 2542 class StreamConsumer extends core.Object {
2532 } 2543 }
2533 return StreamConsumer; 2544 return StreamConsumer;
2534 }); 2545 });
2535 let StreamConsumer = StreamConsumer$(dart.dynamic); 2546 let StreamConsumer = StreamConsumer$(dart.dynamic);
2536 let StreamSink$ = dart.generic(function(S) { 2547 let StreamSink$ = dart.generic(function(S) {
2537 class StreamSink extends core.Object { 2548 class StreamSink extends core.Object {
2538 } 2549 }
2550 StreamSink[dart.implements] = [StreamConsumer$(S), EventSink$(S)];
2539 return StreamSink; 2551 return StreamSink;
2540 }); 2552 });
2541 let StreamSink = StreamSink$(dart.dynamic); 2553 let StreamSink = StreamSink$(dart.dynamic);
2542 let StreamTransformer$ = dart.generic(function(S, T) { 2554 let StreamTransformer$ = dart.generic(function(S, T) {
2543 class StreamTransformer extends core.Object { 2555 class StreamTransformer extends core.Object {
2544 StreamTransformer(transformer) { 2556 StreamTransformer(transformer) {
2545 return new _StreamSubscriptionTransformer(transformer); 2557 return new _StreamSubscriptionTransformer(transformer);
2546 } 2558 }
2547 fromHandlers(opts) { 2559 fromHandlers(opts) {
2548 return new _StreamHandlerTransformer(opts); 2560 return new _StreamHandlerTransformer(opts);
(...skipping 22 matching lines...) Expand all
2571 } 2583 }
2572 addError(error, stackTrace) { 2584 addError(error, stackTrace) {
2573 if (stackTrace === void 0) 2585 if (stackTrace === void 0)
2574 stackTrace = null; 2586 stackTrace = null;
2575 this[_sink].addError(error, stackTrace); 2587 this[_sink].addError(error, stackTrace);
2576 } 2588 }
2577 close() { 2589 close() {
2578 this[_sink].close(); 2590 this[_sink].close();
2579 } 2591 }
2580 } 2592 }
2593 _ControllerEventSinkWrapper[dart.implements] = [EventSink$(T)];
2581 return _ControllerEventSinkWrapper; 2594 return _ControllerEventSinkWrapper;
2582 }); 2595 });
2583 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic); 2596 let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic);
2584 let StreamController$ = dart.generic(function(T) { 2597 let StreamController$ = dart.generic(function(T) {
2585 class StreamController extends core.Object { 2598 class StreamController extends core.Object {
2586 StreamController(opts) { 2599 StreamController(opts) {
2587 let onListen = opts && 'onListen' in opts ? opts.onListen : null; 2600 let onListen = opts && 'onListen' in opts ? opts.onListen : null;
2588 let onPause = opts && 'onPause' in opts ? opts.onPause : null; 2601 let onPause = opts && 'onPause' in opts ? opts.onPause : null;
2589 let onResume = opts && 'onResume' in opts ? opts.onResume : null; 2602 let onResume = opts && 'onResume' in opts ? opts.onResume : null;
2590 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; 2603 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
2591 let sync = opts && 'sync' in opts ? opts.sync : false; 2604 let sync = opts && 'sync' in opts ? opts.sync : false;
2592 if (dart.notNull(onListen === null) && dart.notNull(onPause === null) && dart.notNull(onResume === null) && dart.notNull(onCancel === null)) { 2605 if (dart.notNull(onListen === null) && dart.notNull(onPause === null) && dart.notNull(onResume === null) && dart.notNull(onCancel === null)) {
2593 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC allbackAsyncStreamController(), StreamController$(T)); 2606 return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoC allbackAsyncStreamController(), StreamController$(T));
2594 } 2607 }
2595 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);
2596 } 2609 }
2597 broadcast(opts) { 2610 broadcast(opts) {
2598 let onListen = opts && 'onListen' in opts ? opts.onListen : null; 2611 let onListen = opts && 'onListen' in opts ? opts.onListen : null;
2599 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; 2612 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
2600 let sync = opts && 'sync' in opts ? opts.sync : false; 2613 let sync = opts && 'sync' in opts ? opts.sync : false;
2601 return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : n ew _AsyncBroadcastStreamController(onListen, onCancel); 2614 return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : n ew _AsyncBroadcastStreamController(onListen, onCancel);
2602 } 2615 }
2603 } 2616 }
2617 StreamController[dart.implements] = [StreamSink$(T)];
2604 dart.defineNamedConstructor(StreamController, 'broadcast'); 2618 dart.defineNamedConstructor(StreamController, 'broadcast');
2605 return StreamController; 2619 return StreamController;
2606 }); 2620 });
2607 let StreamController = StreamController$(dart.dynamic); 2621 let StreamController = StreamController$(dart.dynamic);
2608 let _StreamControllerLifecycle$ = dart.generic(function(T) { 2622 let _StreamControllerLifecycle$ = dart.generic(function(T) {
2609 class _StreamControllerLifecycle extends core.Object { 2623 class _StreamControllerLifecycle extends core.Object {
2610 [_recordPause](subscription) {} 2624 [_recordPause](subscription) {}
2611 [_recordResume](subscription) {} 2625 [_recordResume](subscription) {}
2612 [_recordCancel](subscription) { 2626 [_recordCancel](subscription) {
2613 return null; 2627 return null;
(...skipping 222 matching lines...) Expand 10 before | Expand all | Expand 10 after
2836 _runGuarded(this[_onPause]); 2850 _runGuarded(this[_onPause]);
2837 } 2851 }
2838 [_recordResume](subscription) { 2852 [_recordResume](subscription) {
2839 if (this[_isAddingStream]) { 2853 if (this[_isAddingStream]) {
2840 let addState = dart.as(this[_varData], _StreamControllerAddStreamState ); 2854 let addState = dart.as(this[_varData], _StreamControllerAddStreamState );
2841 addState.resume(); 2855 addState.resume();
2842 } 2856 }
2843 _runGuarded(this[_onResume]); 2857 _runGuarded(this[_onResume]);
2844 } 2858 }
2845 } 2859 }
2860 _StreamController[dart.implements] = [StreamController$(T), _StreamControlle rLifecycle$(T), _EventSink$(T), _EventDispatch$(T)];
2846 _StreamController._STATE_INITIAL = 0; 2861 _StreamController._STATE_INITIAL = 0;
2847 _StreamController._STATE_SUBSCRIBED = 1; 2862 _StreamController._STATE_SUBSCRIBED = 1;
2848 _StreamController._STATE_CANCELED = 2; 2863 _StreamController._STATE_CANCELED = 2;
2849 _StreamController._STATE_SUBSCRIPTION_MASK = 3; 2864 _StreamController._STATE_SUBSCRIPTION_MASK = 3;
2850 _StreamController._STATE_CLOSED = 4; 2865 _StreamController._STATE_CLOSED = 4;
2851 _StreamController._STATE_ADDSTREAM = 8; 2866 _StreamController._STATE_ADDSTREAM = 8;
2852 return _StreamController; 2867 return _StreamController;
2853 }); 2868 });
2854 let _StreamController = _StreamController$(dart.dynamic); 2869 let _StreamController = _StreamController$(dart.dynamic);
2855 let _SyncStreamControllerDispatch$ = dart.generic(function(T) { 2870 let _SyncStreamControllerDispatch$ = dart.generic(function(T) {
2856 class _SyncStreamControllerDispatch extends core.Object { 2871 class _SyncStreamControllerDispatch extends core.Object {
2857 [_sendData](data) { 2872 [_sendData](data) {
2858 this[_subscription]._add(data); 2873 this[_subscription]._add(data);
2859 } 2874 }
2860 [_sendError](error, stackTrace) { 2875 [_sendError](error, stackTrace) {
2861 this[_subscription]._addError(error, stackTrace); 2876 this[_subscription]._addError(error, stackTrace);
2862 } 2877 }
2863 [_sendDone]() { 2878 [_sendDone]() {
2864 this[_subscription]._close(); 2879 this[_subscription]._close();
2865 } 2880 }
2866 } 2881 }
2882 _SyncStreamControllerDispatch[dart.implements] = [_StreamController$(T)];
2867 return _SyncStreamControllerDispatch; 2883 return _SyncStreamControllerDispatch;
2868 }); 2884 });
2869 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(dart.dynami c); 2885 let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$(dart.dynami c);
2870 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) { 2886 let _AsyncStreamControllerDispatch$ = dart.generic(function(T) {
2871 class _AsyncStreamControllerDispatch extends core.Object { 2887 class _AsyncStreamControllerDispatch extends core.Object {
2872 [_sendData](data) { 2888 [_sendData](data) {
2873 this[_subscription]._addPending(new _DelayedData(data)); 2889 this[_subscription]._addPending(new _DelayedData(data));
2874 } 2890 }
2875 [_sendError](error, stackTrace) { 2891 [_sendError](error, stackTrace) {
2876 this[_subscription]._addPending(new _DelayedError(error, stackTrace)); 2892 this[_subscription]._addPending(new _DelayedError(error, stackTrace));
2877 } 2893 }
2878 [_sendDone]() { 2894 [_sendDone]() {
2879 this[_subscription]._addPending(new _DelayedDone()); 2895 this[_subscription]._addPending(new _DelayedDone());
2880 } 2896 }
2881 } 2897 }
2898 _AsyncStreamControllerDispatch[dart.implements] = [_StreamController$(T)];
2882 return _AsyncStreamControllerDispatch; 2899 return _AsyncStreamControllerDispatch;
2883 }); 2900 });
2884 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(dart.dyna mic); 2901 let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$(dart.dyna mic);
2885 let _AsyncStreamController$ = dart.generic(function(T) { 2902 let _AsyncStreamController$ = dart.generic(function(T) {
2886 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) { 2903 class _AsyncStreamController extends dart.mixin(_StreamController$(T), _Asyn cStreamControllerDispatch$(T)) {
2887 _AsyncStreamController(onListen$, onPause$, onResume$, onCancel$) { 2904 _AsyncStreamController(onListen$, onPause$, onResume$, onCancel$) {
2888 this[_onListen] = onListen$; 2905 this[_onListen] = onListen$;
2889 this[_onPause] = onPause$; 2906 this[_onPause] = onPause$;
2890 this[_onResume] = onResume$; 2907 this[_onResume] = onResume$;
2891 this[_onCancel] = onCancel$; 2908 this[_onCancel] = onCancel$;
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after
2959 return this[_target].close(); 2976 return this[_target].close();
2960 } 2977 }
2961 addStream(source, opts) { 2978 addStream(source, opts) {
2962 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true; 2979 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : true;
2963 return this[_target].addStream(source, {cancelOnError: cancelOnError}); 2980 return this[_target].addStream(source, {cancelOnError: cancelOnError});
2964 } 2981 }
2965 get done() { 2982 get done() {
2966 return this[_target].done; 2983 return this[_target].done;
2967 } 2984 }
2968 } 2985 }
2986 _StreamSinkWrapper[dart.implements] = [StreamSink$(T)];
2969 return _StreamSinkWrapper; 2987 return _StreamSinkWrapper;
2970 }); 2988 });
2971 let _StreamSinkWrapper = _StreamSinkWrapper$(dart.dynamic); 2989 let _StreamSinkWrapper = _StreamSinkWrapper$(dart.dynamic);
2972 let _AddStreamState$ = dart.generic(function(T) { 2990 let _AddStreamState$ = dart.generic(function(T) {
2973 class _AddStreamState extends core.Object { 2991 class _AddStreamState extends core.Object {
2974 _AddStreamState(controller, source, cancelOnError) { 2992 _AddStreamState(controller, source, cancelOnError) {
2975 this.addStreamFuture = new _Future(); 2993 this.addStreamFuture = new _Future();
2976 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} );
2977 } 2995 }
2978 static makeErrorHandler(controller) { 2996 static makeErrorHandler(controller) {
(...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after
3175 perform(dispatch) { 3193 perform(dispatch) {
3176 dispatch._sendDone(); 3194 dispatch._sendDone();
3177 } 3195 }
3178 get next() { 3196 get next() {
3179 return null; 3197 return null;
3180 } 3198 }
3181 set next(_) { 3199 set next(_) {
3182 throw new core.StateError("No events after a done."); 3200 throw new core.StateError("No events after a done.");
3183 } 3201 }
3184 } 3202 }
3203 _DelayedDone[dart.implements] = [_DelayedEvent];
3185 class _StreamImplEvents extends _PendingEvents { 3204 class _StreamImplEvents extends _PendingEvents {
3186 _StreamImplEvents() { 3205 _StreamImplEvents() {
3187 this.firstPendingEvent = null; 3206 this.firstPendingEvent = null;
3188 this.lastPendingEvent = null; 3207 this.lastPendingEvent = null;
3189 super._PendingEvents(); 3208 super._PendingEvents();
3190 } 3209 }
3191 get isEmpty() { 3210 get isEmpty() {
3192 return this.lastPendingEvent === null; 3211 return this.lastPendingEvent === null;
3193 } 3212 }
3194 add(event) { 3213 add(event) {
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after
3296 } 3315 }
3297 [_sendDone]() { 3316 [_sendDone]() {
3298 this[_state] = ~dart.notNull(_DoneStreamSubscription[_SCHEDULED]); 3317 this[_state] = ~dart.notNull(_DoneStreamSubscription[_SCHEDULED]);
3299 if (this.isPaused) 3318 if (this.isPaused)
3300 return; 3319 return;
3301 this[_state] = _DoneStreamSubscription[_DONE_SENT]; 3320 this[_state] = _DoneStreamSubscription[_DONE_SENT];
3302 if (this[_onDone] !== null) 3321 if (this[_onDone] !== null)
3303 this[_zone].runGuarded(this[_onDone]); 3322 this[_zone].runGuarded(this[_onDone]);
3304 } 3323 }
3305 } 3324 }
3325 _DoneStreamSubscription[dart.implements] = [StreamSubscription$(T)];
3306 _DoneStreamSubscription._DONE_SENT = 1; 3326 _DoneStreamSubscription._DONE_SENT = 1;
3307 _DoneStreamSubscription._SCHEDULED = 2; 3327 _DoneStreamSubscription._SCHEDULED = 2;
3308 _DoneStreamSubscription._PAUSED = 4; 3328 _DoneStreamSubscription._PAUSED = 4;
3309 return _DoneStreamSubscription; 3329 return _DoneStreamSubscription;
3310 }); 3330 });
3311 let _DoneStreamSubscription = _DoneStreamSubscription$(dart.dynamic); 3331 let _DoneStreamSubscription = _DoneStreamSubscription$(dart.dynamic);
3312 let _source = Symbol('_source'); 3332 let _source = Symbol('_source');
3313 let _onListenHandler = Symbol('_onListenHandler'); 3333 let _onListenHandler = Symbol('_onListenHandler');
3314 let _onCancelHandler = Symbol('_onCancelHandler'); 3334 let _onCancelHandler = Symbol('_onCancelHandler');
3315 let _cancelSubscription = Symbol('_cancelSubscription'); 3335 let _cancelSubscription = Symbol('_cancelSubscription');
(...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after
3416 } 3436 }
3417 get isPaused() { 3437 get isPaused() {
3418 return this[_stream][_isSubscriptionPaused]; 3438 return this[_stream][_isSubscriptionPaused];
3419 } 3439 }
3420 asFuture(futureValue) { 3440 asFuture(futureValue) {
3421 if (futureValue === void 0) 3441 if (futureValue === void 0)
3422 futureValue = null; 3442 futureValue = null;
3423 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.");
3424 } 3444 }
3425 } 3445 }
3446 _BroadcastSubscriptionWrapper[dart.implements] = [StreamSubscription$(T)];
3426 return _BroadcastSubscriptionWrapper; 3447 return _BroadcastSubscriptionWrapper;
3427 }); 3448 });
3428 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(dart.dynami c); 3449 let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$(dart.dynami c);
3429 let _current = Symbol('_current'); 3450 let _current = Symbol('_current');
3430 let _futureOrPrefetch = Symbol('_futureOrPrefetch'); 3451 let _futureOrPrefetch = Symbol('_futureOrPrefetch');
3431 let _STATE_FOUND = Symbol('_STATE_FOUND'); 3452 let _STATE_FOUND = Symbol('_STATE_FOUND');
3432 let _STATE_DONE = Symbol('_STATE_DONE'); 3453 let _STATE_DONE = Symbol('_STATE_DONE');
3433 let _STATE_MOVING = Symbol('_STATE_MOVING'); 3454 let _STATE_MOVING = Symbol('_STATE_MOVING');
3434 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA'); 3455 let _STATE_EXTRA_DATA = Symbol('_STATE_EXTRA_DATA');
3435 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
3534 let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool)); 3555 let hasNext = dart.as(this[_futureOrPrefetch], _Future$(core.bool));
3535 this[_clear](); 3556 this[_clear]();
3536 hasNext._complete(false); 3557 hasNext._complete(false);
3537 return; 3558 return;
3538 } 3559 }
3539 this[_subscription].pause(); 3560 this[_subscription].pause();
3540 this[_futureOrPrefetch] = null; 3561 this[_futureOrPrefetch] = null;
3541 this[_state] = _StreamIteratorImpl[_STATE_EXTRA_DONE]; 3562 this[_state] = _StreamIteratorImpl[_STATE_EXTRA_DONE];
3542 } 3563 }
3543 } 3564 }
3565 _StreamIteratorImpl[dart.implements] = [StreamIterator$(T)];
3544 _StreamIteratorImpl._STATE_FOUND = 0; 3566 _StreamIteratorImpl._STATE_FOUND = 0;
3545 _StreamIteratorImpl._STATE_DONE = 1; 3567 _StreamIteratorImpl._STATE_DONE = 1;
3546 _StreamIteratorImpl._STATE_MOVING = 2; 3568 _StreamIteratorImpl._STATE_MOVING = 2;
3547 _StreamIteratorImpl._STATE_EXTRA_DATA = 3; 3569 _StreamIteratorImpl._STATE_EXTRA_DATA = 3;
3548 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4; 3570 _StreamIteratorImpl._STATE_EXTRA_ERROR = 4;
3549 _StreamIteratorImpl._STATE_EXTRA_DONE = 5; 3571 _StreamIteratorImpl._STATE_EXTRA_DONE = 5;
3550 return _StreamIteratorImpl; 3572 return _StreamIteratorImpl;
3551 }); 3573 });
3552 let _StreamIteratorImpl = _StreamIteratorImpl$(dart.dynamic); 3574 let _StreamIteratorImpl = _StreamIteratorImpl$(dart.dynamic);
3553 // 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
3955 } 3977 }
3956 addError(error, stackTrace) { 3978 addError(error, stackTrace) {
3957 if (stackTrace === void 0) 3979 if (stackTrace === void 0)
3958 stackTrace = null; 3980 stackTrace = null;
3959 this[_sink]._addError(error, stackTrace); 3981 this[_sink]._addError(error, stackTrace);
3960 } 3982 }
3961 close() { 3983 close() {
3962 this[_sink]._close(); 3984 this[_sink]._close();
3963 } 3985 }
3964 } 3986 }
3987 _EventSinkWrapper[dart.implements] = [EventSink$(T)];
3965 return _EventSinkWrapper; 3988 return _EventSinkWrapper;
3966 }); 3989 });
3967 let _EventSinkWrapper = _EventSinkWrapper$(dart.dynamic); 3990 let _EventSinkWrapper = _EventSinkWrapper$(dart.dynamic);
3968 let _transformerSink = Symbol('_transformerSink'); 3991 let _transformerSink = Symbol('_transformerSink');
3969 let _isSubscribed = Symbol('_isSubscribed'); 3992 let _isSubscribed = Symbol('_isSubscribed');
3970 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) { 3993 let _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) {
3971 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio n$(T) { 3994 class _SinkTransformerStreamSubscription extends _BufferingStreamSubscriptio n$(T) {
3972 _SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone , cancelOnError) { 3995 _SinkTransformerStreamSubscription(source, mapper, onData, onError, onDone , cancelOnError) {
3973 this[_transformerSink] = null; 3996 this[_transformerSink] = null;
3974 this[_subscription] = null; 3997 this[_subscription] = null;
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after
4055 let _sinkMapper = Symbol('_sinkMapper'); 4078 let _sinkMapper = Symbol('_sinkMapper');
4056 let _StreamSinkTransformer$ = dart.generic(function(S, T) { 4079 let _StreamSinkTransformer$ = dart.generic(function(S, T) {
4057 class _StreamSinkTransformer extends core.Object { 4080 class _StreamSinkTransformer extends core.Object {
4058 _StreamSinkTransformer(sinkMapper) { 4081 _StreamSinkTransformer(sinkMapper) {
4059 this[_sinkMapper] = sinkMapper; 4082 this[_sinkMapper] = sinkMapper;
4060 } 4083 }
4061 bind(stream) { 4084 bind(stream) {
4062 return new _BoundSinkStream(stream, this[_sinkMapper]); 4085 return new _BoundSinkStream(stream, this[_sinkMapper]);
4063 } 4086 }
4064 } 4087 }
4088 _StreamSinkTransformer[dart.implements] = [StreamTransformer$(S, T)];
4065 return _StreamSinkTransformer; 4089 return _StreamSinkTransformer;
4066 }); 4090 });
4067 let _StreamSinkTransformer = _StreamSinkTransformer$(dart.dynamic, dart.dynami c); 4091 let _StreamSinkTransformer = _StreamSinkTransformer$(dart.dynamic, dart.dynami c);
4068 let _BoundSinkStream$ = dart.generic(function(S, T) { 4092 let _BoundSinkStream$ = dart.generic(function(S, T) {
4069 class _BoundSinkStream extends Stream$(T) { 4093 class _BoundSinkStream extends Stream$(T) {
4070 get isBroadcast() { 4094 get isBroadcast() {
4071 return this[_stream].isBroadcast; 4095 return this[_stream].isBroadcast;
4072 } 4096 }
4073 _BoundSinkStream(stream$, sinkMapper) { 4097 _BoundSinkStream(stream$, sinkMapper) {
4074 this[_stream] = stream$; 4098 this[_stream] = stream$;
(...skipping 25 matching lines...) Expand all
4100 } 4124 }
4101 addError(error, stackTrace) { 4125 addError(error, stackTrace) {
4102 if (stackTrace === void 0) 4126 if (stackTrace === void 0)
4103 stackTrace = null; 4127 stackTrace = null;
4104 return this[_handleError](error, stackTrace, this[_sink]); 4128 return this[_handleError](error, stackTrace, this[_sink]);
4105 } 4129 }
4106 close() { 4130 close() {
4107 return this[_handleDone](this[_sink]); 4131 return this[_handleDone](this[_sink]);
4108 } 4132 }
4109 } 4133 }
4134 _HandlerEventSink[dart.implements] = [EventSink$(S)];
4110 return _HandlerEventSink; 4135 return _HandlerEventSink;
4111 }); 4136 });
4112 let _HandlerEventSink = _HandlerEventSink$(dart.dynamic, dart.dynamic); 4137 let _HandlerEventSink = _HandlerEventSink$(dart.dynamic, dart.dynamic);
4113 let _defaultHandleData = Symbol('_defaultHandleData'); 4138 let _defaultHandleData = Symbol('_defaultHandleData');
4114 let _defaultHandleError = Symbol('_defaultHandleError'); 4139 let _defaultHandleError = Symbol('_defaultHandleError');
4115 let _defaultHandleDone = Symbol('_defaultHandleDone'); 4140 let _defaultHandleDone = Symbol('_defaultHandleDone');
4116 let _StreamHandlerTransformer$ = dart.generic(function(S, T) { 4141 let _StreamHandlerTransformer$ = dart.generic(function(S, T) {
4117 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) { 4142 class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) {
4118 _StreamHandlerTransformer(opts) { 4143 _StreamHandlerTransformer(opts) {
4119 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
4148 let _transformer = Symbol('_transformer'); 4173 let _transformer = Symbol('_transformer');
4149 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) { 4174 let _StreamSubscriptionTransformer$ = dart.generic(function(S, T) {
4150 class _StreamSubscriptionTransformer extends core.Object { 4175 class _StreamSubscriptionTransformer extends core.Object {
4151 _StreamSubscriptionTransformer(transformer$) { 4176 _StreamSubscriptionTransformer(transformer$) {
4152 this[_transformer] = transformer$; 4177 this[_transformer] = transformer$;
4153 } 4178 }
4154 bind(stream) { 4179 bind(stream) {
4155 return new _BoundSubscriptionStream(stream, this[_transformer]); 4180 return new _BoundSubscriptionStream(stream, this[_transformer]);
4156 } 4181 }
4157 } 4182 }
4183 _StreamSubscriptionTransformer[dart.implements] = [StreamTransformer$(S, T)] ;
4158 return _StreamSubscriptionTransformer; 4184 return _StreamSubscriptionTransformer;
4159 }); 4185 });
4160 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dart.dyna mic, dart.dynamic); 4186 let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$(dart.dyna mic, dart.dynamic);
4161 let _BoundSubscriptionStream$ = dart.generic(function(S, T) { 4187 let _BoundSubscriptionStream$ = dart.generic(function(S, T) {
4162 class _BoundSubscriptionStream extends Stream$(T) { 4188 class _BoundSubscriptionStream extends Stream$(T) {
4163 _BoundSubscriptionStream(stream$, transformer$) { 4189 _BoundSubscriptionStream(stream$, transformer$) {
4164 this[_stream] = stream$; 4190 this[_stream] = stream$;
4165 this[_transformer] = transformer$; 4191 this[_transformer] = transformer$;
4166 super.Stream(); 4192 super.Stream();
4167 } 4193 }
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
4263 this.registerUnaryCallback = registerUnaryCallback; 4289 this.registerUnaryCallback = registerUnaryCallback;
4264 this.registerBinaryCallback = registerBinaryCallback; 4290 this.registerBinaryCallback = registerBinaryCallback;
4265 this.errorCallback = errorCallback; 4291 this.errorCallback = errorCallback;
4266 this.scheduleMicrotask = scheduleMicrotask; 4292 this.scheduleMicrotask = scheduleMicrotask;
4267 this.createTimer = createTimer; 4293 this.createTimer = createTimer;
4268 this.createPeriodicTimer = createPeriodicTimer; 4294 this.createPeriodicTimer = createPeriodicTimer;
4269 this.print = print; 4295 this.print = print;
4270 this.fork = fork; 4296 this.fork = fork;
4271 } 4297 }
4272 } 4298 }
4299 _ZoneSpecification[dart.implements] = [ZoneSpecification];
4273 class ZoneDelegate extends core.Object { 4300 class ZoneDelegate extends core.Object {
4274 } 4301 }
4275 let _$ = Symbol('_'); 4302 let _$ = Symbol('_');
4276 let _enter = Symbol('_enter'); 4303 let _enter = Symbol('_enter');
4277 let _leave = Symbol('_leave'); 4304 let _leave = Symbol('_leave');
4278 class Zone extends core.Object { 4305 class Zone extends core.Object {
4279 [_$]() { 4306 [_$]() {
4280 } 4307 }
4281 static get current() { 4308 static get current() {
4282 return Zone[_current]; 4309 return Zone[_current];
(...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after
4380 let implementation = this[_delegationTarget][_print]; 4407 let implementation = this[_delegationTarget][_print];
4381 let implZone = implementation.zone; 4408 let implZone = implementation.zone;
4382 dart.dinvokef(implementation.function, implZone, _parentDelegate(implZone) , zone, line); 4409 dart.dinvokef(implementation.function, implZone, _parentDelegate(implZone) , zone, line);
4383 } 4410 }
4384 fork(zone, specification, zoneValues) { 4411 fork(zone, specification, zoneValues) {
4385 let implementation = this[_delegationTarget][_fork]; 4412 let implementation = this[_delegationTarget][_fork];
4386 let implZone = implementation.zone; 4413 let implZone = implementation.zone;
4387 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);
4388 } 4415 }
4389 } 4416 }
4417 _ZoneDelegate[dart.implements] = [ZoneDelegate];
4390 class _Zone extends core.Object { 4418 class _Zone extends core.Object {
4391 _Zone() { 4419 _Zone() {
4392 } 4420 }
4393 inSameErrorZone(otherZone) { 4421 inSameErrorZone(otherZone) {
4394 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));
4395 } 4423 }
4396 } 4424 }
4425 _Zone[dart.implements] = [Zone];
4397 let _delegateCache = Symbol('_delegateCache'); 4426 let _delegateCache = Symbol('_delegateCache');
4398 let _map = Symbol('_map'); 4427 let _map = Symbol('_map');
4399 class _CustomZone extends _Zone { 4428 class _CustomZone extends _Zone {
4400 get [_delegate]() { 4429 get [_delegate]() {
4401 if (this[_delegateCache] !== null) 4430 if (this[_delegateCache] !== null)
4402 return this[_delegateCache]; 4431 return this[_delegateCache];
4403 this[_delegateCache] = new _ZoneDelegate(this); 4432 this[_delegateCache] = new _ZoneDelegate(this);
4404 return this[_delegateCache]; 4433 return this[_delegateCache];
4405 } 4434 }
4406 _CustomZone(parent, specification, map) { 4435 _CustomZone(parent, specification, map) {
(...skipping 322 matching lines...) Expand 10 before | Expand all | Expand 10 after
4729 get createPeriodicTimer() { 4758 get createPeriodicTimer() {
4730 return _rootCreatePeriodicTimer; 4759 return _rootCreatePeriodicTimer;
4731 } 4760 }
4732 get print() { 4761 get print() {
4733 return _rootPrint; 4762 return _rootPrint;
4734 } 4763 }
4735 get fork() { 4764 get fork() {
4736 return _rootFork; 4765 return _rootFork;
4737 } 4766 }
4738 } 4767 }
4768 _RootZoneSpecification[dart.implements] = [ZoneSpecification];
4739 let _rootMap = Symbol('_rootMap'); 4769 let _rootMap = Symbol('_rootMap');
4740 let _rootDelegate = Symbol('_rootDelegate'); 4770 let _rootDelegate = Symbol('_rootDelegate');
4741 class _RootZone extends _Zone { 4771 class _RootZone extends _Zone {
4742 _RootZone() { 4772 _RootZone() {
4743 super._Zone(); 4773 super._Zone();
4744 } 4774 }
4745 get [_run]() { 4775 get [_run]() {
4746 return new _ZoneFunction(_ROOT_ZONE, _rootRun); 4776 return new _ZoneFunction(_ROOT_ZONE, _rootRun);
4747 } 4777 }
4748 get [_runUnary]() { 4778 get [_runUnary]() {
(...skipping 233 matching lines...) Expand 10 before | Expand all | Expand 10 after
4982 exports.StreamIterator = StreamIterator; 5012 exports.StreamIterator = StreamIterator;
4983 exports.StreamIterator$ = StreamIterator$; 5013 exports.StreamIterator$ = StreamIterator$;
4984 exports.StreamController = StreamController; 5014 exports.StreamController = StreamController;
4985 exports.StreamController$ = StreamController$; 5015 exports.StreamController$ = StreamController$;
4986 exports.Timer = Timer; 5016 exports.Timer = Timer;
4987 exports.ZoneSpecification = ZoneSpecification; 5017 exports.ZoneSpecification = ZoneSpecification;
4988 exports.ZoneDelegate = ZoneDelegate; 5018 exports.ZoneDelegate = ZoneDelegate;
4989 exports.Zone = Zone; 5019 exports.Zone = Zone;
4990 exports.runZoned = runZoned; 5020 exports.runZoned = runZoned;
4991 })(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