#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 в качестве параметра и не заботится о том, что возвращает восходящий поток, что означает, что вы не можете использовать полезную нагрузку из восходящего потока.