Data.Conduit.Throttle.MBC

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 :: (MonadIO m, MonadBaseControl IO m, MonadResource m) => Conf o -> ConduitM () o m () -> ConduitM () o m ()

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.