hunk.code_window:   }
     const { count, resetOnSuccess = false } = config;
     return count <= 0
       ? () => EMPTY
       : operate((source, subscriber) => {
           let soFar = 0;
           let innerSub: Subscription | null;
           const subscribeForRetry = () => {
  
hunk.labels: keep keep keep keep replace keep keep keep keep
hunk.after_edit:     ? identity
  
hunk.file_path: src/internal/operators/retry.ts
hunk.type: replace
file: import { of, asyncScheduler } from 'rxjs';
  import { debounceTime } from 'rxjs/operators';
  
  it('should infer correctly', () => {
    const o = of(1, 2, 3).pipe(debounceTime(47)); // $ExpectType Observable<number>
  });
  
  it('should support a scheduler', () => {
    const o = of(1, 2, 3).pipe(debounceTime(47, asyncScheduler)); // $ExpectType Observable<number>
  });
  
  it('should enforce types', () => {
    const o = of(1, 2, 3).pipe(debounceTime()); // $ExpectError
    const p = of(1, 2, 3).pipe(debounceTime('foo')); // $ExpectError
    const q = of(1, 2, 3).pipe(debounceTime(47, 'foo')); // $ExpectError
  });
  