Safe Haskell	None
Language	Haskell2010

Data.Conduit.Throttle.MBC

Synopsis

Documentation

data Conf a Source #

newConf :: Conf a Source #

setMeasure :: Measure a -> Conf a -> Conf a Source #

Set measure function in configuration.

setInterval :: Double -> Conf a -> Conf a Source #

Set interval in configuration.

setMaxThroughput :: Double -> Conf a -> Conf a Source #

Set max throughput in configuration.

setBufferSize :: Int -> Conf a -> Conf a Source #

Set buffer size in configuration.

setEmaAlpha :: Double -> Conf a -> Conf a Source #

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 () Source #

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.