Запустите несколько действий и подождите, пока они разрешат RxJS / Redux Observables - PullRequest
Новая
       29

Запустите несколько действий и подождите, пока они разрешат RxJS / Redux Observables

0 голосов
/ 11 февраля 2019

У меня есть действие, которое я хочу использовать для инициализации своего приложения, я хочу создать эпос для этого действия, а затем запустить несколько других действий за его пределами, дождаться их завершения и запустить другое действие.Я посмотрел на другие вопросы, и это очень похоже на этот один

Я попробовал этот подход, и для меня, он не работает, тогда запускается действие APP_INITно затем не запускает другие действия в последовательности.Кто-нибудь может помочь? 

import { of } from 'rxjs';
import { mergeMap, zip, concat, mapTo } from 'rxjs/operators';
import { ofType } from 'redux-observable';
import { firstAction, secondAction } from 'actions';

export default function appInit (action$) {
  return (
    action$.pipe(
      ofType('APP_INIT'),
      mergeMap(() =>
        concat(
          of(firstAction()),
          of(secondAction()),
          zip(
            action$.ofType('ACTION_ONE_COMPLETE'),
            action$.ofType('ACTION_TWO_COMPLETE')
          ).mapTo(() => console.log('complete'))
        )
      )
    )
  );
}

Ответы [ 2 ]

0 голосов
/ 11 февраля 2019

Оказывается, мой код был довольно хорошо в первую очередь, основной причиной было то, что я импортировал concat из rxjs/operators, когда я должен был импортировать из rxjs напрямую, мне потребовались часы, чтобы понять, нотеперь он работает.

Полный код ниже для всех, кому это может помочь. 

import { of, concat, zip } from 'rxjs';
import { mergeMap, map, take } from 'rxjs/operators';
import { ofType } from 'redux-observable';

import { appInitialisationComplete, APP_INITIALISATION } from 'client/actions/app/app';
import { actionOne, ACTION_ONE_COMPLETE } from 'client/actions/action-one/action-one';
import { actioTwo, ACTION_TWO_COMPLETE } from 'client/actions/action-two/action-two';

/**
 * appInitialisationEpic
 * @param  {Object} action$
 * @return {Object}
 */
export default function appInitialisationEpic (action$) {
  return (
    action$.pipe(
      ofType(APP_INITIALISATION),
      mergeMap(() =>
        concat(
          of(actionOne()),
          of(actioTwo()),
          zip(
            action$.ofType(ACTION_ONE_COMPLETE).pipe(take(1)),
            action$.ofType(ACTION_TWO_COMPLETE).pipe(take(1))
          )
            .pipe(map(() => appInitialisationComplete()))
        )
      )
    )
  );
}
0 голосов
/ 11 февраля 2019

объединитьПоследний - это то, что вы хотите, и которое будет излучаться только тогда, когда все наблюдаемые излучают. 

const { combineLatest, of } = rxjs;
const { delay } = rxjs.operators;

combineLatest(
  of(1),
  of(2).pipe(delay(2000)),
  of(3).pipe(delay(1000))
).subscribe(([a,b,c]) => {
  console.log(`${a} ${b} ${c}`); // Will take 2 seconds as that is when all have emitted
});
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.4.0/rxjs.umd.min.js"></script>
...