| Index: lib/runtime/dart/async.js
|
| diff --git a/lib/runtime/dart/async.js b/lib/runtime/dart/async.js
|
| index ccc39fa0bbff0d5f7532fc73724efef07bab3544..fb3ed4af7ec9195dc3bcfaceb7378afa94194e13 100644
|
| --- a/lib/runtime/dart/async.js
|
| +++ b/lib/runtime/dart/async.js
|
| @@ -782,6 +782,21 @@ var async;
|
| let _close = Symbol('_close');
|
| let _sendDone = Symbol('_sendDone');
|
| let _checkState = Symbol('_checkState');
|
| + let StreamSubscription$ = dart.generic(function(T) {
|
| + class StreamSubscription extends core.Object {}
|
| + return StreamSubscription;
|
| + });
|
| + let StreamSubscription = StreamSubscription$(dart.dynamic);
|
| + let _EventSink$ = dart.generic(function(T) {
|
| + class _EventSink extends core.Object {}
|
| + return _EventSink;
|
| + });
|
| + let _EventSink = _EventSink$(dart.dynamic);
|
| + let _EventDispatch$ = dart.generic(function(T) {
|
| + class _EventDispatch extends core.Object {}
|
| + return _EventDispatch;
|
| + });
|
| + let _EventDispatch = _EventDispatch$(dart.dynamic);
|
| let _BufferingStreamSubscription$ = dart.generic(function(T) {
|
| class _BufferingStreamSubscription extends core.Object {
|
| _BufferingStreamSubscription(onData, onError, onDone, cancelOnError) {
|
| @@ -1167,6 +1182,59 @@ var async;
|
| let _addEventError = Symbol('_addEventError');
|
| let _forEachListener = Symbol('_forEachListener');
|
| let _mayComplete = Symbol('_mayComplete');
|
| + let StreamConsumer$ = dart.generic(function(S) {
|
| + class StreamConsumer extends core.Object {}
|
| + return StreamConsumer;
|
| + });
|
| + let StreamConsumer = StreamConsumer$(dart.dynamic);
|
| + let EventSink$ = dart.generic(function(T) {
|
| + class EventSink extends core.Object {}
|
| + EventSink[dart.implements] = [core.Sink$(T)];
|
| + return EventSink;
|
| + });
|
| + let EventSink = EventSink$(dart.dynamic);
|
| + let StreamSink$ = dart.generic(function(S) {
|
| + class StreamSink extends core.Object {}
|
| + StreamSink[dart.implements] = [StreamConsumer$(S), EventSink$(S)];
|
| + return StreamSink;
|
| + });
|
| + let StreamSink = StreamSink$(dart.dynamic);
|
| + let StreamController$ = dart.generic(function(T) {
|
| + class StreamController extends core.Object {
|
| + StreamController(opts) {
|
| + let onListen = opts && 'onListen' in opts ? opts.onListen : null;
|
| + let onPause = opts && 'onPause' in opts ? opts.onPause : null;
|
| + let onResume = opts && 'onResume' in opts ? opts.onResume : null;
|
| + let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
|
| + let sync = opts && 'sync' in opts ? opts.sync : false;
|
| + if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && dart.notNull(onResume == null) && dart.notNull(onCancel == null)) {
|
| + return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController(), StreamController$(T));
|
| + }
|
| + return sync ? new _SyncStreamController(onListen, onPause, onResume, onCancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel);
|
| + }
|
| + broadcast(opts) {
|
| + let onListen = opts && 'onListen' in opts ? opts.onListen : null;
|
| + let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
|
| + let sync = opts && 'sync' in opts ? opts.sync : false;
|
| + return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : new _AsyncBroadcastStreamController(onListen, onCancel);
|
| + }
|
| + }
|
| + StreamController[dart.implements] = [StreamSink$(T)];
|
| + dart.defineNamedConstructor(StreamController, 'broadcast');
|
| + return StreamController;
|
| + });
|
| + let StreamController = StreamController$(dart.dynamic);
|
| + let _StreamControllerLifecycle$ = dart.generic(function(T) {
|
| + class _StreamControllerLifecycle extends core.Object {
|
| + [_recordPause](subscription) {}
|
| + [_recordResume](subscription) {}
|
| + [_recordCancel](subscription) {
|
| + return null;
|
| + }
|
| + }
|
| + return _StreamControllerLifecycle;
|
| + });
|
| + let _StreamControllerLifecycle = _StreamControllerLifecycle$(dart.dynamic);
|
| let _BroadcastStreamController$ = dart.generic(function(T) {
|
| class _BroadcastStreamController extends core.Object {
|
| _BroadcastStreamController(onListen$, onCancel$) {
|
| @@ -2500,19 +2568,6 @@ var async;
|
| return _AsyncRun[_initializeScheduleImmediate]();
|
| }
|
| });
|
| - let StreamSubscription$ = dart.generic(function(T) {
|
| - class StreamSubscription extends core.Object {
|
| - }
|
| - return StreamSubscription;
|
| - });
|
| - let StreamSubscription = StreamSubscription$(dart.dynamic);
|
| - let EventSink$ = dart.generic(function(T) {
|
| - class EventSink extends core.Object {
|
| - }
|
| - EventSink[dart.implements] = [core.Sink$(T)];
|
| - return EventSink;
|
| - });
|
| - let EventSink = EventSink$(dart.dynamic);
|
| let _stream = Symbol('_stream');
|
| let StreamView$ = dart.generic(function(T) {
|
| class StreamView extends Stream$(T) {
|
| @@ -2538,19 +2593,6 @@ var async;
|
| return StreamView;
|
| });
|
| let StreamView = StreamView$(dart.dynamic);
|
| - let StreamConsumer$ = dart.generic(function(S) {
|
| - class StreamConsumer extends core.Object {
|
| - }
|
| - return StreamConsumer;
|
| - });
|
| - let StreamConsumer = StreamConsumer$(dart.dynamic);
|
| - let StreamSink$ = dart.generic(function(S) {
|
| - class StreamSink extends core.Object {
|
| - }
|
| - StreamSink[dart.implements] = [StreamConsumer$(S), EventSink$(S)];
|
| - return StreamSink;
|
| - });
|
| - let StreamSink = StreamSink$(dart.dynamic);
|
| let StreamTransformer$ = dart.generic(function(S, T) {
|
| class StreamTransformer extends core.Object {
|
| StreamTransformer(transformer) {
|
| @@ -2594,42 +2636,6 @@ var async;
|
| return _ControllerEventSinkWrapper;
|
| });
|
| let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$(dart.dynamic);
|
| - let StreamController$ = dart.generic(function(T) {
|
| - class StreamController extends core.Object {
|
| - StreamController(opts) {
|
| - let onListen = opts && 'onListen' in opts ? opts.onListen : null;
|
| - let onPause = opts && 'onPause' in opts ? opts.onPause : null;
|
| - let onResume = opts && 'onResume' in opts ? opts.onResume : null;
|
| - let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
|
| - let sync = opts && 'sync' in opts ? opts.sync : false;
|
| - if (dart.notNull(onListen == null) && dart.notNull(onPause == null) && dart.notNull(onResume == null) && dart.notNull(onCancel == null)) {
|
| - return dart.as(sync ? new _NoCallbackSyncStreamController() : new _NoCallbackAsyncStreamController(), StreamController$(T));
|
| - }
|
| - return sync ? new _SyncStreamController(onListen, onPause, onResume, onCancel) : new _AsyncStreamController(onListen, onPause, onResume, onCancel);
|
| - }
|
| - broadcast(opts) {
|
| - let onListen = opts && 'onListen' in opts ? opts.onListen : null;
|
| - let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
|
| - let sync = opts && 'sync' in opts ? opts.sync : false;
|
| - return sync ? new _SyncBroadcastStreamController(onListen, onCancel) : new _AsyncBroadcastStreamController(onListen, onCancel);
|
| - }
|
| - }
|
| - StreamController[dart.implements] = [StreamSink$(T)];
|
| - dart.defineNamedConstructor(StreamController, 'broadcast');
|
| - return StreamController;
|
| - });
|
| - let StreamController = StreamController$(dart.dynamic);
|
| - let _StreamControllerLifecycle$ = dart.generic(function(T) {
|
| - class _StreamControllerLifecycle extends core.Object {
|
| - [_recordPause](subscription) {}
|
| - [_recordResume](subscription) {}
|
| - [_recordCancel](subscription) {
|
| - return null;
|
| - }
|
| - }
|
| - return _StreamControllerLifecycle;
|
| - });
|
| - let _StreamControllerLifecycle = _StreamControllerLifecycle$(dart.dynamic);
|
| let _varData = Symbol('_varData');
|
| let _STATE_SUBSCRIBED = Symbol('_STATE_SUBSCRIBED');
|
| let _isInitialState = Symbol('_isInitialState');
|
| @@ -2939,10 +2945,8 @@ var async;
|
| return null;
|
| }
|
| }
|
| - class _NoCallbackAsyncStreamController extends dart.mixin(_AsyncStreamControllerDispatch, _NoCallbacks) {
|
| - }
|
| - class _NoCallbackSyncStreamController extends dart.mixin(_SyncStreamControllerDispatch, _NoCallbacks) {
|
| - }
|
| + class _NoCallbackAsyncStreamController extends dart.mixin(_AsyncStreamControllerDispatch, _NoCallbacks) {}
|
| + class _NoCallbackSyncStreamController extends dart.mixin(_SyncStreamControllerDispatch, _NoCallbacks) {}
|
| // Function _runGuarded: (() → dynamic) → Future<dynamic>
|
| function _runGuarded(notificationHandler) {
|
| if (notificationHandler == null)
|
| @@ -3035,18 +3039,6 @@ var async;
|
| return _StreamControllerAddStreamState;
|
| });
|
| let _StreamControllerAddStreamState = _StreamControllerAddStreamState$(dart.dynamic);
|
| - let _EventSink$ = dart.generic(function(T) {
|
| - class _EventSink extends core.Object {
|
| - }
|
| - return _EventSink;
|
| - });
|
| - let _EventSink = _EventSink$(dart.dynamic);
|
| - let _EventDispatch$ = dart.generic(function(T) {
|
| - class _EventDispatch extends core.Object {
|
| - }
|
| - return _EventDispatch;
|
| - });
|
| - let _EventDispatch = _EventDispatch$(dart.dynamic);
|
| let _isUsed = Symbol('_isUsed');
|
| let _GeneratedStreamImpl$ = dart.generic(function(T) {
|
| class _GeneratedStreamImpl extends _StreamImpl$(T) {
|
| @@ -4297,8 +4289,7 @@ var async;
|
| }
|
| }
|
| _ZoneSpecification[dart.implements] = [ZoneSpecification];
|
| - class ZoneDelegate extends core.Object {
|
| - }
|
| + class ZoneDelegate extends core.Object {}
|
| let _$ = Symbol('_');
|
| let _enter = Symbol('_enter');
|
| let _leave = Symbol('_leave');
|
| @@ -4989,6 +4980,16 @@ var async;
|
| exports.AsyncError = AsyncError;
|
| exports.Stream = Stream;
|
| exports.Stream$ = Stream$;
|
| + exports.StreamSubscription = StreamSubscription;
|
| + exports.StreamSubscription$ = StreamSubscription$;
|
| + exports.StreamController = StreamController;
|
| + exports.StreamController$ = StreamController$;
|
| + exports.StreamSink = StreamSink;
|
| + exports.StreamSink$ = StreamSink$;
|
| + exports.StreamConsumer = StreamConsumer;
|
| + exports.StreamConsumer$ = StreamConsumer$;
|
| + exports.EventSink = EventSink;
|
| + exports.EventSink$ = EventSink$;
|
| exports.DeferredLibrary = DeferredLibrary;
|
| exports.DeferredLoadException = DeferredLoadException;
|
| exports.Future = Future;
|
| @@ -4997,22 +4998,12 @@ var async;
|
| exports.Completer = Completer;
|
| exports.Completer$ = Completer$;
|
| exports.scheduleMicrotask = scheduleMicrotask;
|
| - exports.StreamSubscription = StreamSubscription;
|
| - exports.StreamSubscription$ = StreamSubscription$;
|
| - exports.EventSink = EventSink;
|
| - exports.EventSink$ = EventSink$;
|
| exports.StreamView = StreamView;
|
| exports.StreamView$ = StreamView$;
|
| - exports.StreamConsumer = StreamConsumer;
|
| - exports.StreamConsumer$ = StreamConsumer$;
|
| - exports.StreamSink = StreamSink;
|
| - exports.StreamSink$ = StreamSink$;
|
| exports.StreamTransformer = StreamTransformer;
|
| exports.StreamTransformer$ = StreamTransformer$;
|
| exports.StreamIterator = StreamIterator;
|
| exports.StreamIterator$ = StreamIterator$;
|
| - exports.StreamController = StreamController;
|
| - exports.StreamController$ = StreamController$;
|
| exports.Timer = Timer;
|
| exports.ZoneSpecification = ZoneSpecification;
|
| exports.ZoneDelegate = ZoneDelegate;
|
|
|