我是rxjs和redux可观察的新手。
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是否正确?
您需要的是这样的东西
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(() => {});