import { of } from 'rxjs'; import { throwIfEmpty } from 'rxjs/operators'; it('should infer correctly', () => { const o = of('a', 'b', 'c').pipe(throwIfEmpty()); // $ExpectType Observable }); it('should support an errorFactory', () => { const o = of('a', 'b', 'c').pipe(throwIfEmpty(() => 47)); // $ExpectType Observable }); it('should enforce errorFactory type', () => { const o = of('a', 'b', 'c').pipe(throwIfEmpty('nope')); // $ExpectError const p = of('a', 'b', 'c').pipe(throwIfEmpty(x => 47)); // $ExpectError });