A Flux Dispatcher with an Action Queue sitting on top to allow dispatching actions at any time.

AppDispatcher.js

/**
 * Create an ActionQueue and dispatch each synchronously
 * @author tgroshon
 * 
 * See an alternate implementation using ASync from
 * https://github.com/facebook/flux/issues/106
 * by fabiozaffani
 */
import {Dispatcher} from 'flux'

var dispatcher = new Dispatcher()
var actionQueue = []
var isProcessing = false

function queueAction(payload) {
  actionQueue.push(payload)
  if (!isProcessing) {
    startProcessing()
  }
}

function startProcessing() {
  isProcessing = true
  while (actionQueue.length > 0) {
    if (dispatcher.isDispatching()) {
      return setTimeout(startProcessing, 100) // Be safe; Avoid an Invariant error from Flux
    }
    var payload = actionQueue.shift()
    dispatcher.dispatch(payload)
  }
  isProcessing = false
}

var AppDispatcher = {
  isProcessing() {
    return isProcessing
  },

  dispatch(payload) {
    queueAction(payload)
  },

  register(callback) {
    return dispatcher.register(callback)
  }
}

module.exports = AppDispatcher