concurrent-machines-0.2.1: Concurrent networked stream transducers

Safe HaskellSafe
LanguageHaskell2010

Data.Machine.Regulated

Description

Slow producers down to run at desired rates.

Synopsis

Documentation

regulated :: MonadIO m => Double -> ProcessT m a a Source

A pass-through process rate-limited to the given inter-step period in seconds. This may be used to slow down an upstream producer; it can not speed things up.