Проблема в эффектах NGX путем передачи полезной нагрузки в concatMapTo [действия]

#rxjs #ngrx #ngrx-effects #rxjs-observables

#rxjs #ngrx #ngrx-эффекты #rxjs-наблюдаемые

Вопрос:

Ниже приведен эффект, используемый для запуска некоторых действий при загрузке приложения. Когда я запускаю приведенный ниже код, он выдает ошибку.

 
@Injectable()
export class BootStrapEffects {
  bootStrap$ = createEffect(() => {
    return this.actions$.pipe(
      ofType(GetPrefSuccess),
      map((action) => action.payload),
      concatMapTo((payload: any) => [
        GetUser(payload.parsed.userId),
        GetMenu(payload.parsed.language),
      ])
    )
  })

  constructor(private actions$: Actions) {}
}
  

Приведенный выше код выдает ошибку ниже

 
error TypeError: You provided 'function (payload) { return [
                Object(_app_store_actions_account_action__WEBPACK_IMPORTED_MODULE_3__["GetUser"])(),
                Object(_app_store_actions_product_action__WEBPACK_IMPORTED_MODULE_7__["GetMenu"])()

  ]; }' where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.
  

Из TSLint

 Argument of type '() => Observable<never>' is not assignable to parameter of type '() => never'.
  Type 'Observable<never>' is not assignable to type 'never'.ts(2345)
  

Кто-нибудь может помочь мне устранить эту ошибку?

Ответ №1:

Вы можете попробовать заменить, concatMapTo на concatMap
concatMapTo принимает observable в качестве параметра и не заботится о том, что возвращает восходящий поток, что означает, что вы не можете использовать полезную нагрузку из восходящего потока.