lib/runtime/dart/async.js - Issue 1633003002: Add --modules=node support

Unified Diff: lib/runtime/dart/async.js

Issue 1633003002: Add --modules=node support (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master

Patch Set: regen sdk and expectations Created 4 years, 11 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 side-by-side diff with in-line comments

Index: lib/runtime/dart/async.js

diff --git a/lib/runtime/dart/async.js b/lib/runtime/dart/async.js

index dc746afdc18f53514d44595bca094bf3bcd92fb0..2d4a7ea526bd727b05c5302d7d5b8be928f4a014 100644

--- a/lib/runtime/dart/async.js

+++ b/lib/runtime/dart/async.js

@@ -757,7 +757,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return Stream;

});

- let Stream = Stream$();

+ const Stream = Stream$();

const _createSubscription = Symbol('_createSubscription');

const _onListen = Symbol('_onListen');

const _StreamImpl$ = dart.generic(function(T) {

@@ -792,7 +792,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamImpl;

});

- let _StreamImpl = _StreamImpl$();

+ const _StreamImpl = _StreamImpl$();

const _controller = Symbol('_controller');

const _subscribe = Symbol('_subscribe');

const _ControllerStream$ = dart.generic(function(T) {

@@ -824,7 +824,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _ControllerStream;

});

- let _ControllerStream = _ControllerStream$();

+ const _ControllerStream = _ControllerStream$();

const _BroadcastStream$ = dart.generic(function(T) {

class _BroadcastStream extends _ControllerStream$(T) {

_BroadcastStream(controller) {

@@ -839,7 +839,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _BroadcastStream;

});

- let _BroadcastStream = _BroadcastStream$();

+ const _BroadcastStream = _BroadcastStream$();

const _next = Symbol('_next');

const _previous = Symbol('_previous');

class _BroadcastSubscriptionLink extends core.Object {

@@ -1191,7 +1191,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _BufferingStreamSubscription;

});

- let _BufferingStreamSubscription = _BufferingStreamSubscription$();

+ const _BufferingStreamSubscription = _BufferingStreamSubscription$();

const _recordCancel = Symbol('_recordCancel');

const _recordPause = Symbol('_recordPause');

const _recordResume = Symbol('_recordResume');

@@ -1216,7 +1216,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _ControllerSubscription;

});

- let _ControllerSubscription = _ControllerSubscription$();

+ const _ControllerSubscription = _ControllerSubscription$();

const _eventState = Symbol('_eventState');

const _expectsEvent = Symbol('_expectsEvent');

const _toggleEventId = Symbol('_toggleEventId');

@@ -1262,7 +1262,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _BroadcastSubscription;

});

- let _BroadcastSubscription = _BroadcastSubscription$();

+ const _BroadcastSubscription = _BroadcastSubscription$();

_BroadcastSubscription._STATE_EVENT_ID = 1;

_BroadcastSubscription._STATE_FIRING = 2;

_BroadcastSubscription._STATE_REMOVE_AFTER_FIRING = 4;

@@ -1503,7 +1503,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _BroadcastStreamController;

});

- let _BroadcastStreamController = _BroadcastStreamController$();

+ const _BroadcastStreamController = _BroadcastStreamController$();

_BroadcastStreamController._STATE_INITIAL = 0;

_BroadcastStreamController._STATE_EVENT_ID = 1;

_BroadcastStreamController._STATE_FIRING = 2;

@@ -1562,7 +1562,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _SyncBroadcastStreamController;

});

- let _SyncBroadcastStreamController = _SyncBroadcastStreamController$();

+ const _SyncBroadcastStreamController = _SyncBroadcastStreamController$();

