fromPromise cause "pipe is not a function" Redux-observable

Question

我是 rxjs 和 redux observable 的新手。

fromPromise 导致错误。

FCM.getFCMToken(( 是类似 fetch 的 API。它返回一个字符串。

我的代码如下。

import { fromPromise } from 'rxjs/observable/fromPromise';
const successLoginWithSessionTokenEpic = (action$: Observable<Action>, store: any) => action$.pipe(
  ofType(actions.SUCCESS_LOGIN_WITH_SESSION_TOKEN),
  fromPromise(FCM.getFCMToken().pipe(
    map((deviceToken: string) => actoins.updateDeviceToken(deviceToken)),
  )),
);

使用fromPromise的正确方法吗？

Answer 1

我认为您关闭括号的时间很晚，您要做的是按以下顺序执行函数：

fromPromise(( =

> obserbable => .pipe((

你需要的是这样的东西

import { fromPromise } from 'rxjs/observable/fromPromise';
const successLoginWithSessionTokenEpic = (action$: Observable<Action>, store: any) => action$.pipe(
  ofType(actions.SUCCESS_LOGIN_WITH_SESSION_TOKEN),
  fromPromise(FCM.getFCMToken()).pipe(
    map((deviceToken: string) => actions.updateDeviceToken(deviceToken))
  ).subscribe(() => {});