WriteBuffer

Documentation

data WriteBufferOpts rec m

Constructors

WriteBufferOpts

Fields

• maxBufferSize :: Int
• maxTimeToWait :: Integer
• bufferInputQueue :: TBMQueue rec
• onError :: SomeException -> m ()
• saveRecords :: [rec] -> m ()

makeBufferOpts :: MonadIO m => TBMQueue rec -> ([rec] -> m ()) -> WriteBufferOpts rec m

runWriteBuffer :: (MonadCatch m, MonadBaseControl IO m, MonadIO m) => WriteBufferOpts rec m -> m ThreadId