Documentation

Fields

• b_runEveryItems :: Maybe Int

  flush in memory items ever N items for processing

• b_runAfterTimeout :: Maybe TimeSpan

  flush after item stuck in queue for longer than this

• b_maxQueueLength :: Maybe Int

  if more than N items are enqueued, block enqueueing

• b_runBatch :: [v] -> m ()

  function describing how batches should be processed

Fields

• bh_enqueue :: v -> m ()

  enqueue a new element