redux-observable-other-actions.js

// Throttling
const inputEpic = (action$) =>
  action$.ofType('INPUT_CHANGED')
    .throttleTime(500)
    ...
    
// Deboucing
const inputEpic = (action$) =>
  action$.ofType('INPUT_CHANGED')
    .debounceTime(500)
    ...
    
// Retry 5 times without waiting
const inputEpic = (action$) =>
  action$.ofType('INPUT_CHANGED')
    .retry(5)
    ...
    
// Retry 5 times with waiting for 2 seconds
const inputEpic = (action$) =>
  action$.ofType('INPUT_CHANGED')
    .retryWhen(function(errors) {
        return errors
          .delay(2000)
          .scan((errorCount, err) => {
            if(errorCount >= 2) {
                throw err;
            }
            return errorCount + 1;
          }, 0);
    })
    ...