Function useActionsQueue

lib/hooks/actions-queue.js:9–43

(
  performAction: (item: T) => mixed | Promise<mixed>,
  canProcess: boolean = true,
)

};

function useActionsQueue<T>(
  performAction: (item: T) => mixed | Promise<mixed>,
  canProcess: boolean = true,
): MessageQueueHook<T> {
  const [queue, setQueue] = React.useState<$ReadOnlyArray<T>>([]);
  const isProcessing = React.useRef(false);

  const process = React.useCallback(
    async (action: T) => {
      isProcessing.current = true;
      try {
        await performAction(action);
      } finally {
        isProcessing.current = false;
        setQueue(currentQueue => currentQueue.slice(1));
      }
    },
    [performAction],
  );

  const enqueue = React.useCallback(
    (items: $ReadOnlyArray<T>) =>
      setQueue(prevQueue => [...prevQueue, ...items]),
    [],
  );

  React.useEffect(() => {
    if (isProcessing.current || queue.length === 0 || !canProcess) {
      return;
    }
    void process(queue[0]);
  }, [process, queue, canProcess]);

  return { enqueue };
}

export { useActionsQueue };