From 1b2c21f537998edd28cb2c0d32c2d608d0bf28b7 Mon Sep 17 00:00:00 2001
From: Nicholas Jamieson <nicholas@cartant.com>
Date: Mon, 23 Jul 2018 22:20:40 +1000
Subject: [PATCH] fix(pipe): replace rest parameters overload

Replace the rest parameters overload with a signature that also includes
the A-I type parameters.

Closes #3841
---
 spec-dtslint/Observable-spec.ts | 4 ----
 src/internal/Observable.ts      | 4 ++--
 2 files changed, 2 insertions(+), 6 deletions(-)

diff --git a/spec-dtslint/Observable-spec.ts b/spec-dtslint/Observable-spec.ts
index da18cc61f2b..af57306ff56 100644
--- a/spec-dtslint/Observable-spec.ts
+++ b/spec-dtslint/Observable-spec.ts
@@ -52,10 +52,6 @@ describe('pipe', () => {
     const o = of('foo').pipe(a('1'), a('2'), a('3'), a('4'), a('5'), a('6'), a('7'), a('8'), a('9'), a('10')); // $ExpectType Observable<{}>
   });
 
-  it('should support an explicit type parameter for more than 9 arguments', () => {
-    const o = of('foo').pipe<string>(a('1'), a('2'), a('3'), a('4'), a('5'), a('6'), a('7'), a('8'), a('9'), a('10')); // $ExpectType Observable<string>
-  });
-
   it('should enforce types for the 1st argument', () => {
     const o = of('foo').pipe(a('#', '1')); // $ExpectError
   });
diff --git a/src/internal/Observable.ts b/src/internal/Observable.ts
index a60bcf83912..1f059f572d0 100644
--- a/src/internal/Observable.ts
+++ b/src/internal/Observable.ts
@@ -296,7 +296,7 @@ export class Observable<T> implements Subscribable<T> {
   pipe<A, B, C, D, E, F, G>(op1: OperatorFunction<T, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>, op7: OperatorFunction<F, G>): Observable<G>;
   pipe<A, B, C, D, E, F, G, H>(op1: OperatorFunction<T, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>, op7: OperatorFunction<F, G>, op8: OperatorFunction<G, H>): Observable<H>;
   pipe<A, B, C, D, E, F, G, H, I>(op1: OperatorFunction<T, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>, op7: OperatorFunction<F, G>, op8: OperatorFunction<G, H>, op9: OperatorFunction<H, I>): Observable<I>;
-  pipe<R>(...operations: OperatorFunction<any, any>[]): Observable<R>;
+  pipe<A, B, C, D, E, F, G, H, I, R>(op1: OperatorFunction<T, A>, op2: OperatorFunction<A, B>, op3: OperatorFunction<B, C>, op4: OperatorFunction<C, D>, op5: OperatorFunction<D, E>, op6: OperatorFunction<E, F>, op7: OperatorFunction<F, G>, op8: OperatorFunction<G, H>, op9: OperatorFunction<H, I>, ...operations: OperatorFunction<any, any>[]): Observable<R>;
   /* tslint:enable:max-line-length */
 
   /**
@@ -318,7 +318,7 @@ export class Observable<T> implements Subscribable<T> {
    *   .subscribe(x => console.log(x))
    * ```
    */
-  pipe<R>(...operations: OperatorFunction<T, R>[]): Observable<R> {
+  pipe<R>(...operations: OperatorFunction<any, any>[]): Observable<R> {
     if (operations.length === 0) {
       return this as any;
     }