Data.Conduit.Throttle

Documentation

data Conf a

newConf :: Conf a

setMeasure :: Measure a -> Conf a -> Conf a

Set measure function in configuration.

setInterval :: Double -> Conf a -> Conf a

Set interval in configuration.

setMaxThroughput :: Double -> Conf a -> Conf a

Set max throughput in configuration.

setBufferSize :: Int -> Conf a -> Conf a

Set buffer size in configuration.

setEmaAlpha :: Double -> Conf a -> Conf a

Set exponential weight factor used for computing current item size.

throttleProducer :: (MonadUnliftIO m, MonadResource m) => Conf a -> Producer m a -> Producer m a

Given a ThrottleConf and a Producer, create and return a new Producer, which yields the same stream of values like the provided producer but throttled according to the provided throttling configuration.