return errors => range(1, 10).pipe(
        zip(errors, (i, err) => {
            if (i == 10) {
                throw err;
            }

            return i;
        }),
        flatMap(i => timer(i * 1000)),
    )

    it('should initially return the same value for streaming and non-streaming get', (done: Function) => {
        translations = {"TEST": "This is a test"};
        translate.use('en');

        translate.stream('TEST').pipe(zip(translate.get('TEST'))).subscribe((value: [string, string]) => {
            const [streamed, nonStreamed] = value;
            expect(streamed).toEqual('This is a test');
            expect(streamed).toEqual(nonStreamed);
            done();
        });
    });

  ngOnInit() {

    this.text = `Bacon ipsum dolor amet tongue short loin short ribs pork chop drumstick picanha 
            pancetta shank cow shoulder salami corned beef swine pig sausage. Rump flank 
            sirloin kielbasa jowl chuck sausage jerky short loin chicken. Flank sirloin frankfurter 
            corned beef turducken. Beef ribs salami ribeye, t-bone meatloaf flank jerky tongue turkey`;

    this.typewriter$ = from(this.text.split(''))
      .pipe(scan((acc, curr) => acc + curr))
      // @ts-ignore
      .pipe(zip(interval(50), x => x));

  }

 retryWhen(attempts => range(1, maxTries)
   .pipe(
     zip(attempts, (i) => i),
     map(i => i * i),
     mergeMap(i =>  timer(i * ms))
   )

it('should support rest parameter observables with type parameters', () => {
  const o = of(1); // $ExpectType Observable<number>
  const z = [of(2)]; // $ExpectType Observable<number>[]
  const a = o.pipe(zip<number, number[]>(...z)); // $ExpectType Observable<number[]>
});