javascript 无状态Redux-Observable

Posted 2021-05-03

import { filter, mergeMap } from 'rxjs/operators'
import { from, pipe, Subject } from 'rxjs'

export const action$ = new Subject()

export const createRootEpic = (
  ...epics
) => (
  from(epics)
  .pipe(
    mergeMap(epic => (
      epic(action$)
    )),
  )
)

export const ofType = (
  ...requiredTypes
) => (
  pipe(
    filter(Boolean),
    filter(action => (
      action
      .type
    )),
    filter(({ type }) => (
      requiredTypes
      .includes(type)
    )),
  )
)

const rootEpic = (
  createRootEpic(
    actionLoggerEpic,
    onMessageEpic,
    storeDataEpic,
  )
)

rootEpic
.subscribe(action$)