Safe Haskell | None |
---|---|
Language | Haskell2010 |
Data.Conduit.Throttle
- data Conf a
- newConf :: Conf a
- setMeasure :: Measure a -> Conf a -> Conf a
- setInterval :: Double -> Conf a -> Conf a
- setMaxThroughput :: Double -> Conf a -> Conf a
- setBufferSize :: Int -> Conf a -> Conf a
- setEmaAlpha :: Double -> Conf a -> Conf a
- throttleProducer :: (MonadUnliftIO m, MonadResource m) => Conf o -> ConduitM () o m () -> ConduitM () o m ()
Documentation
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 o -> ConduitM () o m () -> ConduitM () o m () #