Does not handle pipeable ofType

[mwoodsmall]

In the following test case, it fails to determine the input action for the effect.

  test1$ = this.actions$
    .pipe(
      ofType('LOGIN'),
      map(data => ({ type: 'LOGIN_SUCCESS', payload: data })),
      catchError(() => of({ type: 'LOGIN_FAILED' }))
    );

and instead sets the input action to undefined