emit interfaces before use

lib/runtime/dart/async.js

 var async;
 (function(exports) {
   'use strict';
   // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic
   function _invokeErrorHandler(errorHandler, error, stackTrace) {
     if (dart.is(errorHandler, ZoneBinaryCallback)) {
       return dart.dinvokef(errorHandler, error, stackTrace);
     } else {
       return dart.dinvokef(errorHandler, error);
     }
@@ skipping 764 matching lines @@
   let _canFire = Symbol('_canFire');
   let _cancelOnError = Symbol('_cancelOnError');
   let _incrementPauseCount = Symbol('_incrementPauseCount');
   let _add = Symbol('_add');
   let _sendData = Symbol('_sendData');
   let _addPending = Symbol('_addPending');
   let _sendError = Symbol('_sendError');
   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) {
         this[_zone] = Zone.current;
         this[_state] = cancelOnError ? _BufferingStreamSubscription[_STATE_CANCEL_ON_ERROR] : 0;
         this[_onData] = null;
         this[_onError] = null;
         this[_onDone] = null;
         this[_cancelFuture] = null;
         this[_pending] = null;
@@ skipping 365 matching lines @@
   let _addListener = Symbol('_addListener');
   let _removeListener = Symbol('_removeListener');
   let _subscribe = Symbol('_subscribe');
   let _recordCancel = Symbol('_recordCancel');
   let _callOnCancel = Symbol('_callOnCancel');
   let _recordPause = Symbol('_recordPause');
   let _recordResume = Symbol('_recordResume');
   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$) {
         this[_onListen] = onListen$;
         this[_onCancel] = onCancel$;
         this[_state] = _BroadcastStreamController[_STATE_INITIAL];
         this[_next] = null;
         this[_previous] = null;
         this[_addStreamState] = null;
         this[_doneFuture] = null;
@@ skipping 1313 matching lines @@
     }
     static [_scheduleImmediateWithTimer](callback) {
       Timer._createTimer(core.Duration.ZERO, callback);
     }
   }
   dart.defineLazyProperties(_AsyncRun, {
     get scheduleImmediateClosure() {
       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) {
       StreamView(stream$) {
         this[_stream] = stream$;
         super.Stream();
       }
       get isBroadcast() {
         return this[_stream].isBroadcast;
       }
       asBroadcastStream(opts) {
         let onListen = opts && 'onListen' in opts ? opts.onListen : null;
         let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null;
         return this[_stream].asBroadcastStream({onListen: onListen, onCancel: onCancel});
       }
       listen(onData, opts) {
         let onError = opts && 'onError' in opts ? opts.onError : null;
         let onDone = opts && 'onDone' in opts ? opts.onDone : null;
         let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError : null;
         return this[_stream].listen(onData, {onError: onError, onDone: onDone, cancelOnError: cancelOnError});
       }
     }
     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) {
         return new _StreamSubscriptionTransformer(transformer);
       }
       fromHandlers(opts) {
         return new _StreamHandlerTransformer(opts);
       }
     }
     dart.defineNamedConstructor(StreamTransformer, 'fromHandlers');
@@ skipping 23 matching lines @@
         this[_sink].addError(error, stackTrace);
       }
       close() {
         this[_sink].close();
       }
     }
     _ControllerEventSinkWrapper[dart.implements] = [EventSink$(T)];
     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');
   let _STATE_SUBSCRIPTION_MASK = Symbol('_STATE_SUBSCRIPTION_MASK');
   let _subscription = Symbol('_subscription');
   let _pendingEvents = Symbol('_pendingEvents');
   let _ensurePendingEvents = Symbol('_ensurePendingEvents');
   let _badEventState = Symbol('_badEventState');
   let _nullFuture = Symbol('_nullFuture');
   let _closeUnchecked = Symbol('_closeUnchecked');
@@ skipping 289 matching lines @@
     get [_onPause]() {
       return null;
     }
     get [_onResume]() {
       return null;
     }
     get [_onCancel]() {
       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)
       return null;
     try {
       let result = notificationHandler();
       if (dart.is(result, Future))
         return dart.as(result, Future);
       return null;
     } catch (e) {
@@ skipping 72 matching lines @@
         this.varData = varData;
         super._AddStreamState(dart.as(controller, _EventSink$(T)), source, cancelOnError);
         if (controller.isPaused) {
           this.addSubscription.pause();
         }
       }
     }
     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) {
       _GeneratedStreamImpl(pending$) {
         this[_pending] = pending$;
         this[_isUsed] = false;
         super._StreamImpl();
       }
       [_createSubscription](onData, onError, onDone, cancelOnError) {
         if (this[_isUsed])
@@ skipping 1230 matching lines @@
       this.registerBinaryCallback = registerBinaryCallback;
       this.errorCallback = errorCallback;
       this.scheduleMicrotask = scheduleMicrotask;
       this.createTimer = createTimer;
       this.createPeriodicTimer = createPeriodicTimer;
       this.print = print;
       this.fork = fork;
     }
   }
   _ZoneSpecification[dart.implements] = [ZoneSpecification];
-  class ZoneDelegate extends core.Object {
-  }
+  class ZoneDelegate extends core.Object {}
   let _$ = Symbol('_');
   let _enter = Symbol('_enter');
   let _leave = Symbol('_leave');
   class Zone extends core.Object {
     [_$]() {
     }
     static get current() {
       return Zone[_current];
     }
     static [_enter](zone) {
@@ skipping 670 matching lines @@
   }
   dart.copyProperties(exports, {
     get _hasDocument() {
       return typeof document == 'object';
     }
   });
   // Exports:
   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;
   exports.Future$ = Future$;
   exports.TimeoutException = TimeoutException;
   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;
   exports.Zone = Zone;
   exports.runZoned = runZoned;
 })(async || (async = {}));