Index: lib/runtime/dart/async.js |
diff --git a/lib/runtime/dart/async.js b/lib/runtime/dart/async.js |
index b12f2e08bc9b54dc0102caf9127290d1a28395f0..5bca86ec64c8b1dda9e14b9e36a51bbf5f5f94a5 100644 |
--- a/lib/runtime/dart/async.js |
+++ b/lib/runtime/dart/async.js |
@@ -62,6 +62,10 @@ dart_library.library('dart/async', null, /* Imports */[ |
names: ['_getBestStackTrace'] |
}); |
const __CastType0 = dart.typedef('__CastType0', () => dart.functionType(dart.dynamic, [dart.dynamic])); |
+ const _controller = Symbol('_controller'); |
+ const _subscribe = Symbol('_subscribe'); |
+ const _createSubscription = Symbol('_createSubscription'); |
+ const _onListen = Symbol('_onListen'); |
const _add = Symbol('_add'); |
const _closeUnchecked = Symbol('_closeUnchecked'); |
const _addError = Symbol('_addError'); |
@@ -754,8 +758,6 @@ dart_library.library('dart/async', null, /* Imports */[ |
return Stream; |
}); |
let Stream = Stream$(); |
- const _createSubscription = Symbol('_createSubscription'); |
- const _onListen = Symbol('_onListen'); |
const _StreamImpl$ = dart.generic(function(T) { |
class _StreamImpl extends Stream$(T) { |
_StreamImpl() { |
@@ -789,8 +791,6 @@ dart_library.library('dart/async', null, /* Imports */[ |
return _StreamImpl; |
}); |
let _StreamImpl = _StreamImpl$(); |
- const _controller = Symbol('_controller'); |
- const _subscribe = Symbol('_subscribe'); |
const _ControllerStream$ = dart.generic(function(T) { |
class _ControllerStream extends _StreamImpl$(T) { |
_ControllerStream(controller) { |
@@ -844,6 +844,18 @@ dart_library.library('dart/async', null, /* Imports */[ |
this[_previous] = null; |
} |
} |
+ const _eventState = Symbol('_eventState'); |
+ const _expectsEvent = Symbol('_expectsEvent'); |
+ const _toggleEventId = Symbol('_toggleEventId'); |
+ const _isFiring = Symbol('_isFiring'); |
+ const _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); |
+ const _removeAfterFiring = Symbol('_removeAfterFiring'); |
+ const _onPause = Symbol('_onPause'); |
+ const _onResume = Symbol('_onResume'); |
+ const _recordCancel = Symbol('_recordCancel'); |
+ const _onCancel = Symbol('_onCancel'); |
+ const _recordPause = Symbol('_recordPause'); |
+ const _recordResume = Symbol('_recordResume'); |
const _zone = Symbol('_zone'); |
const _state = Symbol('_state'); |
const _onData = Symbol('_onData'); |
@@ -858,17 +870,14 @@ dart_library.library('dart/async', null, /* Imports */[ |
const _isInputPaused = Symbol('_isInputPaused'); |
const _inCallback = Symbol('_inCallback'); |
const _guardCallback = Symbol('_guardCallback'); |
- const _onPause = Symbol('_onPause'); |
const _decrementPauseCount = Symbol('_decrementPauseCount'); |
const _hasPending = Symbol('_hasPending'); |
const _mayResumeInput = Symbol('_mayResumeInput'); |
- const _onResume = Symbol('_onResume'); |
const _cancel = Symbol('_cancel'); |
const _isClosed = Symbol('_isClosed'); |
const _waitsForCancel = Symbol('_waitsForCancel'); |
const _canFire = Symbol('_canFire'); |
const _cancelOnError = Symbol('_cancelOnError'); |
- const _onCancel = Symbol('_onCancel'); |
const _incrementPauseCount = Symbol('_incrementPauseCount'); |
const _sendData = Symbol('_sendData'); |
const _addPending = Symbol('_addPending'); |
@@ -1197,9 +1206,6 @@ dart_library.library('dart/async', null, /* Imports */[ |
return _BufferingStreamSubscription; |
}); |
let _BufferingStreamSubscription = _BufferingStreamSubscription$(); |
- const _recordCancel = Symbol('_recordCancel'); |
- const _recordPause = Symbol('_recordPause'); |
- const _recordResume = Symbol('_recordResume'); |
const _ControllerSubscription$ = dart.generic(function(T) { |
class _ControllerSubscription extends _BufferingStreamSubscription$(T) { |
_ControllerSubscription(controller, onData, onError, onDone, cancelOnError) { |
@@ -1222,12 +1228,6 @@ dart_library.library('dart/async', null, /* Imports */[ |
return _ControllerSubscription; |
}); |
let _ControllerSubscription = _ControllerSubscription$(); |
- const _eventState = Symbol('_eventState'); |
- const _expectsEvent = Symbol('_expectsEvent'); |
- const _toggleEventId = Symbol('_toggleEventId'); |
- const _isFiring = Symbol('_isFiring'); |
- const _setRemoveAfterFiring = Symbol('_setRemoveAfterFiring'); |
- const _removeAfterFiring = Symbol('_removeAfterFiring'); |
const _BroadcastSubscription$ = dart.generic(function(T) { |
class _BroadcastSubscription extends _ControllerSubscription$(T) { |
_BroadcastSubscription(controller, onData, onError, onDone, cancelOnError) { |
@@ -3464,6 +3464,7 @@ dart_library.library('dart/async', null, /* Imports */[ |
return _GeneratedStreamImpl; |
}); |
let _GeneratedStreamImpl = _GeneratedStreamImpl$(); |
+ const _iterator = Symbol('_iterator'); |
const _eventScheduled = Symbol('_eventScheduled'); |
class _PendingEvents extends core.Object { |
_PendingEvents() { |
@@ -3504,7 +3505,6 @@ dart_library.library('dart/async', null, /* Imports */[ |
_PendingEvents._STATE_UNSCHEDULED = 0; |
_PendingEvents._STATE_SCHEDULED = 1; |
_PendingEvents._STATE_CANCELED = 3; |
- const _iterator = Symbol('_iterator'); |
const _IterablePendingEvents$ = dart.generic(function(T) { |
class _IterablePendingEvents extends _PendingEvents { |
_IterablePendingEvents(data) { |