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

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

Issue 1045323002: emit interfaces before use (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 9 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
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 »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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;
« 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