使用redux-saga进行轮询

// pollingSaga.js

import { put, call, delay, takeEvery } from 'redux-saga/effects';
import { fetchDataSuccess, fetchDataFailure } from './actions';

// 轮询逻辑
function* pollData() {
  try {
    while (true) {
      // 发起异步请求
      const response = yield call(fetch, 'https://api.example.com/data');
      const data = yield response.json();

      // 处理成功响应
      yield put(fetchDataSuccess(data));

      // 延迟一段时间后再次轮询
      yield delay(5000);
    }
  } catch (error) {
    // 处理错误响应
    yield put(fetchDataFailure(error));
  }
}

// 监听特定的action，并执行轮询逻辑
function* watchPollData() {
  yield takeEvery('START_POLLING', pollData);
}

export default function* rootSaga() {
  yield watchPollData();
}

// index.js

import { createStore, applyMiddleware } from 'redux';
import createSagaMiddleware from 'redux-saga';
import rootReducer from './reducers';
import rootSaga from './sagas';

// 创建saga中间件
const sagaMiddleware = createSagaMiddleware();

// 创建store并应用中间件
const store = createStore(rootReducer, applyMiddleware(sagaMiddleware));

// 启动saga
sagaMiddleware.run(rootSaga);