Control.Batch

Documentation

data Batch v m

Constructors

Batch

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

data BatchHandle v m

Constructors

BatchHandle

Fields

• bh_enqueue :: v -> m ()

  enqueue a new element

withBatchRunner :: forall v m a. MonadBaseControl IO m => Batch v m -> (BatchHandle v m -> m a) -> m a