Data.Buffer

A buffer for batched write operations. Push individual items into the buffer and provide an operation that writes out batches of them.

Buffer

data Buffer a

A buffer for write operations.

new :: Settings a -> IO (Buffer a)

Creates a new Buffer.

push :: Buffer a -> a -> IO ()

Push a new item into the buffer.

flush :: Buffer a -> IO ()

Flush the current contents of the buffer.

Settings

data Settings a

Configuration settings for a new Buffer.

defaultSettings :: Settings a

Default Buffer settings. A buffer created by these settings has a size of 1 and writes items out as soon as they come in.

write :: Settings a -> NonEmpty a -> IO ()

Function to write a batch of items.

size :: Settings a -> Natural

The maximum amount of items to write in a single batch.

frequencyInMicroSeconds :: Settings a -> Int

The frequency with which the buffer gets flushed automatically.