Redux Observables / RxJS: Как создать эпос, который возвращает разные действия, основываясь на if / else?

Question

Я пытаюсь подключить свое приложение к покупкам в приложении, используя это: https://github.com/chirag04/react-native-in-app-utils

У меня есть эпопея, где я хочу излучать успех, если он успешен, и провал, если он терпит неудачу. Что-то вроде этого:

import 'rxjs';
import { InAppUtils } from 'NativeModules';

import * as packagesActions from '../ducks/packages';
import * as subscriptionActions from '../ducks/subscription';

export default function createSubscription(action$, store) {
  return action$.ofType(packagesActions.SELECT)
    .mergeMap(action => {
      const productId = action.payload;
      InAppUtils.purchaseProduct(productId, (error, response) => {
        if(response && response.productIdentifier) {
          return subscriptionActions.subscribeSuccess();
        } else {
          return subscriptionActions.subscribeFailure();
        }
      });
    });
};

Однако я не уверен, как написать содержимое mergeMap, Есть ли способ сделать это?

Answer 1

InAppUtils.purchaseProduct кажется, использует обратный вызов в стиле Node. Существует статический метод RxJS, который можно использовать для создания наблюдаемого из такого вызова API: bindNodeCallback,

В вашем mergeMap, вы должны быть в состоянии сделать что-то вроде этого

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/bindNodeCallback';
import 'rxjs/add/observable/of';

...
.mergeMap(action => {
  const productId = action.payload;
  const bound = Observable.bindNodeCallback((callback) => InAppUtils.purchaseProduct(productId, callback));
  return bound()
    .map(response => subscriptionActions.subscribeSuccess())
    .catch(error => Observable.of(subscriptionActions.subscribeFailure()));
});