hunk.code_window:       source.subscribe(function (x) {
           expect(x).toBe(expected[i++]);
         }, null, done);
         source.connect();
  
hunk.labels: keep replace keep keep keep
hunk.after_edit:         throw 'this should not be called';
  
hunk.file_path: spec/operators/publish-spec.js
hunk.type: replace
file: import Subscription from './Subscription';
  import Action from './schedulers/Action';
  
  interface Scheduler {
    now(): number;
    
    schedule<T>(work: (state?: any) => Subscription<T>|void, delay?: number, state?: any): Subscription<T>;
    
    flush(): void;
    
    actions: Action[];
    
    scheduled: boolean;
    
    active: boolean;
  }
  
  export default Scheduler;