const _AsyncBroadcastStreamController$ = dart.generic(function(T) {

class _AsyncBroadcastStreamController extends _BroadcastStreamController$(T) {

_AsyncBroadcastStreamController(onListen, onCancel) {

@@ -1604,7 +1604,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _AsyncBroadcastStreamController;

});

- let _AsyncBroadcastStreamController = _AsyncBroadcastStreamController$();

+ const _AsyncBroadcastStreamController = _AsyncBroadcastStreamController$();

const _addPendingEvent = Symbol('_addPendingEvent');

const _AsBroadcastStreamController$ = dart.generic(function(T) {

class _AsBroadcastStreamController extends _SyncBroadcastStreamController$(T) {

@@ -1672,7 +1672,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _AsBroadcastStreamController;

});

- let _AsBroadcastStreamController = _AsBroadcastStreamController$();

+ const _AsBroadcastStreamController = _AsBroadcastStreamController$();

const _pauseCount = Symbol('_pauseCount');

const _resume = Symbol('_resume');

const _DoneSubscription$ = dart.generic(function(T) {

@@ -1726,12 +1726,12 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _DoneSubscription;

});

- let _DoneSubscription = _DoneSubscription$();

+ const _DoneSubscription = _DoneSubscription$();

const __CastType2$ = dart.generic(function(T) {

const __CastType2 = dart.typedef('__CastType2', () => dart.functionType(dart.void, [_BufferingStreamSubscription$(T)]));

return __CastType2;

});

- let __CastType2 = __CastType2$();

+ const __CastType2 = __CastType2$();

class DeferredLibrary extends core.Object {

DeferredLibrary(libraryName, opts) {

let uri = opts && 'uri' in opts ? opts.uri : null;

@@ -1931,7 +1931,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return Future;

});

- let Future = Future$();

+ const Future = Future$();

dart.defineLazyProperties(Future, {

get _nullFuture() {

return new _Future.immediate(null);

@@ -1971,7 +1971,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return Completer;

});

- let Completer = Completer$();

+ const Completer = Completer$();

function _completeWithErrorCallback(result, error, stackTrace) {

let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core.StackTrace));

if (replacement != null) {

@@ -1990,7 +1990,7 @@ dart_library.library('dart/async', null, /* Imports */[

const _FutureOnValue = dart.typedef('_FutureOnValue', () => dart.functionType(dart.dynamic, [T]));

return _FutureOnValue;

});

- let _FutureOnValue = _FutureOnValue$();

+ const _FutureOnValue = _FutureOnValue$();

const _FutureErrorTest = dart.typedef('_FutureErrorTest', () => dart.functionType(core.bool, [dart.dynamic]));

const _FutureAction = dart.typedef('_FutureAction', () => dart.functionType(dart.dynamic, []));

const _Completer$ = dart.generic(function(T) {

@@ -2019,7 +2019,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _Completer;

});

- let _Completer = _Completer$();

+ const _Completer = _Completer$();

const _asyncCompleteError = Symbol('_asyncCompleteError');

const _AsyncCompleter$ = dart.generic(function(T) {

class _AsyncCompleter extends _Completer$(T) {

@@ -2043,7 +2043,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _AsyncCompleter;

});

- let _AsyncCompleter = _AsyncCompleter$();

+ const _AsyncCompleter = _AsyncCompleter$();

const _SyncCompleter$ = dart.generic(function(T) {

class _SyncCompleter extends _Completer$(T) {

_SyncCompleter() {

@@ -2066,7 +2066,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _SyncCompleter;

});

- let _SyncCompleter = _SyncCompleter$();

+ const _SyncCompleter = _SyncCompleter$();

const _nextListener = Symbol('_nextListener');

const _onValue = Symbol('_onValue');

const _errorTest = Symbol('_errorTest');

@@ -2610,7 +2610,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _Future;

});

- let _Future = _Future$();

+ const _Future = _Future$();

_Future._INCOMPLETE = 0;

_Future._PENDING_COMPLETE = 1;

_Future._CHAINED = 2;

@@ -2620,7 +2620,7 @@ dart_library.library('dart/async', null, /* Imports */[

const __CastType6 = dart.typedef('__CastType6', () => dart.functionType(S, [T]));

return __CastType6;

});

- let __CastType6 = __CastType6$();

+ const __CastType6 = __CastType6$();

const __CastType8 = dart.typedef('__CastType8', () => dart.functionType(core.bool, [dart.dynamic]));

const __CastType10 = dart.typedef('__CastType10', () => dart.functionType(dart.dynamic, [dart.dynamic]));

const _AsyncCallback = dart.typedef('_AsyncCallback', () => dart.functionType(dart.void, []));

@@ -2773,13 +2773,13 @@ dart_library.library('dart/async', null, /* Imports */[

class StreamSubscription extends core.Object {}

return StreamSubscription;

});

- let StreamSubscription = StreamSubscription$();

+ const StreamSubscription = StreamSubscription$();

const EventSink$ = dart.generic(function(T) {

class EventSink extends core.Object {}

EventSink[dart.implements] = () => [core.Sink$(T)];

return EventSink;

});

- let EventSink = EventSink$();

+ const EventSink = EventSink$();

const _stream = Symbol('_stream');

const StreamView$ = dart.generic(function(T) {

class StreamView extends Stream$(T) {

@@ -2815,18 +2815,18 @@ dart_library.library('dart/async', null, /* Imports */[

});

return StreamView;

});

- let StreamView = StreamView$();

+ const StreamView = StreamView$();

const StreamConsumer$ = dart.generic(function(S) {

class StreamConsumer extends core.Object {}

return StreamConsumer;

});

- let StreamConsumer = StreamConsumer$();

+ const StreamConsumer = StreamConsumer$();

const StreamSink$ = dart.generic(function(S) {

class StreamSink extends core.Object {}

StreamSink[dart.implements] = () => [StreamConsumer$(S), EventSink$(S)];

return StreamSink;

});

- let StreamSink = StreamSink$();

+ const StreamSink = StreamSink$();

const StreamTransformer$ = dart.generic(function(S, T) {

class StreamTransformer extends core.Object {

static new(transformer) {

@@ -2844,7 +2844,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return StreamTransformer;

});

- let StreamTransformer = StreamTransformer$();

+ const StreamTransformer = StreamTransformer$();

const StreamIterator$ = dart.generic(function(T) {

class StreamIterator extends core.Object {

static new(stream) {

@@ -2856,7 +2856,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return StreamIterator;

});

- let StreamIterator = StreamIterator$();

+ const StreamIterator = StreamIterator$();

const _ControllerEventSinkWrapper$ = dart.generic(function(T) {

class _ControllerEventSinkWrapper extends core.Object {

_ControllerEventSinkWrapper(sink) {

@@ -2885,7 +2885,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _ControllerEventSinkWrapper;

});

- let _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$();

+ const _ControllerEventSinkWrapper = _ControllerEventSinkWrapper$();

const __CastType12 = dart.typedef('__CastType12', () => dart.functionType(dart.void, [StreamSubscription]));

const __CastType14 = dart.typedef('__CastType14', () => dart.functionType(dart.dynamic, [dart.dynamic, core.StackTrace]));

const __CastType17 = dart.typedef('__CastType17', () => dart.functionType(dart.void, []));

@@ -2919,7 +2919,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return StreamController;

});

- let StreamController = StreamController$();

+ const StreamController = StreamController$();

const _StreamControllerLifecycle$ = dart.generic(function(T) {

class _StreamControllerLifecycle extends core.Object {

[_recordPause](subscription) {

@@ -2942,7 +2942,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamControllerLifecycle;

});

- let _StreamControllerLifecycle = _StreamControllerLifecycle$();

+ const _StreamControllerLifecycle = _StreamControllerLifecycle$();

const _varData = Symbol('_varData');

const _isInitialState = Symbol('_isInitialState');

const _subscription = Symbol('_subscription');

@@ -3187,7 +3187,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamController;

});

- let _StreamController = _StreamController$();

+ const _StreamController = _StreamController$();

_StreamController._STATE_INITIAL = 0;

_StreamController._STATE_SUBSCRIBED = 1;

_StreamController._STATE_CANCELED = 2;

@@ -3217,7 +3217,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _SyncStreamControllerDispatch;

});

- let _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$();

+ const _SyncStreamControllerDispatch = _SyncStreamControllerDispatch$();

const _AsyncStreamControllerDispatch$ = dart.generic(function(T) {

class _AsyncStreamControllerDispatch extends core.Object {

[_sendData](data) {

@@ -3241,7 +3241,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _AsyncStreamControllerDispatch;

});

- let _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$();

+ const _AsyncStreamControllerDispatch = _AsyncStreamControllerDispatch$();

const _AsyncStreamController$ = dart.generic(function(T) {

class _AsyncStreamController extends dart.mixin(_StreamController$(T), _AsyncStreamControllerDispatch$(T)) {

_AsyncStreamController(onListen, onPause, onResume, onCancel) {

@@ -3257,7 +3257,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _AsyncStreamController;

});

- let _AsyncStreamController = _AsyncStreamController$();

+ const _AsyncStreamController = _AsyncStreamController$();

const _SyncStreamController$ = dart.generic(function(T) {

class _SyncStreamController extends dart.mixin(_StreamController$(T), _SyncStreamControllerDispatch$(T)) {

_SyncStreamController(onListen, onPause, onResume, onCancel) {

@@ -3273,7 +3273,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _SyncStreamController;

});

- let _SyncStreamController = _SyncStreamController$();

+ const _SyncStreamController = _SyncStreamController$();

class _NoCallbacks extends core.Object {

get [_onListen]() {

return null;

@@ -3296,7 +3296,7 @@ dart_library.library('dart/async', null, /* Imports */[

}

return _NoCallbackAsyncStreamController;

});

- let _NoCallbackAsyncStreamController = _NoCallbackAsyncStreamController$();

+ const _NoCallbackAsyncStreamController = _NoCallbackAsyncStreamController$();

const _NoCallbackSyncStreamController$ = dart.generic(function(T) {

class _NoCallbackSyncStreamController extends dart.mixin(_StreamController$(T), _SyncStreamControllerDispatch$(T), _NoCallbacks) {

_NoCallbackSyncStreamController() {

@@ -3305,7 +3305,7 @@ dart_library.library('dart/async', null, /* Imports */[

}

return _NoCallbackSyncStreamController;

});

- let _NoCallbackSyncStreamController = _NoCallbackSyncStreamController$();

+ const _NoCallbackSyncStreamController = _NoCallbackSyncStreamController$();

const _NotificationHandler = dart.typedef('_NotificationHandler', () => dart.functionType(dart.dynamic, []));

function _runGuarded(notificationHandler) {

if (notificationHandler == null) return null;

@@ -3358,7 +3358,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamSinkWrapper;

});

- let _StreamSinkWrapper = _StreamSinkWrapper$();

+ const _StreamSinkWrapper = _StreamSinkWrapper$();

const _AddStreamState$ = dart.generic(function(T) {

class _AddStreamState extends core.Object {

_AddStreamState(controller, source, cancelOnError) {

@@ -3404,7 +3404,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _AddStreamState;

});

- let _AddStreamState = _AddStreamState$();

+ const _AddStreamState = _AddStreamState$();

const _StreamControllerAddStreamState$ = dart.generic(function(T) {

class _StreamControllerAddStreamState extends _AddStreamState$(T) {

_StreamControllerAddStreamState(controller, varData, source, cancelOnError) {

@@ -3420,17 +3420,17 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamControllerAddStreamState;

});

- let _StreamControllerAddStreamState = _StreamControllerAddStreamState$();

+ const _StreamControllerAddStreamState = _StreamControllerAddStreamState$();

const _EventSink$ = dart.generic(function(T) {

class _EventSink extends core.Object {}

return _EventSink;

});

- let _EventSink = _EventSink$();

+ const _EventSink = _EventSink$();

const _EventDispatch$ = dart.generic(function(T) {

class _EventDispatch extends core.Object {}

return _EventDispatch;

});

- let _EventDispatch = _EventDispatch$();

+ const _EventDispatch = _EventDispatch$();

_BufferingStreamSubscription._STATE_CANCEL_ON_ERROR = 1;

_BufferingStreamSubscription._STATE_CLOSED = 2;

_BufferingStreamSubscription._STATE_INPUT_PAUSED = 4;

@@ -3464,7 +3464,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _GeneratedStreamImpl;

});

- let _GeneratedStreamImpl = _GeneratedStreamImpl$();

+ const _GeneratedStreamImpl = _GeneratedStreamImpl$();

const _eventScheduled = Symbol('_eventScheduled');

class _PendingEvents extends core.Object {

_PendingEvents() {

@@ -3547,12 +3547,12 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _IterablePendingEvents;

});

- let _IterablePendingEvents = _IterablePendingEvents$();

+ const _IterablePendingEvents = _IterablePendingEvents$();

const _DataHandler$ = dart.generic(function(T) {

const _DataHandler = dart.typedef('_DataHandler', () => dart.functionType(dart.void, [T]));

return _DataHandler;

});

- let _DataHandler = _DataHandler$();

+ const _DataHandler = _DataHandler$();

const _DoneHandler = dart.typedef('_DoneHandler', () => dart.functionType(dart.void, []));

function _nullDataHandler(value) {

}

@@ -3573,7 +3573,7 @@ dart_library.library('dart/async', null, /* Imports */[

}

return _DelayedEvent;

});

- let _DelayedEvent = _DelayedEvent$();

+ const _DelayedEvent = _DelayedEvent$();

const _DelayedData$ = dart.generic(function(T) {

class _DelayedData extends _DelayedEvent$(T) {

_DelayedData(value) {

@@ -3591,7 +3591,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _DelayedData;

});

- let _DelayedData = _DelayedData$();

+ const _DelayedData = _DelayedData$();

class _DelayedError extends _DelayedEvent {

_DelayedError(error, stackTrace) {

this.error = error;

@@ -3772,7 +3772,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _DoneStreamSubscription;

});

- let _DoneStreamSubscription = _DoneStreamSubscription$();

+ const _DoneStreamSubscription = _DoneStreamSubscription$();

_DoneStreamSubscription._DONE_SENT = 1;

_DoneStreamSubscription._SCHEDULED = 2;

_DoneStreamSubscription._PAUSED = 4;

@@ -3863,7 +3863,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _AsBroadcastStream;

});

- let _AsBroadcastStream = _AsBroadcastStream$();

+ const _AsBroadcastStream = _AsBroadcastStream$();

const _BroadcastSubscriptionWrapper$ = dart.generic(function(T) {

class _BroadcastSubscriptionWrapper extends core.Object {

_BroadcastSubscriptionWrapper(stream) {

@@ -3914,7 +3914,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _BroadcastSubscriptionWrapper;

});

- let _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$();

+ const _BroadcastSubscriptionWrapper = _BroadcastSubscriptionWrapper$();

const _current = Symbol('_current');

const _futureOrPrefetch = Symbol('_futureOrPrefetch');

const _clear = Symbol('_clear');

@@ -4039,7 +4039,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamIteratorImpl;

});

- let _StreamIteratorImpl = _StreamIteratorImpl$();

+ const _StreamIteratorImpl = _StreamIteratorImpl$();

_StreamIteratorImpl._STATE_FOUND = 0;

_StreamIteratorImpl._STATE_DONE = 1;

_StreamIteratorImpl._STATE_MOVING = 2;

@@ -4050,7 +4050,7 @@ dart_library.library('dart/async', null, /* Imports */[

const __CastType20 = dart.typedef('__CastType20', () => dart.functionType(dart.void, [T]));

return __CastType20;

});

- let __CastType20 = __CastType20$();

+ const __CastType20 = __CastType20$();

const __CastType22 = dart.typedef('__CastType22', () => dart.functionType(dart.dynamic, [dart.dynamic, dart.dynamic]));

const __CastType25 = dart.typedef('__CastType25', () => dart.functionType(dart.dynamic, [dart.dynamic]));

function _runUserCode(userCode, onSuccess, onError) {

@@ -4154,7 +4154,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _ForwardingStream;

});

- let _ForwardingStream = _ForwardingStream$();

+ const _ForwardingStream = _ForwardingStream$();

const _ForwardingStreamSubscription$ = dart.generic(function(S, T) {

class _ForwardingStreamSubscription extends _BufferingStreamSubscription$(T) {

_ForwardingStreamSubscription(stream, onData, onError, onDone, cancelOnError) {

@@ -4210,12 +4210,12 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _ForwardingStreamSubscription;

});

- let _ForwardingStreamSubscription = _ForwardingStreamSubscription$();

+ const _ForwardingStreamSubscription = _ForwardingStreamSubscription$();

const _Predicate$ = dart.generic(function(T) {

const _Predicate = dart.typedef('_Predicate', () => dart.functionType(core.bool, [T]));

return _Predicate;

});

- let _Predicate = _Predicate$();

+ const _Predicate = _Predicate$();

function _addErrorWithReplacement(sink, error, stackTrace) {

let replacement = Zone.current.errorCallback(error, dart.as(stackTrace, core.StackTrace));

if (replacement != null) {

@@ -4255,12 +4255,12 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _WhereStream;

});

- let _WhereStream = _WhereStream$();

+ const _WhereStream = _WhereStream$();

const _Transformation$ = dart.generic(function(S, T) {

const _Transformation = dart.typedef('_Transformation', () => dart.functionType(T, [S]));

return _Transformation;

});

- let _Transformation = _Transformation$();

+ const _Transformation = _Transformation$();

const _transform = Symbol('_transform');

const _MapStream$ = dart.generic(function(S, T) {

class _MapStream extends _ForwardingStream$(S, T) {

@@ -4289,7 +4289,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _MapStream;

});

- let _MapStream = _MapStream$();

+ const _MapStream = _MapStream$();

const _expand = Symbol('_expand');

const _ExpandStream$ = dart.generic(function(S, T) {

class _ExpandStream extends _ForwardingStream$(S, T) {

@@ -4317,7 +4317,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _ExpandStream;

});

- let _ExpandStream = _ExpandStream$();

+ const _ExpandStream = _ExpandStream$();

const _ErrorTest = dart.typedef('_ErrorTest', () => dart.functionType(core.bool, [dart.dynamic]));

const _HandleErrorStream$ = dart.generic(function(T) {

class _HandleErrorStream extends _ForwardingStream$(T, T) {

@@ -4363,7 +4363,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _HandleErrorStream;

});

- let _HandleErrorStream = _HandleErrorStream$();

+ const _HandleErrorStream = _HandleErrorStream$();

const _remaining = Symbol('_remaining');

const _TakeStream$ = dart.generic(function(T) {

class _TakeStream extends _ForwardingStream$(T, T) {

@@ -4390,7 +4390,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _TakeStream;

});

- let _TakeStream = _TakeStream$();

+ const _TakeStream = _TakeStream$();

const _TakeWhileStream$ = dart.generic(function(T) {

class _TakeWhileStream extends _ForwardingStream$(T, T) {

_TakeWhileStream(source, test) {

@@ -4423,7 +4423,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _TakeWhileStream;

});

- let _TakeWhileStream = _TakeWhileStream$();

+ const _TakeWhileStream = _TakeWhileStream$();

const _SkipStream$ = dart.generic(function(T) {

class _SkipStream extends _ForwardingStream$(T, T) {

_SkipStream(source, count) {

@@ -4447,7 +4447,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _SkipStream;

});

- let _SkipStream = _SkipStream$();

+ const _SkipStream = _SkipStream$();

const _hasFailed = Symbol('_hasFailed');

const _SkipWhileStream$ = dart.generic(function(T) {

class _SkipWhileStream extends _ForwardingStream$(T, T) {

@@ -4485,12 +4485,12 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _SkipWhileStream;

});

- let _SkipWhileStream = _SkipWhileStream$();

+ const _SkipWhileStream = _SkipWhileStream$();

const _Equality$ = dart.generic(function(T) {

const _Equality = dart.typedef('_Equality', () => dart.functionType(core.bool, [T, T]));

return _Equality;

});

- let _Equality = _Equality$();

+ const _Equality = _Equality$();

const _equals = Symbol('_equals');

const _DistinctStream$ = dart.generic(function(T) {

class _DistinctStream extends _ForwardingStream$(T, T) {

@@ -4532,7 +4532,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _DistinctStream;

});

- let _DistinctStream = _DistinctStream$();

+ const _DistinctStream = _DistinctStream$();

dart.defineLazyProperties(_DistinctStream, {

get _SENTINEL() {

return new core.Object();

@@ -4567,7 +4567,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _EventSinkWrapper;

});

- let _EventSinkWrapper = _EventSinkWrapper$();

+ const _EventSinkWrapper = _EventSinkWrapper$();

const _transformerSink = Symbol('_transformerSink');

const _isSubscribed = Symbol('_isSubscribed');

const _SinkTransformerStreamSubscription$ = dart.generic(function(S, T) {

@@ -4662,12 +4662,12 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _SinkTransformerStreamSubscription;

});

- let _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$();

+ const _SinkTransformerStreamSubscription = _SinkTransformerStreamSubscription$();

const _SinkMapper$ = dart.generic(function(S, T) {

const _SinkMapper = dart.typedef('_SinkMapper', () => dart.functionType(EventSink$(S), [EventSink$(T)]));

return _SinkMapper;

});

- let _SinkMapper = _SinkMapper$();

+ const _SinkMapper = _SinkMapper$();

const _sinkMapper = Symbol('_sinkMapper');

const _StreamSinkTransformer$ = dart.generic(function(S, T) {

class _StreamSinkTransformer extends core.Object {

@@ -4686,7 +4686,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamSinkTransformer;

});

- let _StreamSinkTransformer = _StreamSinkTransformer$();

+ const _StreamSinkTransformer = _StreamSinkTransformer$();

const _BoundSinkStream$ = dart.generic(function(S, T) {

class _BoundSinkStream extends Stream$(T) {

get isBroadcast() {

@@ -4714,22 +4714,22 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _BoundSinkStream;

});

- let _BoundSinkStream = _BoundSinkStream$();

+ const _BoundSinkStream = _BoundSinkStream$();

const _TransformDataHandler$ = dart.generic(function(S, T) {

const _TransformDataHandler = dart.typedef('_TransformDataHandler', () => dart.functionType(dart.void, [S, EventSink$(T)]));

return _TransformDataHandler;

});

- let _TransformDataHandler = _TransformDataHandler$();

+ const _TransformDataHandler = _TransformDataHandler$();

const _TransformErrorHandler$ = dart.generic(function(T) {

const _TransformErrorHandler = dart.typedef('_TransformErrorHandler', () => dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)]));

return _TransformErrorHandler;

});

- let _TransformErrorHandler = _TransformErrorHandler$();

+ const _TransformErrorHandler = _TransformErrorHandler$();

const _TransformDoneHandler$ = dart.generic(function(T) {

const _TransformDoneHandler = dart.typedef('_TransformDoneHandler', () => dart.functionType(dart.void, [EventSink$(T)]));

return _TransformDoneHandler;

});

- let _TransformDoneHandler = _TransformDoneHandler$();

+ const _TransformDoneHandler = _TransformDoneHandler$();

const _HandlerEventSink$ = dart.generic(function(S, T) {

class _HandlerEventSink extends core.Object {

_HandlerEventSink(handleData, handleError, handleDone, sink) {

@@ -4761,7 +4761,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _HandlerEventSink;

});

- let _HandlerEventSink = _HandlerEventSink$();

+ const _HandlerEventSink = _HandlerEventSink$();

const _StreamHandlerTransformer$ = dart.generic(function(S, T) {

class _StreamHandlerTransformer extends _StreamSinkTransformer$(S, T) {

_StreamHandlerTransformer(opts) {

@@ -4802,12 +4802,12 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamHandlerTransformer;

});

- let _StreamHandlerTransformer = _StreamHandlerTransformer$();

+ const _StreamHandlerTransformer = _StreamHandlerTransformer$();

const _SubscriptionTransformer$ = dart.generic(function(S, T) {

const _SubscriptionTransformer = dart.typedef('_SubscriptionTransformer', () => dart.functionType(StreamSubscription$(T), [Stream$(S), core.bool]));

return _SubscriptionTransformer;

});

- let _SubscriptionTransformer = _SubscriptionTransformer$();

+ const _SubscriptionTransformer = _SubscriptionTransformer$();

const _transformer = Symbol('_transformer');

const _StreamSubscriptionTransformer$ = dart.generic(function(S, T) {

class _StreamSubscriptionTransformer extends core.Object {

@@ -4826,7 +4826,7 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _StreamSubscriptionTransformer;

});

- let _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$();

+ const _StreamSubscriptionTransformer = _StreamSubscriptionTransformer$();

const _BoundSubscriptionStream$ = dart.generic(function(S, T) {

class _BoundSubscriptionStream extends Stream$(T) {

_BoundSubscriptionStream(stream, transformer) {

@@ -4854,17 +4854,17 @@ dart_library.library('dart/async', null, /* Imports */[

});

return _BoundSubscriptionStream;

});

- let _BoundSubscriptionStream = _BoundSubscriptionStream$();

+ const _BoundSubscriptionStream = _BoundSubscriptionStream$();

const __CastType27$ = dart.generic(function(S, T) {

const __CastType27 = dart.typedef('__CastType27', () => dart.functionType(dart.void, [S, EventSink$(T)]));

return __CastType27;

});

- let __CastType27 = __CastType27$();

+ const __CastType27 = __CastType27$();

const __CastType30$ = dart.generic(function(T) {

const __CastType30 = dart.typedef('__CastType30', () => dart.functionType(dart.void, [core.Object, core.StackTrace, EventSink$(T)]));

return __CastType30;

});

- let __CastType30 = __CastType30$();

+ const __CastType30 = __CastType30$();

class Timer extends core.Object {

static new(duration, callback) {

if (dart.equals(Zone.current, Zone.ROOT)) {

« no previous file with comments | « lib/runtime/dart/_runtime.js ('k') | lib/runtime/dart/collection.js » ('j') | lib/src/codegen/module_builder.dart » ('J')