vldvel

const store = createStore(
  rootReducer,
  compose(applyMiddleware(/** other middlewares */, getWeatherDataMiddleware))
);

vldvel

const getWeatherDataTimedout = async dispatch => {
  await getWeatherData()(dispatch);

  setTimeout(() => updateMessages(dispatch), 30 * 1000);
};

const getWeatherDataMiddleware = ({ dispatch }) => next => {
  getWeatherDataTimedout(dispatch);

  return action => next(action);

vldvel

export const initActions = async dispatch => {
  let updateTimeout;
  
  getWeatherDataTimedout = async () => {
    await dispatch(getWeatherData());

    updateTimeout = setTimeout(getWeatherDataTimedout, 30 * 1000);
  }
  
  /** Initialize any other actions */

vldvel

class WeatherApp extends React.Component {
  updateTimeout;
  
  componentDidMount() {
    this.getWeatherData();
  }
  
  getWeatherData = async () => {
    await this.props.getWeatherData();

vldvel

class WeatherApp extends Rect.Component {
  updateInterval;
  
  componentDidMount() {
    this.updateInterval = setInterval(() => {
      this.props.getWeatherData();
    }, 1000 * 30); // 30 seconds
  }
  
  componentWillUnmount() {

vldvel

const EnumStatus = {
  LOADED: 'LOADED',
  LOADING: 'LOADING',
  FAILED: 'FAILED'
}

const state = {
  subState_1: {
    data: any,
    status: EnumStatus

vldvel

const store = createStore(
  rootReducer,
  compose(applyMiddleware(/** other middlewares */, updateMessagesMiddleware))
);

vldvel

const updateMessagesMiddleware = ({ dispatch }) => next => {
  const updateMessages = async () => {
    await getNewMessages()(dispatch);
    setTimeout(updateMessages, 500);
  };

  updateMessages();

  return action => next(action);
};

vldvel

export const initActions = async dispatch => {
  let updateTimeout;
  
  updateMessages = async () => {
    await dispatch(getNewMessages());
    updateTimeout = setTimeout(updateMessages, 500);
  }
  
  updateMessages();
}

vldvel

class NewMessages extends React.PureComponent {
  updateTimeout;
  
  componentDidMount() {
    this.updateMessages();
  }
  
  updateMessages = async () => {
    // thunk
    await this.props.getNewMessages(); // waiting for request