使用redux observable和firebase执行异步操作的正确方式是什么？

npm install redux-observable firebase rxjs --save

import { ofType } from 'redux-observable';
import { mergeMap } from 'rxjs/operators';
import { firebase } from '@firebase/app';
import '@firebase/database';

// 创建一个Epic来处理异步操作
const myEpic = action$ =>
  action$.pipe(
    ofType('FETCH_DATA'), // 监听FETCH_DATA action
    mergeMap(action => {
      // 使用firebase API执行异步操作
      return firebase
        .database()
        .ref('/data')
        .once('value')
        .then(snapshot => {
          const data = snapshot.val();
          // 返回一个新的action，将数据传递给Reducer进行更新
          return { type: 'FETCH_DATA_SUCCESS', payload: data };
        })
        .catch(error => {
          // 返回一个新的action，将错误信息传递给Reducer进行处理
          return { type: 'FETCH_DATA_ERROR', payload: error.message };
        });
    })
  );

export default myEpic;

import { createEpicMiddleware } from 'redux-observable';
import { createStore, applyMiddleware } from 'redux';
import myEpic from './myEpic';
import rootReducer from './rootReducer';

// 创建redux observable中间件
const epicMiddleware = createEpicMiddleware();

// 创建store，并将epicMiddleware添加到中间件中
const store = createStore(rootReducer, applyMiddleware(epicMiddleware));

// 运行Epic
epicMiddleware.run(myEpic);

export default store;