how to correctly type a wrapper over Observable#pipe?

[bkkgbkjb]

say for some reason, I want to wrap the source event like process#message in my class
then provide a pipe api to MY USER like following

const rawSource$ = fromEvent(process, "message") as Observable<
  [string, ...unknown[]]
>;

class FromParent {
  source$ = rawSource$;

  // just overloads to make users happy
  pipe(): Observable<string>;
  pipe<A>(op1: OperatorFunction<string, A>): Observable<A>;
  pipe<A, B>(
    op1: OperatorFunction<string, A>,
    op2: OperatorFunction<A, B>
  ): Observable<B>;
  pipe<A, B, C>(
    op1: OperatorFunction<string, A>,
    op2: OperatorFunction<A, B>,
    op3: OperatorFunction<B, C>
  ): Observable<C>;

  // we provide our own pipe method, to enforce common logics like dataMapping, logging and fallback ErrorCatch
  pipe(...ops: OperatorFunction<any, any>[]) {
    return this.source$.pipe(
      map(([msg, ...rest]) => msg),
      tap((msg) => console.log(msg)),
      mergeMap((msg) =>
        of(msg)
          // !!! ts(2556) is thrown here!: A spread argument must either have a tuple type or be passed to a rest parameter.
          // My question: How to avoid ts type check error here
          .pipe(...ops)
          .pipe(
            catchError((e) => {
              console.error(e);
              return EMPTY;
            })
          )
      )
    );
  }
}

I'm using rxjs: ^7.3.0 and typescript: 4.4.2